AccumulatorMetrics

records

accumulators

spark

add

BitFlags ByKeyAdditiveAccumulator

addMessagesFor

Issue

allIssues

RecordsRichDataset

allRecordFields

RecordEnvironment

apply

FlatRecordEnvironment PartitionedRecordEnvironment SimpleDriverContext SimpleJobContext