File tree Expand file tree Collapse file tree 2 files changed +6
-2
lines changed
bigtable/beam/change-streams Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ feature.
24
24
` ` ` sh
25
25
gcloud alpha bigtable instances tables create $TABLE_ID \
26
26
--column-families=cf1 --change-stream-retention-period=7d \
27
- --instance=$BIGTABLE_TESTING_INSTANCE --project=$GOOGLE_CLOUD_PROJECT
27
+ --instance=$BIGTABLE_TESTING_INSTANCE --project=$GOOGLE_CLOUD_PROJECT
28
28
` ` `
29
29
30
30
1. Run command to start the pipeline
@@ -33,7 +33,7 @@ feature.
33
33
mvn compile exec:java -Dexec.mainClass=ChangeStreamsHelloWorld \
34
34
" -Dexec.args=--project=$GOOGLE_CLOUD_PROJECT --bigtableProjectId=$BIGTABLE_PROJECT \
35
35
--bigtableInstanceId=$INSTANCE_ID --bigtableTableId=$TABLE_ID \
36
- --runner=dataflow --region=$REGION "
36
+ --runner=dataflow --region=$REGION --experiments=use_runner_v2 "
37
37
` ` `
38
38
39
39
1. Make changes to your data via the clients or with the ` cbt` CLI, and view the
Original file line number Diff line number Diff line change
1
+ ,col1
2
+ user123#2023,abc
3
+ user546#2023,def
4
+ user789#2023,ghi
You can’t perform that action at this time.
0 commit comments