org.apache.flink.streaming.runtime.operators.asyncprocessing

枚举 ElementOrder

java.lang.Object

java.lang.Enum<ElementOrder>

org.apache.flink.streaming.runtime.operators.asyncprocessing.ElementOrder

所有已实现的接口:

Serializable, Comparable<ElementOrder>

@Internal
public enum ElementOrder
extends Enum<ElementOrder>

This enum defines the element order of being processed. Only the elements with the same key should be considered here. We should keep this internal and away from API module for now, until we could see the concrete need for FIRST_STATE_ORDER from average users.

枚举常量概要

枚举常量

枚举常量和说明
FIRST_STATE_ORDER The processElement call will be invoked on record arrival, but may be blocked at the first state accessing if there is a preceding same-key record under processing.
RECORD_ORDER Treat the record processing as a whole, meaning that any processElement call for the elements with same key should follow the order of record arrival AND no parallel run is allowed.

方法概要

限定符和类型	方法和说明
static ElementOrder	valueOf(String name) 返回带有指定名称的该类型的枚举常量。
static ElementOrder[]	values() 按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

从类继承的方法 java.lang.Enum

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

从类继承的方法 java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

枚举常量详细资料

RECORD_ORDER

public static final ElementOrder RECORD_ORDER

Treat the record processing as a whole, meaning that any processElement call for the elements with same key should follow the order of record arrival AND no parallel run is allowed.

FIRST_STATE_ORDER

public static final ElementOrder FIRST_STATE_ORDER

The processElement call will be invoked on record arrival, but may be blocked at the first state accessing if there is a preceding same-key record under processing.

方法详细资料

values

public static ElementOrder[] values()

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。该方法可用于迭代 常量, 如下所示:

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

返回:

按照声明该枚举类型的常量的顺序返回的包含这些常量的数组

valueOf

public static ElementOrder valueOf(String name)

返回带有指定名称的该类型的枚举常量。 字符串必须与用于声明该类型的枚举常量的 标识符完全匹配。(不允许有多余 的空格字符。)

参数:

name - 要返回的枚举常量的名称。

返回:

返回带有指定名称的枚举常量

抛出:

IllegalArgumentException - 如果该枚举类型没有带有指定名称的常量

NullPointerException - 如果参数为空值