public abstract class GenericFlatTypePostPass<X,T extends AbstractSchema<X>> extends Object implements OptimizerPostPass
Constructor and Description |
---|
GenericFlatTypePostPass() |
Modifier and Type | Method and Description |
---|---|
protected abstract TypeComparatorFactory<?> |
createComparator(FieldList fields,
boolean[] directions,
T schema) |
protected abstract T |
createEmptySchema() |
protected abstract TypePairComparatorFactory<?,?> |
createPairComparator(FieldList fields1,
FieldList fields2,
boolean[] sortDirections,
T schema1,
T schema2) |
protected abstract TypeSerializerFactory<?> |
createSerializer(T schema) |
protected abstract void |
getDualInputNodeSchema(DualInputPlanNode node,
T input1Schema,
T input2Schema) |
protected abstract void |
getSingleInputNodeSchema(SingleInputPlanNode node,
T schema) |
protected abstract void |
getSinkSchema(SinkPlanNode sink,
T schema) |
boolean |
isPropagateParentSchemaDown() |
void |
postPass(OptimizedPlan plan)
Central post processing function.
|
void |
setPropagateParentSchemaDown(boolean propagateParentSchemaDown) |
protected void |
traverse(PlanNode node,
T parentSchema,
boolean createUtilities) |
public boolean isPropagateParentSchemaDown()
public void setPropagateParentSchemaDown(boolean propagateParentSchemaDown)
public void postPass(OptimizedPlan plan)
OptimizerPostPass
postPass
in interface OptimizerPostPass
plan
- The plan to be post processed.protected abstract T createEmptySchema()
protected abstract void getSinkSchema(SinkPlanNode sink, T schema) throws CompilerPostPassException, ConflictingFieldTypeInfoException
protected abstract void getSingleInputNodeSchema(SingleInputPlanNode node, T schema) throws CompilerPostPassException, ConflictingFieldTypeInfoException
protected abstract void getDualInputNodeSchema(DualInputPlanNode node, T input1Schema, T input2Schema) throws CompilerPostPassException, ConflictingFieldTypeInfoException
protected abstract TypeSerializerFactory<?> createSerializer(T schema) throws MissingFieldTypeInfoException
MissingFieldTypeInfoException
protected abstract TypeComparatorFactory<?> createComparator(FieldList fields, boolean[] directions, T schema) throws MissingFieldTypeInfoException
MissingFieldTypeInfoException
protected abstract TypePairComparatorFactory<?,?> createPairComparator(FieldList fields1, FieldList fields2, boolean[] sortDirections, T schema1, T schema2) throws MissingFieldTypeInfoException
MissingFieldTypeInfoException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.