Package org.apache.flink.optimizer.plandump

Interface DumpableConnection<T extends DumpableNode<T>>

All Known Implementing Classes:

Channel, DagConnection, NamedChannel

public interface DumpableConnection<T extends DumpableNode<T>>

Method Summary

Modifier and Type	Method	Description
org.apache.flink.runtime.operators.shipping.ShipStrategyType	getShipStrategy()
DumpableNode<T>	getSource()

Method Detail

getSource

DumpableNode<T> getSource()

getShipStrategy

org.apache.flink.runtime.operators.shipping.ShipStrategyType getShipStrategy()