Uses of Class
org.apache.flink.optimizer.plan.NamedChannel
-
Packages that use NamedChannel Package Description org.apache.flink.optimizer.dag org.apache.flink.optimizer.plan -
-
Uses of NamedChannel in org.apache.flink.optimizer.dag
Method parameters in org.apache.flink.optimizer.dag with type arguments of type NamedChannel Modifier and Type Method Description protected voidSingleInputNode. addLocalCandidates(Channel template, List<Set<? extends NamedChannel>> broadcastPlanChannels, RequestedGlobalProperties rgps, List<PlanNode> target, CostEstimator estimator)protected voidTwoInputNode. addLocalCandidates(Channel template1, Channel template2, List<Set<? extends NamedChannel>> broadcastPlanChannels, RequestedGlobalProperties rgps1, RequestedGlobalProperties rgps2, List<PlanNode> target, OperatorDescriptorDual.LocalPropertiesPair[] validLocalCombinations, CostEstimator estimator)protected voidTwoInputNode. 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 voidWorksetIterationNode. 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)protected voidBulkIterationNode. instantiateCandidate(OperatorDescriptorSingle dps, Channel in, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReq, RequestedLocalProperties locPropsReq)protected voidSingleInputNode. instantiateCandidate(OperatorDescriptorSingle dps, Channel in, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReq, RequestedLocalProperties locPropsReq) -
Uses of NamedChannel in org.apache.flink.optimizer.plan
Methods in org.apache.flink.optimizer.plan that return types with arguments of type NamedChannel Modifier and Type Method Description List<NamedChannel>PlanNode. getBroadcastInputs()Gets a list of all broadcast inputs attached to this node.Method parameters in org.apache.flink.optimizer.plan with type arguments of type NamedChannel Modifier and Type Method Description voidPlanNode. setBroadcastInputs(List<NamedChannel> broadcastInputs)Sets a list of all broadcast inputs attached to this node.
-