datafu.hourglass.schemas
Class PartitionCollapsingSchemas

java.lang.Object
  datafu.hourglass.schemas.PartitionCollapsingSchemas

All Implemented Interfaces:

java.io.Serializable

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

Generates the Avro schemas used by AbstractPartitionCollapsingIncrementalJob and its derivations.

Author:

"Matthew Hayes"

See Also:

Serialized Form

Constructor Summary

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

PartitionCollapsingSchemas

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

getKeySchema

public org.apache.avro.Schema getKeySchema()

getMapOutputKeySchema

public org.apache.avro.Schema getMapOutputKeySchema()

getReduceOutputSchema

public org.apache.avro.Schema getReduceOutputSchema()

getDatedIntermediateValueSchema

public org.apache.avro.Schema getDatedIntermediateValueSchema()

getOutputValueSchema

public org.apache.avro.Schema getOutputValueSchema()

getIntermediateValueSchema

public org.apache.avro.Schema getIntermediateValueSchema()

getMapOutputValueSchema

public org.apache.avro.Schema getMapOutputValueSchema()