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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskSchemas.Builder

Method Summary

Methods

Modifier and Type	Method and Description
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()