Uses of Interface
datafu.hourglass.model.Accumulator

Packages that use Accumulator

datafu.hourglass.jobs	Incremental Hadoop jobs and some supporting classes.
datafu.hourglass.mapreduce	Implementations of mappers, combiners, and reducers used by incremental jobs.

Uses of Accumulator in datafu.hourglass.jobs

Methods in datafu.hourglass.jobs that return Accumulator

Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	AbstractPartitionCollapsingIncrementalJob.getCombinerAccumulator() Gets the accumulator used for the combiner.
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	AbstractPartitionPreservingIncrementalJob.getCombinerAccumulator() Gets the accumulator used for the combiner.
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	PartitionCollapsingIncrementalJob.getCombinerAccumulator()
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	PartitionPreservingIncrementalJob.getCombinerAccumulator()
abstract Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	AbstractPartitionCollapsingIncrementalJob.getReducerAccumulator() Gets the accumulator used for the reducer.
abstract Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	AbstractPartitionPreservingIncrementalJob.getReducerAccumulator() Gets the accumulator used for the reducer.
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	PartitionCollapsingIncrementalJob.getReducerAccumulator()
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	PartitionPreservingIncrementalJob.getReducerAccumulator()

Methods in datafu.hourglass.jobs with parameters of type Accumulator

void	PartitionCollapsingIncrementalJob.setCombinerAccumulator(Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> combiner) Set the accumulator for the combiner
void	PartitionPreservingIncrementalJob.setCombinerAccumulator(Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> combiner) Set the accumulator for the combiner
void	PartitionCollapsingIncrementalJob.setReducerAccumulator(Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> reducer) Set the accumulator for the reducer.
void	PartitionPreservingIncrementalJob.setReducerAccumulator(Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> reducer) Set the accumulator for the reducer.

Uses of Accumulator in datafu.hourglass.mapreduce

Methods in datafu.hourglass.mapreduce that return Accumulator

Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	CollapsingCombiner.getAccumulator() Gets the accumulator used to perform aggregation.
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	PartitioningCombiner.getAccumulator() Gets the accumulator used to perform aggregation.
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	PartitioningReducer.getAccumulator() Gets the accumulator used to perform aggregation.
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	CollapsingReducer.getNewAccumulator()
Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>	CollapsingReducer.getOldAccumulator()

Methods in datafu.hourglass.mapreduce with parameters of type Accumulator

void	CollapsingCombiner.setAccumulator(Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> acc) Sets the accumulator used to perform aggregation.
void	CollapsingReducer.setAccumulator(Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> acc)
void	PartitioningCombiner.setAccumulator(Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> acc) Sets the accumulator used to perform aggregation.
void	PartitioningReducer.setAccumulator(Accumulator<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> acc) Sets the accumulator used to perform aggregation.