Enum StreamingMode (0.67.0) 

public enum StreamingMode extends Enum<StreamingMode> implements ProtocolMessageEnum

Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages written to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see Set the pipeline streaming mode.

Protobuf enum google.dataflow.v1beta3.StreamingMode

Implements

ProtocolMessageEnum

Static Fields

Name Description
STREAMING_MODE_AT_LEAST_ONCE

Message deduplication is not performed. Messages might be processed multiple times, and the results are applied multiple times. Note: Setting this value also enables Streaming Engine and Streaming Engine resource-based billing.

STREAMING_MODE_AT_LEAST_ONCE = 2;
STREAMING_MODE_AT_LEAST_ONCE_VALUE

Message deduplication is not performed. Messages might be processed multiple times, and the results are applied multiple times. Note: Setting this value also enables Streaming Engine and Streaming Engine resource-based billing.

STREAMING_MODE_AT_LEAST_ONCE = 2;
STREAMING_MODE_EXACTLY_ONCE

In this mode, message deduplication is performed against persistent state to make sure each message is processed and committed to storage exactly once.

STREAMING_MODE_EXACTLY_ONCE = 1;
STREAMING_MODE_EXACTLY_ONCE_VALUE

In this mode, message deduplication is performed against persistent state to make sure each message is processed and committed to storage exactly once.

STREAMING_MODE_EXACTLY_ONCE = 1;
STREAMING_MODE_UNSPECIFIED

Run in the default mode.

STREAMING_MODE_UNSPECIFIED = 0;
STREAMING_MODE_UNSPECIFIED_VALUE

Run in the default mode.

STREAMING_MODE_UNSPECIFIED = 0;
UNRECOGNIZED

Static Methods

Name Description
forNumber(int value)
getDescriptor()
internalGetValueMap()
valueOf(Descriptors.EnumValueDescriptor desc)
valueOf(int value)

Deprecated. Use #forNumber(int) instead.
valueOf(String name)
values()

Methods

Name Description
getDescriptorForType()
getNumber()
getValueDescriptor()