Package org.apache.flink.runtime.operators

Enum DriverStrategy

java.lang.Object

java.lang.Enum<DriverStrategy>

org.apache.flink.runtime.operators.DriverStrategy

All Implemented Interfaces:

Serializable, Comparable<DriverStrategy>

public enum DriverStrategy
extends Enum<DriverStrategy>

Enumeration of all available operator strategies.

Enum Constant Summary

Enum Constants

Enum Constant	Description
ALL_GROUP_COMBINE
ALL_GROUP_REDUCE
ALL_GROUP_REDUCE_COMBINE
ALL_REDUCE
BINARY_NO_OP
CO_GROUP
CO_GROUP_RAW
FLAT_MAP
FULL_OUTER_HYBRIDHASH_BUILD_FIRST
FULL_OUTER_HYBRIDHASH_BUILD_SECOND
FULL_OUTER_MERGE
HASHED_PARTIAL_REDUCE
HYBRIDHASH_BUILD_FIRST
HYBRIDHASH_BUILD_FIRST_CACHED
HYBRIDHASH_BUILD_SECOND
HYBRIDHASH_BUILD_SECOND_CACHED
INNER_MERGE
LEFT_HYBRIDHASH_BUILD_FIRST
LEFT_HYBRIDHASH_BUILD_SECOND
LEFT_OUTER_MERGE
MAP
MAP_PARTITION
NESTEDLOOP_BLOCKED_OUTER_FIRST
NESTEDLOOP_BLOCKED_OUTER_SECOND
NESTEDLOOP_STREAMED_OUTER_FIRST
NESTEDLOOP_STREAMED_OUTER_SECOND
NONE
RIGHT_HYBRIDHASH_BUILD_FIRST
RIGHT_HYBRIDHASH_BUILD_SECOND
RIGHT_OUTER_MERGE
SINK
SORTED_GROUP_COMBINE
SORTED_GROUP_REDUCE
SORTED_PARTIAL_REDUCE
SORTED_REDUCE
SOURCE
UNARY_NO_OP
UNION
UNION_WITH_CACHED

Method Summary

Modifier and Type	Method	Description
DamBehavior	damOnInput(int num)
DamBehavior	firstDam()
Class<? extends Driver<?,?>>	getDriverClass()
int	getNumInputs()
int	getNumRequiredComparators()
Class<? extends ChainedDriver<?,?>>	getPushChainDriverClass()
boolean	isMaterializing()
DamBehavior	secondDam()
static DriverStrategy	valueOf(String name)	Returns the enum constant of this type with the specified name.
static DriverStrategy[]	values()	Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

NONE

public static final DriverStrategy NONE

UNARY_NO_OP

public static final DriverStrategy UNARY_NO_OP

BINARY_NO_OP

public static final DriverStrategy BINARY_NO_OP

MAP

public static final DriverStrategy MAP

MAP_PARTITION

public static final DriverStrategy MAP_PARTITION

FLAT_MAP

public static final DriverStrategy FLAT_MAP

ALL_REDUCE

public static final DriverStrategy ALL_REDUCE

ALL_GROUP_REDUCE

public static final DriverStrategy ALL_GROUP_REDUCE

ALL_GROUP_REDUCE_COMBINE

public static final DriverStrategy ALL_GROUP_REDUCE_COMBINE

SORTED_REDUCE

public static final DriverStrategy SORTED_REDUCE

SORTED_PARTIAL_REDUCE

public static final DriverStrategy SORTED_PARTIAL_REDUCE

HASHED_PARTIAL_REDUCE

public static final DriverStrategy HASHED_PARTIAL_REDUCE

SORTED_GROUP_REDUCE

public static final DriverStrategy SORTED_GROUP_REDUCE

SORTED_GROUP_COMBINE

public static final DriverStrategy SORTED_GROUP_COMBINE

ALL_GROUP_COMBINE

public static final DriverStrategy ALL_GROUP_COMBINE

INNER_MERGE

public static final DriverStrategy INNER_MERGE

LEFT_OUTER_MERGE

public static final DriverStrategy LEFT_OUTER_MERGE

RIGHT_OUTER_MERGE

public static final DriverStrategy RIGHT_OUTER_MERGE

FULL_OUTER_MERGE

public static final DriverStrategy FULL_OUTER_MERGE

CO_GROUP

public static final DriverStrategy CO_GROUP

CO_GROUP_RAW

public static final DriverStrategy CO_GROUP_RAW

HYBRIDHASH_BUILD_FIRST

public static final DriverStrategy HYBRIDHASH_BUILD_FIRST

HYBRIDHASH_BUILD_SECOND

public static final DriverStrategy HYBRIDHASH_BUILD_SECOND

HYBRIDHASH_BUILD_FIRST_CACHED

public static final DriverStrategy HYBRIDHASH_BUILD_FIRST_CACHED

HYBRIDHASH_BUILD_SECOND_CACHED

public static final DriverStrategy HYBRIDHASH_BUILD_SECOND_CACHED

RIGHT_HYBRIDHASH_BUILD_FIRST

public static final DriverStrategy RIGHT_HYBRIDHASH_BUILD_FIRST

RIGHT_HYBRIDHASH_BUILD_SECOND

public static final DriverStrategy RIGHT_HYBRIDHASH_BUILD_SECOND

LEFT_HYBRIDHASH_BUILD_FIRST

public static final DriverStrategy LEFT_HYBRIDHASH_BUILD_FIRST

LEFT_HYBRIDHASH_BUILD_SECOND

public static final DriverStrategy LEFT_HYBRIDHASH_BUILD_SECOND

FULL_OUTER_HYBRIDHASH_BUILD_FIRST

public static final DriverStrategy FULL_OUTER_HYBRIDHASH_BUILD_FIRST

FULL_OUTER_HYBRIDHASH_BUILD_SECOND

public static final DriverStrategy FULL_OUTER_HYBRIDHASH_BUILD_SECOND

NESTEDLOOP_BLOCKED_OUTER_FIRST

public static final DriverStrategy NESTEDLOOP_BLOCKED_OUTER_FIRST

NESTEDLOOP_BLOCKED_OUTER_SECOND

public static final DriverStrategy NESTEDLOOP_BLOCKED_OUTER_SECOND

NESTEDLOOP_STREAMED_OUTER_FIRST

public static final DriverStrategy NESTEDLOOP_STREAMED_OUTER_FIRST

NESTEDLOOP_STREAMED_OUTER_SECOND

public static final DriverStrategy NESTEDLOOP_STREAMED_OUTER_SECOND

UNION

public static final DriverStrategy UNION

UNION_WITH_CACHED

public static final DriverStrategy UNION_WITH_CACHED

SOURCE

public static final DriverStrategy SOURCE

SINK

public static final DriverStrategy SINK

Method Detail

values

public static DriverStrategy[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (DriverStrategy c : DriverStrategy.values())
    System.out.println(c);

Returns:

an array containing the constants of this enum type, in the order they are declared

valueOf

public static DriverStrategy valueOf(String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum type has no constant with the specified name

NullPointerException - if the argument is null

getDriverClass

public Class<? extends Driver<?,?>> getDriverClass()

getPushChainDriverClass

public Class<? extends ChainedDriver<?,?>> getPushChainDriverClass()

getNumInputs

public int getNumInputs()

firstDam

public DamBehavior firstDam()

secondDam

public DamBehavior secondDam()

damOnInput

public DamBehavior damOnInput(int num)

isMaterializing

public boolean isMaterializing()

getNumRequiredComparators

public int getNumRequiredComparators()