org.apache.beam.runners.dataflow.util

Class PropertyNames

java.lang.Object

org.apache.beam.runners.dataflow.util.PropertyNames

public class PropertyNames
extends java.lang.Object

Constant property names used by the SDK in CloudWorkflow specifications.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CO_GBK_RESULT_SCHEMA
static java.lang.String	COMPONENT_ENCODINGS
static java.lang.String	CUSTOM_SOURCE_FORMAT
static java.lang.String	DISALLOW_COMBINER_LIFTING
static java.lang.String	DISPLAY_DATA
static java.lang.String	ENCODING
static java.lang.String	ENVIRONMENT_VERSION_JOB_TYPE_KEY
static java.lang.String	ENVIRONMENT_VERSION_MAJOR_KEY
static java.lang.String	FORMAT
static java.lang.String	IMPULSE_ELEMENT
static java.lang.String	INPUTS
static java.lang.String	IS_MERGING_WINDOW_FN
static java.lang.String	IS_PAIR_LIKE
static java.lang.String	IS_STREAM_LIKE
static java.lang.String	IS_WRAPPER
static java.lang.String	NON_PARALLEL_INPUTS
static java.lang.String	OBJECT_TYPE_NAME
static java.lang.String	OUTPUT
static java.lang.String	OUTPUT_INFO
static java.lang.String	OUTPUT_NAME
static java.lang.String	PARALLEL_INPUT
static java.lang.String	PIPELINE_PROTO_CODER_ID
static java.lang.String	PUBSUB_ID_ATTRIBUTE
static java.lang.String	PUBSUB_SERIALIZED_ATTRIBUTES_FN
static java.lang.String	PUBSUB_SUBSCRIPTION
static java.lang.String	PUBSUB_SUBSCRIPTION_OVERRIDE
static java.lang.String	PUBSUB_TIMESTAMP_ATTRIBUTE
static java.lang.String	PUBSUB_TOPIC
static java.lang.String	PUBSUB_TOPIC_OVERRIDE
static java.lang.String	RESTRICTION_CODER Deprecated. Uses the incorrect terminology. RESTRICTION_ENCODING. Should be removed once non FnAPI SplittableDoFn expansion for Dataflow is removed.
static java.lang.String	RESTRICTION_ENCODING
static java.lang.String	SCALAR_FIELD_NAME
static java.lang.String	SERIALIZED_FN
static java.lang.String	SERIALIZED_TEST_STREAM
static java.lang.String	SORT_VALUES
static java.lang.String	SOURCE_DOES_NOT_NEED_SPLITTING
static java.lang.String	SOURCE_ESTIMATED_SIZE_BYTES
static java.lang.String	SOURCE_IS_INFINITE
static java.lang.String	SOURCE_METADATA
static java.lang.String	SOURCE_SPEC
static java.lang.String	SOURCE_STEP_INPUT
static java.lang.String	TUPLE_TAGS
static java.lang.String	USE_INDEXED_FORMAT
static java.lang.String	USER_FN
static java.lang.String	USER_NAME
static java.lang.String	USES_KEYED_STATE
static java.lang.String	VALUE
static java.lang.String	WINDOWING_STRATEGY

Constructor Summary

Constructors

Constructor and Description
PropertyNames()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CO_GBK_RESULT_SCHEMA

public static final java.lang.String CO_GBK_RESULT_SCHEMA

See Also:

Constant Field Values

COMPONENT_ENCODINGS

public static final java.lang.String COMPONENT_ENCODINGS

See Also:

Constant Field Values

CUSTOM_SOURCE_FORMAT

public static final java.lang.String CUSTOM_SOURCE_FORMAT

See Also:

Constant Field Values

SOURCE_STEP_INPUT

public static final java.lang.String SOURCE_STEP_INPUT

See Also:

Constant Field Values

SOURCE_SPEC

public static final java.lang.String SOURCE_SPEC

See Also:

Constant Field Values

SOURCE_METADATA

public static final java.lang.String SOURCE_METADATA

See Also:

Constant Field Values

SOURCE_DOES_NOT_NEED_SPLITTING

public static final java.lang.String SOURCE_DOES_NOT_NEED_SPLITTING

See Also:

Constant Field Values

SOURCE_IS_INFINITE

public static final java.lang.String SOURCE_IS_INFINITE

See Also:

Constant Field Values

SOURCE_ESTIMATED_SIZE_BYTES

public static final java.lang.String SOURCE_ESTIMATED_SIZE_BYTES

See Also:

Constant Field Values

ENCODING

public static final java.lang.String ENCODING

See Also:

Constant Field Values

ENVIRONMENT_VERSION_JOB_TYPE_KEY

public static final java.lang.String ENVIRONMENT_VERSION_JOB_TYPE_KEY

See Also:

Constant Field Values

ENVIRONMENT_VERSION_MAJOR_KEY

public static final java.lang.String ENVIRONMENT_VERSION_MAJOR_KEY

See Also:

Constant Field Values

FORMAT

public static final java.lang.String FORMAT

See Also:

Constant Field Values

INPUTS

public static final java.lang.String INPUTS

See Also:

Constant Field Values

IS_MERGING_WINDOW_FN

public static final java.lang.String IS_MERGING_WINDOW_FN

See Also:

Constant Field Values

IS_PAIR_LIKE

public static final java.lang.String IS_PAIR_LIKE

See Also:

Constant Field Values

IS_STREAM_LIKE

public static final java.lang.String IS_STREAM_LIKE

See Also:

Constant Field Values

IS_WRAPPER

public static final java.lang.String IS_WRAPPER

See Also:

Constant Field Values

DISALLOW_COMBINER_LIFTING

public static final java.lang.String DISALLOW_COMBINER_LIFTING

See Also:

Constant Field Values

NON_PARALLEL_INPUTS

public static final java.lang.String NON_PARALLEL_INPUTS

See Also:

Constant Field Values

OBJECT_TYPE_NAME

public static final java.lang.String OBJECT_TYPE_NAME

See Also:

Constant Field Values

OUTPUT

public static final java.lang.String OUTPUT

See Also:

Constant Field Values

OUTPUT_INFO

public static final java.lang.String OUTPUT_INFO

See Also:

Constant Field Values

OUTPUT_NAME

public static final java.lang.String OUTPUT_NAME

See Also:

Constant Field Values

PARALLEL_INPUT

public static final java.lang.String PARALLEL_INPUT

See Also:

Constant Field Values

PUBSUB_ID_ATTRIBUTE

public static final java.lang.String PUBSUB_ID_ATTRIBUTE

See Also:

Constant Field Values

PUBSUB_SERIALIZED_ATTRIBUTES_FN

public static final java.lang.String PUBSUB_SERIALIZED_ATTRIBUTES_FN

See Also:

Constant Field Values

PUBSUB_SUBSCRIPTION

public static final java.lang.String PUBSUB_SUBSCRIPTION

See Also:

Constant Field Values

PUBSUB_SUBSCRIPTION_OVERRIDE

public static final java.lang.String PUBSUB_SUBSCRIPTION_OVERRIDE

See Also:

Constant Field Values

PUBSUB_TIMESTAMP_ATTRIBUTE

public static final java.lang.String PUBSUB_TIMESTAMP_ATTRIBUTE

See Also:

Constant Field Values

PUBSUB_TOPIC

public static final java.lang.String PUBSUB_TOPIC

See Also:

Constant Field Values

PUBSUB_TOPIC_OVERRIDE

public static final java.lang.String PUBSUB_TOPIC_OVERRIDE

See Also:

Constant Field Values

SCALAR_FIELD_NAME

public static final java.lang.String SCALAR_FIELD_NAME

See Also:

Constant Field Values

SERIALIZED_FN

public static final java.lang.String SERIALIZED_FN

See Also:

Constant Field Values

SERIALIZED_TEST_STREAM

public static final java.lang.String SERIALIZED_TEST_STREAM

See Also:

Constant Field Values

SORT_VALUES

public static final java.lang.String SORT_VALUES

See Also:

Constant Field Values

TUPLE_TAGS

public static final java.lang.String TUPLE_TAGS

See Also:

Constant Field Values

USE_INDEXED_FORMAT

public static final java.lang.String USE_INDEXED_FORMAT

See Also:

Constant Field Values

USER_FN

public static final java.lang.String USER_FN

See Also:

Constant Field Values

USER_NAME

public static final java.lang.String USER_NAME

See Also:

Constant Field Values

USES_KEYED_STATE

public static final java.lang.String USES_KEYED_STATE

See Also:

Constant Field Values

VALUE

public static final java.lang.String VALUE

See Also:

Constant Field Values

WINDOWING_STRATEGY

public static final java.lang.String WINDOWING_STRATEGY

See Also:

Constant Field Values

DISPLAY_DATA

public static final java.lang.String DISPLAY_DATA

See Also:

Constant Field Values

RESTRICTION_CODER

@Deprecated
public static final java.lang.String RESTRICTION_CODER

Deprecated. Uses the incorrect terminology. RESTRICTION_ENCODING. Should be removed once non FnAPI SplittableDoFn expansion for Dataflow is removed.

See Also:

Constant Field Values

IMPULSE_ELEMENT

public static final java.lang.String IMPULSE_ELEMENT

See Also:

Constant Field Values

PIPELINE_PROTO_CODER_ID

public static final java.lang.String PIPELINE_PROTO_CODER_ID

See Also:

Constant Field Values

RESTRICTION_ENCODING

public static final java.lang.String RESTRICTION_ENCODING

See Also:

Constant Field Values

Constructor Detail

PropertyNames

public PropertyNames()