datafu.hourglass.schemas
Class TaskSchemas

java.lang.Object
  extended by 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"

Nested Class Summary
static class TaskSchemas.Builder
           
 
Method Summary
 org.apache.avro.Schema getIntermediateValueSchema()
           
 org.apache.avro.Schema getKeySchema()
           
 org.apache.avro.Schema getOutputValueSchema()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getKeySchema

public org.apache.avro.Schema getKeySchema()

getIntermediateValueSchema

public org.apache.avro.Schema getIntermediateValueSchema()

getOutputValueSchema

public org.apache.avro.Schema getOutputValueSchema()


Matthew Hayes