Uses of Class
org.apache.flink.optimizer.dag.DagConnection

Packages that use DagConnection

Package	Description
org.apache.flink.optimizer.dag

Uses of DagConnection in org.apache.flink.optimizer.dag

Fields in org.apache.flink.optimizer.dag declared as DagConnection

Modifier and Type	Field	Description
protected DagConnection	SingleInputNode.inConn
protected DagConnection	DataSinkNode.input
protected DagConnection	TwoInputNode.input1
protected DagConnection	TwoInputNode.input2

Methods in org.apache.flink.optimizer.dag that return DagConnection

Modifier and Type	Method	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.

Methods in org.apache.flink.optimizer.dag that return types with arguments of type DagConnection

Modifier and Type	Method	Description
List<DagConnection>	OptimizerNode.getBroadcastConnections()	Return the list of inputs associated with broadcast variables for this node.
List<DagConnection>	AbstractPartialSolutionNode.getIncomingConnections()
List<DagConnection>	DataSinkNode.getIncomingConnections()
List<DagConnection>	DataSourceNode.getIncomingConnections()
abstract List<DagConnection>	OptimizerNode.getIncomingConnections()	Gets all incoming connections of this node.
List<DagConnection>	SingleInputNode.getIncomingConnections()
List<DagConnection>	TwoInputNode.getIncomingConnections()
List<DagConnection>	DataSinkNode.getOutgoingConnections()	Gets all outgoing connections, which is an empty set for the data sink.
List<DagConnection>	OptimizerNode.getOutgoingConnections()	The list of outgoing connections from this node to succeeding tasks.
List<DagConnection>	SinkJoiner.getOutgoingConnections()

Methods in org.apache.flink.optimizer.dag with parameters of type DagConnection

Modifier and Type	Method	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>	DataSinkNode.getBranchesForParent(DagConnection parent)
protected List<OptimizerNode.UnclosedBranchDescriptor>	OptimizerNode.getBranchesForParent(DagConnection toParent)
void	SingleInputNode.setIncomingConnection(DagConnection inConn)	Sets the connection through which this node receives its input.
void	WorksetIterationNode.SingleRootJoiner.setInputs(DagConnection input1, DagConnection input2)