Reference documentation and code samples for the Google Cloud Dataflow V1beta3 Client class StreamingMode.
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 type google.dataflow.v1beta3.StreamingMode
Namespace
Google \ Cloud \ Dataflow \ V1beta3
Methods
static::name
Parameter
Name
Description
value
mixed
static::value
Parameter
Name
Description
name
mixed
Constants
STREAMING_MODE_UNSPECIFIED
Value: 0
Run in the default mode.
Generated from protobuf enum STREAMING_MODE_UNSPECIFIED = 0;
STREAMING_MODE_EXACTLY_ONCE
Value: 1
In this mode, message deduplication is performed against persistent state
to make sure each message is processed and committed to storage exactly
once.
Generated from protobuf enum STREAMING_MODE_EXACTLY_ONCE = 1;
STREAMING_MODE_AT_LEAST_ONCE
Value: 2
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.
Generated from protobuf enum STREAMING_MODE_AT_LEAST_ONCE = 2;
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-28 UTC."],[],[],null,["# Google Cloud Dataflow V1beta3 Client - Class StreamingMode (0.8.2)\n\nVersion latestkeyboard_arrow_down\n\n- [0.8.2 (latest)](/php/docs/reference/cloud-dataflow/latest/V1beta3.StreamingMode)\n- [0.8.1](/php/docs/reference/cloud-dataflow/0.8.1/V1beta3.StreamingMode)\n- [0.7.1](/php/docs/reference/cloud-dataflow/0.7.1/V1beta3.StreamingMode)\n- [0.6.6](/php/docs/reference/cloud-dataflow/0.6.6/V1beta3.StreamingMode)\n- [0.5.1](/php/docs/reference/cloud-dataflow/0.5.1/V1beta3.StreamingMode)\n- [0.4.1](/php/docs/reference/cloud-dataflow/0.4.1/V1beta3.StreamingMode)\n- [0.3.10](/php/docs/reference/cloud-dataflow/0.3.10/V1beta3.StreamingMode) \n| **Beta**\n|\n|\n| This library is covered by the [Pre-GA Offerings Terms](/terms/service-terms#1)\n| of the Terms of Service. Pre-GA libraries might have limited support,\n| and changes to pre-GA libraries might not be compatible with other pre-GA versions.\n| For more information, see the\n[launch stage descriptions](/products#product-launch-stages). \nReference documentation and code samples for the Google Cloud Dataflow V1beta3 Client class StreamingMode.\n\nSpecifies the Streaming Engine message processing guarantees. Reduces cost\nand latency but might result in duplicate messages written to storage.\n\nDesigned to run simple mapping streaming ETL jobs at the lowest cost.\nFor example, Change Data Capture (CDC) to BigQuery is a canonical use\ncase. For more information, see\n[Set the pipeline streaming\nmode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).\n\nProtobuf type `google.dataflow.v1beta3.StreamingMode`\n\nNamespace\n---------\n\nGoogle \\\\ Cloud \\\\ Dataflow \\\\ V1beta3\n\nMethods\n-------\n\n### static::name\n\n### static::value\n\nConstants\n---------\n\n### STREAMING_MODE_UNSPECIFIED\n\n Value: 0\n\nRun in the default mode.\n\nGenerated from protobuf enum `STREAMING_MODE_UNSPECIFIED = 0;`\n\n### STREAMING_MODE_EXACTLY_ONCE\n\n Value: 1\n\nIn this mode, message deduplication is performed against persistent state\nto make sure each message is processed and committed to storage exactly\nonce.\n\nGenerated from protobuf enum `STREAMING_MODE_EXACTLY_ONCE = 1;`\n\n### STREAMING_MODE_AT_LEAST_ONCE\n\n Value: 2\n\nMessage deduplication is not performed. Messages might be processed\nmultiple times, and the results are applied multiple times.\n\nNote: Setting this value also enables Streaming Engine and\nStreaming Engine resource-based billing.\n\nGenerated from protobuf enum `STREAMING_MODE_AT_LEAST_ONCE = 2;`"]]
