org.apache.flink.api.common.operators.base

Enum JoinOperatorBase.JoinHint

java.lang.Object

java.lang.Enum<JoinOperatorBase.JoinHint>

org.apache.flink.api.common.operators.base.JoinOperatorBase.JoinHint

All Implemented Interfaces:

Serializable, Comparable<JoinOperatorBase.JoinHint>

Enclosing class:

JoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>>

@Public
public static enum JoinOperatorBase.JoinHint
extends Enum<JoinOperatorBase.JoinHint>

An enumeration of hints, optionally usable to tell the system how exactly execute the join.

Enum Constant Summary

Enum Constants

Enum Constant and Description
BROADCAST_HASH_FIRST Hint that the first join input is much smaller than the second.
BROADCAST_HASH_SECOND Hint that the second join input is much smaller than the first.
OPTIMIZER_CHOOSES Leave the choice how to do the join to the optimizer.
REPARTITION_HASH_FIRST Hint that the first join input is a bit smaller than the second.
REPARTITION_HASH_SECOND Hint that the second join input is a bit smaller than the first.
REPARTITION_SORT_MERGE Hint that the join should repartitioning both inputs and use sorting and merging as the join strategy.

Method Summary

Modifier and Type	Method and Description
static JoinOperatorBase.JoinHint	valueOf(String name) Returns the enum constant of this type with the specified name.
static JoinOperatorBase.JoinHint[]	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

OPTIMIZER_CHOOSES

public static final JoinOperatorBase.JoinHint OPTIMIZER_CHOOSES

Leave the choice how to do the join to the optimizer. If in doubt, the optimizer will choose a repartitioning join.

BROADCAST_HASH_FIRST

public static final JoinOperatorBase.JoinHint BROADCAST_HASH_FIRST

Hint that the first join input is much smaller than the second. This results in broadcasting and hashing the first input, unless the optimizer infers that prior existing partitioning is available that is even cheaper to exploit.

BROADCAST_HASH_SECOND

public static final JoinOperatorBase.JoinHint BROADCAST_HASH_SECOND

Hint that the second join input is much smaller than the first. This results in broadcasting and hashing the second input, unless the optimizer infers that prior existing partitioning is available that is even cheaper to exploit.

REPARTITION_HASH_FIRST

public static final JoinOperatorBase.JoinHint REPARTITION_HASH_FIRST

Hint that the first join input is a bit smaller than the second. This results in repartitioning both inputs and hashing the first input, unless the optimizer infers that prior existing partitioning and orders are available that are even cheaper to exploit.

REPARTITION_HASH_SECOND

public static final JoinOperatorBase.JoinHint REPARTITION_HASH_SECOND

Hint that the second join input is a bit smaller than the first. This results in repartitioning both inputs and hashing the second input, unless the optimizer infers that prior existing partitioning and orders are available that are even cheaper to exploit.

REPARTITION_SORT_MERGE

public static final JoinOperatorBase.JoinHint REPARTITION_SORT_MERGE

Hint that the join should repartitioning both inputs and use sorting and merging as the join strategy.

Method Detail

values

public static JoinOperatorBase.JoinHint[] 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 (JoinOperatorBase.JoinHint c : JoinOperatorBase.JoinHint.values())
    System.out.println(c);

Returns:

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

valueOf

public static JoinOperatorBase.JoinHint 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