Modifier and Type | Method and Description |
---|---|
ShipStrategyType |
DagConnection.getShipStrategy()
Gets the shipping strategy for this connection.
|
Modifier and Type | Method and Description |
---|---|
void |
DagConnection.setShipStrategy(ShipStrategyType strategy)
Sets the shipping strategy for this connection.
|
Constructor and Description |
---|
DagConnection(OptimizerNode source,
OptimizerNode target,
ShipStrategyType shipStrategy,
ExecutionMode exchangeMode)
Creates a new Connection between two nodes.
|
Modifier and Type | Method and Description |
---|---|
ShipStrategyType |
Channel.getShipStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
Channel.setShipStrategy(ShipStrategyType strategy,
DataExchangeMode dataExchangeMode) |
void |
Channel.setShipStrategy(ShipStrategyType strategy,
FieldList keys,
boolean[] sortDirection,
DataExchangeMode dataExchangeMode) |
void |
Channel.setShipStrategy(ShipStrategyType strategy,
FieldList keys,
boolean[] sortDirection,
Partitioner<?> partitioner,
DataExchangeMode dataExchangeMode) |
void |
Channel.setShipStrategy(ShipStrategyType strategy,
FieldList keys,
DataExchangeMode dataExchangeMode) |
void |
Channel.setShipStrategy(ShipStrategyType strategy,
FieldList keys,
Partitioner<?> partitioner,
DataExchangeMode dataExchangeMode) |
Modifier and Type | Method and Description |
---|---|
ShipStrategyType |
DumpableConnection.getShipStrategy() |
Modifier and Type | Method and Description |
---|---|
static String |
JsonMapper.getShipStrategyString(ShipStrategyType shipType) |
Modifier and Type | Method and Description |
---|---|
static DataExchangeMode |
DataExchangeMode.select(ExecutionMode executionMode,
ShipStrategyType shipStrategy,
boolean breakPipeline)
Computes the mode of data exchange to be used for a given execution mode and ship strategy.
|
Modifier and Type | Method and Description |
---|---|
static ShipStrategyType |
ShipStrategyType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ShipStrategyType[] |
ShipStrategyType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
OutputEmitter(ShipStrategyType strategy,
int indexInSubtaskGroup)
Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...)
and uses the supplied task index perform a round robin distribution.
|
OutputEmitter(ShipStrategyType strategy,
int indexInSubtaskGroup,
TypeComparator<T> comparator,
Partitioner<?> partitioner,
DataDistribution distribution) |
OutputEmitter(ShipStrategyType strategy,
TypeComparator<T> comparator)
Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...)
and uses the supplied comparator to hash / compare records for partitioning them deterministically.
|
Modifier and Type | Method and Description |
---|---|
ShipStrategyType |
TaskConfig.getOutputShipStrategy(int outputNum) |
Modifier and Type | Method and Description |
---|---|
void |
TaskConfig.addOutputShipStrategy(ShipStrategyType strategy) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.