public class PartitionCollapsingSchemas
extends java.lang.Object
implements java.io.Serializable
AbstractPartitionCollapsingIncrementalJob
and its derivations.Constructor and Description |
---|
PartitionCollapsingSchemas(TaskSchemas schemas,
java.util.Map<java.lang.String,org.apache.avro.Schema> inputSchemas,
java.lang.String outputSchemaName,
java.lang.String outputSchemaNamespace) |
Modifier and Type | Method and Description |
---|---|
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() |
public PartitionCollapsingSchemas(TaskSchemas schemas, java.util.Map<java.lang.String,org.apache.avro.Schema> inputSchemas, java.lang.String outputSchemaName, java.lang.String outputSchemaNamespace)
public java.util.Map<java.lang.String,org.apache.avro.Schema> getMapInputSchemas()
public org.apache.avro.Schema getMapOutputSchema()
public org.apache.avro.Schema getKeySchema()
public org.apache.avro.Schema getMapOutputKeySchema()
public org.apache.avro.Schema getReduceOutputSchema()
public org.apache.avro.Schema getDatedIntermediateValueSchema()
public org.apache.avro.Schema getOutputValueSchema()
public org.apache.avro.Schema getIntermediateValueSchema()
public org.apache.avro.Schema getMapOutputValueSchema()