Package | Description |
---|---|
org.apache.flink.optimizer.dag | |
org.apache.flink.optimizer.operators |
Modifier and Type | Method and Description |
---|---|
protected List<OperatorDescriptorDual> |
CoGroupRawNode.getPossibleProperties() |
protected abstract List<OperatorDescriptorDual> |
TwoInputNode.getPossibleProperties() |
protected List<OperatorDescriptorDual> |
BinaryUnionNode.getPossibleProperties() |
protected List<OperatorDescriptorDual> |
JoinNode.getPossibleProperties() |
protected List<OperatorDescriptorDual> |
OuterJoinNode.getPossibleProperties() |
protected List<OperatorDescriptorDual> |
CoGroupNode.getPossibleProperties() |
protected List<OperatorDescriptorDual> |
WorksetIterationNode.getPossibleProperties() |
protected List<OperatorDescriptorDual> |
WorksetIterationNode.SingleRootJoiner.getPossibleProperties() |
protected List<OperatorDescriptorDual> |
CrossNode.getPossibleProperties() |
protected List<OperatorDescriptorDual> |
SinkJoiner.getPossibleProperties() |
Modifier and Type | Method and Description |
---|---|
protected void |
TwoInputNode.instantiate(OperatorDescriptorDual operator,
Channel in1,
Channel in2,
List<Set<? extends NamedChannel>> broadcastPlanChannels,
List<PlanNode> target,
CostEstimator estimator,
RequestedGlobalProperties globPropsReq1,
RequestedGlobalProperties globPropsReq2,
RequestedLocalProperties locPropsReq1,
RequestedLocalProperties locPropsReq2) |
protected void |
WorksetIterationNode.instantiate(OperatorDescriptorDual operator,
Channel solutionSetIn,
Channel worksetIn,
List<Set<? extends NamedChannel>> broadcastPlanChannels,
List<PlanNode> target,
CostEstimator estimator,
RequestedGlobalProperties globPropsReqSolutionSet,
RequestedGlobalProperties globPropsReqWorkset,
RequestedLocalProperties locPropsReqSolutionSet,
RequestedLocalProperties locPropsReqWorkset) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.