public class Channel extends Object implements EstimateProvider, Cloneable, DumpableConnection<PlanNode>
The channel defines and tracks various properties and characteristics of the data set and data exchange.
Data set characteristics:
Constructor and Description |
---|
Channel(PlanNode sourceNode) |
Channel(PlanNode sourceNode,
TempMode tempMode) |
Modifier and Type | Method and Description |
---|---|
void |
adjustGlobalPropertiesForFullParallelismChange() |
Channel |
clone() |
int |
getCostWeight() |
DataDistribution |
getDataDistribution() |
DataExchangeMode |
getDataExchangeMode()
Gets the data exchange mode (batch / pipelined) to use for the data exchange of this channel.
|
float |
getEstimatedAvgWidthPerOutputRecord()
Gets the estimated number of bytes per record.
|
long |
getEstimatedNumRecords()
Gets the estimated number of records in the output of this node.
|
long |
getEstimatedOutputSize()
Gets the estimated output size from this node.
|
GlobalProperties |
getGlobalProperties() |
LocalProperties |
getLocalProperties() |
LocalStrategy |
getLocalStrategy() |
TypeComparatorFactory<?> |
getLocalStrategyComparator()
Gets the local strategy comparator from this Channel.
|
FieldList |
getLocalStrategyKeys() |
boolean[] |
getLocalStrategySortOrder() |
int |
getMaxDepth() |
Partitioner<?> |
getPartitioner() |
double |
getRelativeMemoryLocalStrategy() |
double |
getRelativeTempMemory()
Gets the memory for materializing the channel's result from this Channel.
|
int |
getReplicationFactor()
Returns the replication factor of the connection.
|
RequestedGlobalProperties |
getRequiredGlobalProps() |
RequestedLocalProperties |
getRequiredLocalProps() |
TypeSerializerFactory<?> |
getSerializer()
Gets the serializer from this Channel.
|
ShipStrategyType |
getShipStrategy() |
TypeComparatorFactory<?> |
getShipStrategyComparator()
Gets the ship strategy comparator from this Channel.
|
FieldList |
getShipStrategyKeys() |
boolean[] |
getShipStrategySortOrder() |
PlanNode |
getSource()
Gets the source of this Channel.
|
PlanNode |
getTarget()
Gets the target of this Channel.
|
TempMode |
getTempMode() |
boolean |
isOnDynamicPath() |
void |
setDataDistribution(DataDistribution dataDistribution) |
void |
setDataExchangeMode(DataExchangeMode dataExchangeMode)
Sets the data exchange mode (batch / pipelined) to use for the data exchange of this channel.
|
void |
setLocalStrategy(LocalStrategy strategy) |
void |
setLocalStrategy(LocalStrategy strategy,
FieldList keys,
boolean[] sortDirection) |
void |
setLocalStrategyComparator(TypeComparatorFactory<?> localStrategyComparator)
Sets the local strategy comparator for this Channel.
|
void |
setRelativeMemoryLocalStrategy(double relativeMemoryLocalStrategy) |
void |
setRelativeTempMemory(double relativeTempMemory)
Sets the memory for materializing the channel's result from this Channel.
|
void |
setReplicationFactor(int factor)
Sets the replication factor of the connection.
|
void |
setRequiredGlobalProps(RequestedGlobalProperties requiredGlobalProps) |
void |
setRequiredLocalProps(RequestedLocalProperties requiredLocalProps) |
void |
setSerializer(TypeSerializerFactory<?> serializer)
Sets the serializer for this Channel.
|
void |
setShipStrategy(ShipStrategyType strategy,
DataExchangeMode dataExchangeMode) |
void |
setShipStrategy(ShipStrategyType strategy,
FieldList keys,
boolean[] sortDirection,
DataExchangeMode dataExchangeMode) |
void |
setShipStrategy(ShipStrategyType strategy,
FieldList keys,
boolean[] sortDirection,
Partitioner<?> partitioner,
DataExchangeMode dataExchangeMode) |
void |
setShipStrategy(ShipStrategyType strategy,
FieldList keys,
DataExchangeMode dataExchangeMode) |
void |
setShipStrategy(ShipStrategyType strategy,
FieldList keys,
Partitioner<?> partitioner,
DataExchangeMode dataExchangeMode) |
void |
setShipStrategyComparator(TypeComparatorFactory<?> shipStrategyComparator)
Sets the ship strategy comparator for this Channel.
|
void |
setSource(PlanNode source) |
void |
setTarget(PlanNode target)
Sets the target of this Channel.
|
void |
setTempMode(TempMode tempMode)
Sets the temp mode of the connection.
|
void |
swapUnionNodes(PlanNode newUnionNode)
Utility method used while swapping binary union nodes for n-ary union nodes.
|
String |
toString() |
public Channel(PlanNode sourceNode)
public PlanNode getSource()
getSource
in interface DumpableConnection<PlanNode>
public void setSource(PlanNode source)
public void setTarget(PlanNode target)
target
- The target.public PlanNode getTarget()
public void setShipStrategy(ShipStrategyType strategy, DataExchangeMode dataExchangeMode)
public void setShipStrategy(ShipStrategyType strategy, FieldList keys, DataExchangeMode dataExchangeMode)
public void setShipStrategy(ShipStrategyType strategy, FieldList keys, boolean[] sortDirection, DataExchangeMode dataExchangeMode)
public void setShipStrategy(ShipStrategyType strategy, FieldList keys, Partitioner<?> partitioner, DataExchangeMode dataExchangeMode)
public void setShipStrategy(ShipStrategyType strategy, FieldList keys, boolean[] sortDirection, Partitioner<?> partitioner, DataExchangeMode dataExchangeMode)
public void setDataExchangeMode(DataExchangeMode dataExchangeMode)
public DataExchangeMode getDataExchangeMode()
public ShipStrategyType getShipStrategy()
getShipStrategy
in interface DumpableConnection<PlanNode>
public FieldList getShipStrategyKeys()
public boolean[] getShipStrategySortOrder()
public void setLocalStrategy(LocalStrategy strategy)
public void setLocalStrategy(LocalStrategy strategy, FieldList keys, boolean[] sortDirection)
public LocalStrategy getLocalStrategy()
public FieldList getLocalStrategyKeys()
public boolean[] getLocalStrategySortOrder()
public void setDataDistribution(DataDistribution dataDistribution)
public DataDistribution getDataDistribution()
public Partitioner<?> getPartitioner()
public TempMode getTempMode()
public void setTempMode(TempMode tempMode)
tempMode
- The temp mode of the connection.public double getRelativeTempMemory()
public void setRelativeTempMemory(double relativeTempMemory)
relativeTempMemory
- The memory for materialization.public void setReplicationFactor(int factor)
factor
- The replication factor of the connection.public int getReplicationFactor()
public TypeSerializerFactory<?> getSerializer()
public void setSerializer(TypeSerializerFactory<?> serializer)
serializer
- The serializer to set.public TypeComparatorFactory<?> getShipStrategyComparator()
public void setShipStrategyComparator(TypeComparatorFactory<?> shipStrategyComparator)
shipStrategyComparator
- The ship strategy comparator to set.public TypeComparatorFactory<?> getLocalStrategyComparator()
public void setLocalStrategyComparator(TypeComparatorFactory<?> localStrategyComparator)
localStrategyComparator
- The local strategy comparator to set.public double getRelativeMemoryLocalStrategy()
public void setRelativeMemoryLocalStrategy(double relativeMemoryLocalStrategy)
public boolean isOnDynamicPath()
public int getCostWeight()
public long getEstimatedOutputSize()
EstimateProvider
getEstimatedOutputSize
in interface EstimateProvider
public long getEstimatedNumRecords()
EstimateProvider
getEstimatedNumRecords
in interface EstimateProvider
public float getEstimatedAvgWidthPerOutputRecord()
EstimateProvider
getEstimatedAvgWidthPerOutputRecord
in interface EstimateProvider
public RequestedGlobalProperties getRequiredGlobalProps()
public void setRequiredGlobalProps(RequestedGlobalProperties requiredGlobalProps)
public RequestedLocalProperties getRequiredLocalProps()
public void setRequiredLocalProps(RequestedLocalProperties requiredLocalProps)
public GlobalProperties getGlobalProperties()
public LocalProperties getLocalProperties()
public void adjustGlobalPropertiesForFullParallelismChange()
public void swapUnionNodes(PlanNode newUnionNode)
public int getMaxDepth()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.