Package org.apache.beam.runners.dataflow.util

Class PropertyNames

java.lang.Object

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

public class PropertyNames
extends Object

Constant property names used by the SDK in CloudWorkflow specifications.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ALLOW_DUPLICATES
static final String	ALLOWS_SHARDABLE_STATE
static final String	CO_GBK_RESULT_SCHEMA
static final String	COMPONENT_ENCODINGS
static final String	CUSTOM_SOURCE_FORMAT
static final String	DISALLOW_COMBINER_LIFTING
static final String	DISPLAY_DATA
static final String	ENCODING
static final String	ENVIRONMENT_VERSION_JOB_TYPE_KEY
static final String	ENVIRONMENT_VERSION_MAJOR_KEY
static final String	FORMAT
static final String	IMPULSE_ELEMENT
static final String	INPUTS
static final String	IS_MERGING_WINDOW_FN
static final String	IS_PAIR_LIKE
static final String	IS_STREAM_LIKE
static final String	IS_WRAPPER
static final String	NON_PARALLEL_INPUTS
static final String	OBJECT_TYPE_NAME
static final String	OUTPUT
static final String	OUTPUT_INFO
static final String	OUTPUT_NAME
static final String	PARALLEL_INPUT
static final String	PIPELINE_PROTO_CODER_ID
static final String	PRESERVES_KEYS
static final String	PUBSUB_DYNAMIC_DESTINATIONS
static final String	PUBSUB_ID_ATTRIBUTE
static final String	PUBSUB_SERIALIZED_ATTRIBUTES_FN
static final String	PUBSUB_SUBSCRIPTION
static final String	PUBSUB_SUBSCRIPTION_OVERRIDE
static final String	PUBSUB_TIMESTAMP_ATTRIBUTE
static final String	PUBSUB_TOPIC
static final String	PUBSUB_TOPIC_OVERRIDE
static final String	RESOURCE_HINTS
static final String	RESTRICTION_CODER	Deprecated. Uses the incorrect terminology.
static final String	RESTRICTION_ENCODING
static final String	SCALAR_FIELD_NAME
static final String	SERIALIZED_FN
static final String	SERIALIZED_TEST_STREAM
static final String	SORT_VALUES
static final String	SOURCE_DOES_NOT_NEED_SPLITTING
static final String	SOURCE_ESTIMATED_SIZE_BYTES
static final String	SOURCE_IS_INFINITE
static final String	SOURCE_METADATA
static final String	SOURCE_SPEC
static final String	SOURCE_STEP_INPUT
static final String	TUPLE_TAGS
static final String	USE_INDEXED_FORMAT
static final String	USER_FN
static final String	USER_NAME
static final String	USES_KEYED_STATE
static final String	VALUE
static final String	WINDOWING_STRATEGY

Constructor Summary

Constructors

Constructor	Description
PropertyNames()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

CO_GBK_RESULT_SCHEMA

public static final String CO_GBK_RESULT_SCHEMA

See Also:

• Constant Field Values

COMPONENT_ENCODINGS

public static final String COMPONENT_ENCODINGS

See Also:

• Constant Field Values

CUSTOM_SOURCE_FORMAT

public static final String CUSTOM_SOURCE_FORMAT

See Also:

• Constant Field Values

SOURCE_STEP_INPUT

public static final String SOURCE_STEP_INPUT

See Also:

• Constant Field Values

SOURCE_SPEC

public static final String SOURCE_SPEC

See Also:

• Constant Field Values

SOURCE_METADATA

public static final String SOURCE_METADATA

See Also:

• Constant Field Values

SOURCE_DOES_NOT_NEED_SPLITTING

public static final String SOURCE_DOES_NOT_NEED_SPLITTING

See Also:

• Constant Field Values

SOURCE_IS_INFINITE

public static final String SOURCE_IS_INFINITE

See Also:

• Constant Field Values

SOURCE_ESTIMATED_SIZE_BYTES

public static final String SOURCE_ESTIMATED_SIZE_BYTES

See Also:

• Constant Field Values

ENCODING

public static final String ENCODING

See Also:

• Constant Field Values

ENVIRONMENT_VERSION_JOB_TYPE_KEY

public static final String ENVIRONMENT_VERSION_JOB_TYPE_KEY

See Also:

• Constant Field Values

ENVIRONMENT_VERSION_MAJOR_KEY

public static final String ENVIRONMENT_VERSION_MAJOR_KEY

See Also:

• Constant Field Values

FORMAT

public static final String FORMAT

See Also:

• Constant Field Values

INPUTS

public static final String INPUTS

See Also:

• Constant Field Values

IS_MERGING_WINDOW_FN

public static final String IS_MERGING_WINDOW_FN

See Also:

• Constant Field Values

IS_PAIR_LIKE

public static final String IS_PAIR_LIKE

See Also:

• Constant Field Values

IS_STREAM_LIKE

public static final String IS_STREAM_LIKE

See Also:

• Constant Field Values

IS_WRAPPER

public static final String IS_WRAPPER

See Also:

• Constant Field Values

DISALLOW_COMBINER_LIFTING

public static final String DISALLOW_COMBINER_LIFTING

See Also:

• Constant Field Values

NON_PARALLEL_INPUTS

public static final String NON_PARALLEL_INPUTS

See Also:

• Constant Field Values

OBJECT_TYPE_NAME

public static final String OBJECT_TYPE_NAME

See Also:

• Constant Field Values

OUTPUT

public static final String OUTPUT

See Also:

• Constant Field Values

OUTPUT_INFO

public static final String OUTPUT_INFO

See Also:

• Constant Field Values

OUTPUT_NAME

public static final String OUTPUT_NAME

See Also:

• Constant Field Values

PARALLEL_INPUT

public static final String PARALLEL_INPUT

See Also:

• Constant Field Values

PUBSUB_ID_ATTRIBUTE

public static final String PUBSUB_ID_ATTRIBUTE

See Also:

• Constant Field Values

PUBSUB_SERIALIZED_ATTRIBUTES_FN

public static final String PUBSUB_SERIALIZED_ATTRIBUTES_FN

See Also:

• Constant Field Values

PUBSUB_SUBSCRIPTION

public static final String PUBSUB_SUBSCRIPTION

See Also:

• Constant Field Values

PUBSUB_SUBSCRIPTION_OVERRIDE

public static final String PUBSUB_SUBSCRIPTION_OVERRIDE

See Also:

• Constant Field Values

PUBSUB_TIMESTAMP_ATTRIBUTE

public static final String PUBSUB_TIMESTAMP_ATTRIBUTE

See Also:

• Constant Field Values

PUBSUB_TOPIC

public static final String PUBSUB_TOPIC

See Also:

• Constant Field Values

PUBSUB_TOPIC_OVERRIDE

public static final String PUBSUB_TOPIC_OVERRIDE

See Also:

• Constant Field Values

PUBSUB_DYNAMIC_DESTINATIONS

public static final String PUBSUB_DYNAMIC_DESTINATIONS

See Also:

• Constant Field Values

SCALAR_FIELD_NAME

public static final String SCALAR_FIELD_NAME

See Also:

• Constant Field Values

SERIALIZED_FN

public static final String SERIALIZED_FN

See Also:

• Constant Field Values

SERIALIZED_TEST_STREAM

public static final String SERIALIZED_TEST_STREAM

See Also:

• Constant Field Values

SORT_VALUES

public static final String SORT_VALUES

See Also:

• Constant Field Values

TUPLE_TAGS

public static final String TUPLE_TAGS

See Also:

• Constant Field Values

USE_INDEXED_FORMAT

public static final String USE_INDEXED_FORMAT

See Also:

• Constant Field Values

USER_FN

public static final String USER_FN

See Also:

• Constant Field Values

USER_NAME

public static final String USER_NAME

See Also:

• Constant Field Values

USES_KEYED_STATE

public static final String USES_KEYED_STATE

See Also:

• Constant Field Values

ALLOWS_SHARDABLE_STATE

public static final String ALLOWS_SHARDABLE_STATE

See Also:

• Constant Field Values

VALUE

public static final String VALUE

See Also:

• Constant Field Values

WINDOWING_STRATEGY

public static final String WINDOWING_STRATEGY

See Also:

• Constant Field Values

DISPLAY_DATA

public static final String DISPLAY_DATA

See Also:

• Constant Field Values

RESOURCE_HINTS

public static final String RESOURCE_HINTS

See Also:

• Constant Field Values

PRESERVES_KEYS

public static final String PRESERVES_KEYS

See Also:

• Constant Field Values

ALLOW_DUPLICATES

public static final String ALLOW_DUPLICATES

See Also:

• Constant Field Values

RESTRICTION_CODER

@Deprecated
public static final 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 String IMPULSE_ELEMENT

See Also:

• Constant Field Values

PIPELINE_PROTO_CODER_ID

public static final String PIPELINE_PROTO_CODER_ID

See Also:

• Constant Field Values

RESTRICTION_ENCODING

public static final String RESTRICTION_ENCODING

See Also:

• Constant Field Values

Constructor Details

PropertyNames

public PropertyNames()