|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use PartitionPreservingSchemas | |
|---|---|
| datafu.hourglass.mapreduce | Implementations of mappers, combiners, and reducers used by incremental jobs. |
| Uses of PartitionPreservingSchemas in datafu.hourglass.mapreduce |
|---|
| Methods in datafu.hourglass.mapreduce that return PartitionPreservingSchemas | |
|---|---|
PartitionPreservingSchemas |
PartitioningMapper.getSchemas()
Gets the Avro schemas. |
PartitionPreservingSchemas |
PartitioningReducer.getSchemas()
Gets the Avro schemas |
| Methods in datafu.hourglass.mapreduce with parameters of type PartitionPreservingSchemas | |
|---|---|
void |
PartitioningMapper.setSchemas(PartitionPreservingSchemas schemas)
Sets the Avro schemas. |
void |
PartitioningReducer.setSchemas(PartitionPreservingSchemas schemas)
Sets the Avro schemas. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||