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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PartitionCollapsingSchemas
public PartitionCollapsingSchemas(TaskSchemas schemas,
java.util.Map<java.lang.String,org.apache.avro.Schema> inputSchemas,
java.lang.String outputSchemaName,
java.lang.String outputSchemaNamespace)
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()
Matthew Hayes