Skip to content

Commit 24b9f20

Browse files
committed
add streaming option
1 parent 80990d2 commit 24b9f20

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

sdks/python/apache_beam/yaml/examples/transforms/blueprint/kafka_to_iceberg.yaml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,8 @@ pipeline:
6363
"fs.gs.auth.type": "SERVICE_ACCOUNT_JSON_KEYFILE"
6464
"fs.gs.auth.service.account.json.keyfile": "/path/to/service/account/key.json"
6565

66+
options:
67+
streaming: true
6668

6769
# Expected:
6870
# Row(text='Fool\tThou shouldst not have been old till thou hadst')

sdks/python/apache_beam/yaml/examples/transforms/blueprint/pubsub_to_iceberg.yaml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,8 @@ pipeline:
4848
"fs.gs.auth.type": "SERVICE_ACCOUNT_JSON_KEYFILE"
4949
"fs.gs.auth.service.account.json.keyfile": "/path/to/service/account/key.json"
5050

51+
options:
52+
streaming: true
5153

5254
# Expected:
5355
# Row(label='37a', rank=1)

0 commit comments

Comments
 (0)