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"

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