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
java.lang.String _outputSchemaName
java.lang.String _outputSchemaNamespace
java.util.Map<K,V> conf
java.util.Map<K,V> _inputSchemas
java.lang.String _outputSchemaName
java.lang.String _outputSchemaNamespace
java.util.Map<K,V> conf
java.util.Map<K,V> _inputSchemas