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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PartitionPreservingSchemas
public PartitionPreservingSchemas(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()
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()
Matthew Hayes