datafu.hourglass.schemas
Class PartitionPreservingSchemas

java.lang.Object
  datafu.hourglass.schemas.PartitionPreservingSchemas

All Implemented Interfaces:

java.io.Serializable

public class PartitionPreservingSchemas
extends java.lang.Object
implements java.io.Serializable

Generates the Avro schemas used by AbstractPartitionPreservingIncrementalJob and its derivations.

Author:

"Matthew Hayes"

See Also:

Serialized Form

Constructor Summary

PartitionPreservingSchemas(TaskSchemas schemas, java.util.Map<java.lang.String,org.apache.avro.Schema> inputSchemas, java.lang.String outputSchemaName, java.lang.String outputSchemaNamespace)

Method Summary

org.apache.avro.Schema	getIntermediateValueSchema()
org.apache.avro.Schema	getKeySchema()
java.util.Map<java.lang.String,org.apache.avro.Schema>	getMapInputSchemas()
org.apache.avro.Schema	getMapOutputKeySchema()
org.apache.avro.Schema	getMapOutputSchema()
org.apache.avro.Schema	getMapOutputValueSchema()
org.apache.avro.Schema	getOutputValueSchema()
org.apache.avro.Schema	getReduceOutputSchema()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionPreservingSchemas

public PartitionPreservingSchemas(TaskSchemas schemas,
                                  java.util.Map<java.lang.String,org.apache.avro.Schema> inputSchemas,
                                  java.lang.String outputSchemaName,
                                  java.lang.String outputSchemaNamespace)

Method Detail

getMapInputSchemas

public java.util.Map<java.lang.String,org.apache.avro.Schema> getMapInputSchemas()

getMapOutputSchema

public org.apache.avro.Schema getMapOutputSchema()

getReduceOutputSchema

public org.apache.avro.Schema getReduceOutputSchema()

getOutputValueSchema

public org.apache.avro.Schema getOutputValueSchema()

getKeySchema

public org.apache.avro.Schema getKeySchema()

getMapOutputKeySchema

public org.apache.avro.Schema getMapOutputKeySchema()

getIntermediateValueSchema

public org.apache.avro.Schema getIntermediateValueSchema()

getMapOutputValueSchema

public org.apache.avro.Schema getMapOutputValueSchema()