datafu.hourglass.schemas
Class TaskSchemas
java.lang.Object
datafu.hourglass.schemas.TaskSchemas
public class TaskSchemas
- extends java.lang.Object
Contains the Avro schemas for the key, intermediate value, and output value of a job.
The mapper and combiner output key-value pairs conforming to the key and intermediate
value schemas defined here.
The reducer outputs key-value pairs conforming to the key and output value schemas.
- Author:
- "Matthew Hayes"
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
getKeySchema
public org.apache.avro.Schema getKeySchema()
getIntermediateValueSchema
public org.apache.avro.Schema getIntermediateValueSchema()
getOutputValueSchema
public org.apache.avro.Schema getOutputValueSchema()
Matthew Hayes