Accumulator<In,Out> _accumulator
boolean _reusePreviousOutput
PartitionCollapsingSchemas _schemas
long _beginTime
long _endTime
boolean _reusePreviousOutput
PartitionCollapsingSchemas _schemas
Mapper<In,OutKey,OutVal> _mapper
long _beginTime
long _endTime
Accumulator<In,Out> _newAccumulator
Accumulator<In,Out> _oldAccumulator
Merger<T> _merger
Merger<T> _oldMerger
boolean _reusePreviousOutput
PartitionCollapsingSchemas _schemas
Accumulator<In,Out> accumulator
Mapper<In,OutKey,OutVal> _mapper
PartitionPreservingSchemas _schemas
PartitionPreservingSchemas _schemas
Accumulator<In,Out> accumulator