Package | Description |
---|---|
org.apache.flink.optimizer.dag | |
org.apache.flink.optimizer.operators |
Modifier and Type | Class and Description |
---|---|
static class |
PartitionNode.PartitionDescriptor |
static class |
SortPartitionNode.SortPartitionDescriptor |
Modifier and Type | Method and Description |
---|---|
protected void |
BulkIterationNode.instantiateCandidate(OperatorDescriptorSingle dps,
Channel in,
List<Set<? extends NamedChannel>> broadcastPlanChannels,
List<PlanNode> target,
CostEstimator estimator,
RequestedGlobalProperties globPropsReq,
RequestedLocalProperties locPropsReq) |
protected void |
SingleInputNode.instantiateCandidate(OperatorDescriptorSingle dps,
Channel in,
List<Set<? extends NamedChannel>> broadcastPlanChannels,
List<PlanNode> target,
CostEstimator estimator,
RequestedGlobalProperties globPropsReq,
RequestedLocalProperties locPropsReq) |
Constructor and Description |
---|
UnaryOperatorNode(String name,
FieldSet keys,
OperatorDescriptorSingle... operators) |
Constructor and Description |
---|
UnaryOperatorNode(String name,
FieldSet keys,
List<OperatorDescriptorSingle> operators) |
Modifier and Type | Class and Description |
---|---|
class |
AllGroupCombineProperties |
class |
AllGroupReduceProperties |
class |
AllGroupWithPartialPreGroupProperties |
class |
AllReduceProperties |
class |
FilterDescriptor |
class |
FlatMapDescriptor |
class |
GroupCombineProperties
The properties file belonging to the GroupCombineNode.
|
class |
GroupReduceProperties |
class |
GroupReduceWithCombineProperties |
class |
MapDescriptor |
class |
MapPartitionDescriptor |
class |
NoOpDescriptor |
class |
PartialGroupProperties |
class |
ReduceProperties |
class |
SolutionSetDeltaOperator |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.