@Internal public class InputProperty extends Object
InputProperty
describes the input information of the ExecNode
.
The input concept is not corresponding to the execution edge, but rather to the Input
.
Modifier and Type | Class and Description |
---|---|
static class |
InputProperty.Builder
Builder of the
InputProperty . |
static class |
InputProperty.DamBehavior
Enumeration which describes how an input record may trigger the output behavior of the target
ExecNode . |
static class |
InputProperty.DistributionType
Enumeration which describes the type of the input data distribution.
|
static class |
InputProperty.HashDistribution
The input will read the records whose keys hash to a particular hash value.
|
static class |
InputProperty.KeepInputAsIsDistribution
A special distribution which indicators the data distribution is the same as its input.
|
static class |
InputProperty.RequiredDistribution
The required input data distribution for records when they are read in.
|
Modifier and Type | Field and Description |
---|---|
static InputProperty.RequiredDistribution |
ANY_DISTRIBUTION
The input does not require any specific data distribution.
|
static InputProperty.RequiredDistribution |
BROADCAST_DISTRIBUTION
The input will read all records for each parallelism of the target node.
|
static InputProperty |
DEFAULT |
static String |
FIELD_NAME_DAM_BEHAVIOR |
static String |
FIELD_NAME_PRIORITY |
static String |
FIELD_NAME_REQUIRED_DISTRIBUTION |
static InputProperty.RequiredDistribution |
SINGLETON_DISTRIBUTION
The input will read all records, and the parallelism of the target node must be 1.
|
static InputProperty.RequiredDistribution |
UNKNOWN_DISTRIBUTION
Returns a place-holder required distribution.
|
Constructor and Description |
---|
InputProperty(InputProperty.RequiredDistribution requiredDistribution,
InputProperty.DamBehavior damBehavior,
int priority) |
Modifier and Type | Method and Description |
---|---|
static InputProperty.Builder |
builder() |
boolean |
equals(Object o) |
InputProperty.DamBehavior |
getDamBehavior() |
int |
getPriority() |
InputProperty.RequiredDistribution |
getRequiredDistribution() |
int |
hashCode() |
static InputProperty.HashDistribution |
hashDistribution(int[] keys)
The input will read the records whose keys hash to a particular hash value.
|
static InputProperty.KeepInputAsIsDistribution |
keepInputAsIsDistribution(InputProperty.RequiredDistribution inputDistribution,
boolean strict)
A special distribution which indicators the data distribution is the same as its input.
|
String |
toString() |
public static final InputProperty.RequiredDistribution ANY_DISTRIBUTION
public static final InputProperty.RequiredDistribution BROADCAST_DISTRIBUTION
public static final InputProperty.RequiredDistribution SINGLETON_DISTRIBUTION
public static final InputProperty.RequiredDistribution UNKNOWN_DISTRIBUTION
Currently InputProperty
is only used for deadlock breakup and multi-input in batch
mode, so for ExecNode
s not affecting the algorithm we use this place-holder.
We should fill out the detailed InputProperty
for each sub-class of ExecNode
in the future.
public static final InputProperty DEFAULT
public static final String FIELD_NAME_REQUIRED_DISTRIBUTION
public static final String FIELD_NAME_DAM_BEHAVIOR
public static final String FIELD_NAME_PRIORITY
public InputProperty(InputProperty.RequiredDistribution requiredDistribution, InputProperty.DamBehavior damBehavior, int priority)
public InputProperty.RequiredDistribution getRequiredDistribution()
public InputProperty.DamBehavior getDamBehavior()
public int getPriority()
public static InputProperty.Builder builder()
public static InputProperty.HashDistribution hashDistribution(int[] keys)
keys
- hash keyspublic static InputProperty.KeepInputAsIsDistribution keepInputAsIsDistribution(InputProperty.RequiredDistribution inputDistribution, boolean strict)
inputDistribution
- the input distributionstrict
- whether the input distribution is strictly guaranteedCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.