Package | Description |
---|---|
org.apache.flink.api.common.operators.base | |
org.apache.flink.optimizer.dag |
Modifier and Type | Field and Description |
---|---|
protected DeltaIterationBase<ST,?> |
DeltaIterationBase.SolutionSetPlaceHolder.containingIteration |
Modifier and Type | Method and Description |
---|---|
DeltaIterationBase<?,WT> |
DeltaIterationBase.WorksetPlaceHolder.getContainingWorksetIteration() |
DeltaIterationBase<ST,?> |
DeltaIterationBase.SolutionSetPlaceHolder.getContainingWorksetIteration() |
Constructor and Description |
---|
SolutionSetPlaceHolder(DeltaIterationBase<ST,?> container,
OperatorInformation<ST> operatorInfo) |
WorksetPlaceHolder(DeltaIterationBase<?,WT> container,
OperatorInformation<WT> operatorInfo) |
Modifier and Type | Method and Description |
---|---|
DeltaIterationBase<?,?> |
WorksetIterationNode.getIterationContract() |
Constructor and Description |
---|
WorksetIterationNode(DeltaIterationBase<?,?> iteration)
Creates a new node with a single input for the optimizer plan.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.