|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Mapper | |
---|---|
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 Mapper in datafu.hourglass.jobs |
---|
Methods in datafu.hourglass.jobs that return Mapper | |
---|---|
abstract Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> |
AbstractPartitionCollapsingIncrementalJob.getMapper()
Gets the mapper. |
abstract Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> |
AbstractPartitionPreservingIncrementalJob.getMapper()
Gets the mapper. |
Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> |
PartitionCollapsingIncrementalJob.getMapper()
|
Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> |
PartitionPreservingIncrementalJob.getMapper()
|
Methods in datafu.hourglass.jobs with parameters of type Mapper | |
---|---|
void |
PartitionCollapsingIncrementalJob.setMapper(Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> mapper)
Set the mapper. |
void |
PartitionPreservingIncrementalJob.setMapper(Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> mapper)
Set the mapper. |
Uses of Mapper in datafu.hourglass.mapreduce |
---|
Methods in datafu.hourglass.mapreduce that return Mapper | |
---|---|
Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> |
CollapsingMapper.getMapper()
Gets the mapper. |
Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> |
PartitioningMapper.getMapper()
Gets the mapper. |
Methods in datafu.hourglass.mapreduce with parameters of type Mapper | |
---|---|
void |
CollapsingMapper.setMapper(Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> mapper)
Sets the mapper. |
void |
PartitioningMapper.setMapper(Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> mapper)
Sets the mapper. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |