Uses of Interface
datafu.hourglass.model.Merger

Packages that use Merger

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 Merger in datafu.hourglass.jobs

Methods in datafu.hourglass.jobs that return Merger

Merger<org.apache.avro.generic.GenericRecord>	AbstractPartitionCollapsingIncrementalJob.getOldRecordMerger() Gets the record merger that is capable of unmerging old partial output from the new output.
Merger<org.apache.avro.generic.GenericRecord>	PartitionCollapsingIncrementalJob.getOldRecordMerger()
Merger<org.apache.avro.generic.GenericRecord>	AbstractPartitionCollapsingIncrementalJob.getRecordMerger() Gets the record merger that is capable of merging previous output with a new partial output.
Merger<org.apache.avro.generic.GenericRecord>	PartitionCollapsingIncrementalJob.getRecordMerger()

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

void	PartitionCollapsingIncrementalJob.setMerger(Merger<org.apache.avro.generic.GenericRecord> merger) Sets the record merger that is capable of merging previous output with a new partial output.
void	PartitionCollapsingIncrementalJob.setOldMerger(Merger<org.apache.avro.generic.GenericRecord> oldMerger) Sets the record merger that is capable of unmerging old partial output from the new output.

Uses of Merger in datafu.hourglass.mapreduce

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

void	CollapsingReducer.setOldRecordMerger(Merger<org.apache.avro.generic.GenericRecord> merger)
void	CollapsingReducer.setRecordMerger(Merger<org.apache.avro.generic.GenericRecord> merger)