Package | Description |
---|---|
org.apache.flink.optimizer.dag |
Modifier and Type | Field and Description |
---|---|
protected DagConnection |
SingleInputNode.inConn |
protected DagConnection |
DataSinkNode.input |
protected DagConnection |
TwoInputNode.input1 |
protected DagConnection |
TwoInputNode.input2 |
Modifier and Type | Method and Description |
---|---|
DagConnection |
TwoInputNode.getFirstIncomingConnection()
Gets the DagConnection through which this node receives its first input.
|
DagConnection |
SingleInputNode.getIncomingConnection()
Gets the input of this operator.
|
DagConnection |
DataSinkNode.getInputConnection()
Gets the input of the sink.
|
DagConnection |
TwoInputNode.getSecondIncomingConnection()
Gets the DagConnection through which this node receives its second input.
|
Modifier and Type | Method and Description |
---|---|
List<DagConnection> |
OptimizerNode.getBroadcastConnections()
Return the list of inputs associated with broadcast variables for this node.
|
List<DagConnection> |
DataSourceNode.getIncomingConnections() |
List<DagConnection> |
SingleInputNode.getIncomingConnections() |
List<DagConnection> |
TwoInputNode.getIncomingConnections() |
List<DagConnection> |
AbstractPartialSolutionNode.getIncomingConnections() |
abstract List<DagConnection> |
OptimizerNode.getIncomingConnections()
Gets all incoming connections of this node.
|
List<DagConnection> |
DataSinkNode.getIncomingConnections() |
List<DagConnection> |
SinkJoiner.getOutgoingConnections() |
List<DagConnection> |
OptimizerNode.getOutgoingConnections()
The list of outgoing connections from this node to succeeding tasks.
|
List<DagConnection> |
DataSinkNode.getOutgoingConnections()
Gets all outgoing connections, which is an empty set for the data sink.
|
Modifier and Type | Method and Description |
---|---|
void |
OptimizerNode.addBroadcastConnection(String name,
DagConnection broadcastConnection)
Adds the broadcast connection identified by the given
name to this node. |
void |
BinaryUnionNode.addOutgoingConnection(DagConnection connection) |
void |
OptimizerNode.addOutgoingConnection(DagConnection connection)
Adds a new outgoing connection to this node.
|
protected List<OptimizerNode.UnclosedBranchDescriptor> |
OptimizerNode.getBranchesForParent(DagConnection toParent) |
protected List<OptimizerNode.UnclosedBranchDescriptor> |
DataSinkNode.getBranchesForParent(DagConnection parent) |
void |
SingleInputNode.setIncomingConnection(DagConnection inConn)
Sets the connection through which this node receives its input.
|
void |
WorksetIterationNode.SingleRootJoiner.setInputs(DagConnection input1,
DagConnection input2) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.