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.

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Methods

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