Package org.apache.flink.streaming.tests

Enum TestOperatorEnum

java.lang.Object

java.lang.Enum<TestOperatorEnum>

org.apache.flink.streaming.tests.TestOperatorEnum

All Implemented Interfaces:

Serializable, Comparable<TestOperatorEnum>

public enum TestOperatorEnum
extends Enum<TestOperatorEnum>

Enum of names and uids of all test operators used in DataStreamAllroundTestProgram.

Enum Constant Summary

Enum Constants

Enum Constant	Description
EVENT_IDENTITY_MAPPER
EVENT_SOURCE
FAILURE_MAPPER_NAME
KEYED_STATE_OPER_WITH_AVRO_SER
KEYED_STATE_OPER_WITH_KRYO_AND_CUSTOM_SER
MAPPER_RETURNS_OUT_WITH_CUSTOM_SER
OPERATOR_STATE_OPER
RESULT_TYPE_QUERYABLE_MAPPER_WITH_CUSTOM_SER
SEMANTICS_CHECK_MAPPER
SEMANTICS_CHECK_PRINT_SINK
SLIDING_WINDOW_AGG
SLIDING_WINDOW_CHECK_MAPPER
SLIDING_WINDOW_CHECK_PRINT_SINK
TIME_WINDOW_OPER

Method Summary

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

EVENT_SOURCE

public static final TestOperatorEnum EVENT_SOURCE

KEYED_STATE_OPER_WITH_KRYO_AND_CUSTOM_SER

public static final TestOperatorEnum KEYED_STATE_OPER_WITH_KRYO_AND_CUSTOM_SER

KEYED_STATE_OPER_WITH_AVRO_SER

public static final TestOperatorEnum KEYED_STATE_OPER_WITH_AVRO_SER

OPERATOR_STATE_OPER

public static final TestOperatorEnum OPERATOR_STATE_OPER

TIME_WINDOW_OPER

public static final TestOperatorEnum TIME_WINDOW_OPER

FAILURE_MAPPER_NAME

public static final TestOperatorEnum FAILURE_MAPPER_NAME

SEMANTICS_CHECK_MAPPER

public static final TestOperatorEnum SEMANTICS_CHECK_MAPPER

SEMANTICS_CHECK_PRINT_SINK

public static final TestOperatorEnum SEMANTICS_CHECK_PRINT_SINK

SLIDING_WINDOW_AGG

public static final TestOperatorEnum SLIDING_WINDOW_AGG

SLIDING_WINDOW_CHECK_MAPPER

public static final TestOperatorEnum SLIDING_WINDOW_CHECK_MAPPER

SLIDING_WINDOW_CHECK_PRINT_SINK

public static final TestOperatorEnum SLIDING_WINDOW_CHECK_PRINT_SINK

RESULT_TYPE_QUERYABLE_MAPPER_WITH_CUSTOM_SER

public static final TestOperatorEnum RESULT_TYPE_QUERYABLE_MAPPER_WITH_CUSTOM_SER

MAPPER_RETURNS_OUT_WITH_CUSTOM_SER

public static final TestOperatorEnum MAPPER_RETURNS_OUT_WITH_CUSTOM_SER

EVENT_IDENTITY_MAPPER

public static final TestOperatorEnum EVENT_IDENTITY_MAPPER

Method Detail

values

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

Returns:

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

valueOf

public static TestOperatorEnum 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

getName

public String getName()

getUid

public String getUid()