public class StreamsFilterRel extends StormFilterRelBase implements StreamsRel
| Constructor and Description |
|---|
StreamsFilterRel(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
org.apache.calcite.rel.RelNode child,
org.apache.calcite.rex.RexNode condition) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.calcite.rel.core.Filter |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode input,
org.apache.calcite.rex.RexNode condition) |
void |
streamsPlan(StreamsPlanCreator planCreator) |
accept, computeSelfCost, copy, estimateFilteredRows, estimateFilteredRows, estimateRowCount, explainTerms, getChildExps, getCondition, isValidchildrenAccept, deriveRowType, getInput, getInputs, replaceInputaccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, explain, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, metadata, onRegister, recomputeDigest, register, sole, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaccept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInputpublic StreamsFilterRel(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
org.apache.calcite.rel.RelNode child,
org.apache.calcite.rex.RexNode condition)
public org.apache.calcite.rel.core.Filter copy(org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode input,
org.apache.calcite.rex.RexNode condition)
copy in class org.apache.calcite.rel.core.Filterpublic void streamsPlan(StreamsPlanCreator planCreator) throws Exception
streamsPlan in interface StreamsRelExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.