Package org.apache.flink.optimizer.plan

Class NamedChannel

java.lang.Object

org.apache.flink.optimizer.plan.Channel

org.apache.flink.optimizer.plan.NamedChannel

All Implemented Interfaces:

Cloneable, EstimateProvider, DumpableConnection<PlanNode>

public class NamedChannel
extends Channel

Constructor Summary

Constructors

Constructor	Description
NamedChannel(String name, PlanNode sourceNode)	Initializes NamedChannel.
NamedChannel(String name, PlanNode sourceNode, TempMode tempMode)

Method Summary

Modifier and Type	Method	Description
String	getName()

Methods inherited from class org.apache.flink.optimizer.plan.Channel

adjustGlobalPropertiesForFullParallelismChange, clone, getCostWeight, getDataDistribution, getDataExchangeMode, getEstimatedAvgWidthPerOutputRecord, getEstimatedNumRecords, getEstimatedOutputSize, getGlobalProperties, getLocalProperties, getLocalStrategy, getLocalStrategyComparator, getLocalStrategyKeys, getLocalStrategySortOrder, getMaxDepth, getPartitioner, getRelativeMemoryLocalStrategy, getRelativeTempMemory, getReplicationFactor, getRequiredGlobalProps, getRequiredLocalProps, getSerializer, getShipStrategy, getShipStrategyComparator, getShipStrategyKeys, getShipStrategySortOrder, getSource, getTarget, getTempMode, isOnDynamicPath, setDataDistribution, setDataExchangeMode, setLocalStrategy, setLocalStrategy, setLocalStrategyComparator, setRelativeMemoryLocalStrategy, setRelativeTempMemory, setReplicationFactor, setRequiredGlobalProps, setRequiredLocalProps, setSerializer, setShipStrategy, setShipStrategy, setShipStrategy, setShipStrategy, setShipStrategy, setShipStrategyComparator, setSource, setTarget, setTempMode, swapUnionNodes, toString

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

NamedChannel

public NamedChannel(String name,
                    PlanNode sourceNode)

Initializes NamedChannel.

Parameters:

sourceNode -

NamedChannel

public NamedChannel(String name,
                    PlanNode sourceNode,
                    TempMode tempMode)

Method Detail

getName

public String getName()