|
||||||||||
| 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 | |||||||||