This is an automated email from the ASF dual-hosted git repository.
derrickaw pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new a40a3e32ef8 Revert "fix Bigtable naming (#40206)" (#40245)
a40a3e32ef8 is described below
commit a40a3e32ef876f9c4afcecb0a266191a73d054fb
Author: Derrick Williams <[email protected]>
AuthorDate: Wed Sep 23 15:17:05 2026 -0400
Revert "fix Bigtable naming (#40206)" (#40245)
This reverts commit 07e8aaf226b5d801107020d4b1c6c6fc437bfb2d.
---
.../gcp/bigtable/BigtableReadSchemaTransformProvider.java | 2 +-
.../bigtable/BigtableWriteSchemaTransformProvider.java | 2 +-
.../apache-beam-jupyterlab-sidepanel/src/yaml/EmojiMap.ts | 3 +--
sdks/python/apache_beam/yaml/standard_io.yaml | 15 ++++++++-------
sdks/python/apache_beam/yaml/tests/bigtable.yaml | 8 ++++----
5 files changed, 15 insertions(+), 15 deletions(-)
diff --git
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadSchemaTransformProvider.java
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadSchemaTransformProvider.java
index 0491a21d60b..ca4caee2e46 100644
---
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadSchemaTransformProvider.java
+++
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadSchemaTransformProvider.java
@@ -96,7 +96,7 @@ public class BigtableReadSchemaTransformProvider
+ "The transform requires the project ID, instance ID, and table ID
parameters.\n"
+ "Optionally, the output can be flattened or nested rows.\n"
+ "Example usage:\n"
- + " - type: ReadFromBigtable\n"
+ + " - type: ReadFromBigTable\n"
+ " config:\n"
+ " project: \"my-gcp-project\"\n"
+ " instance: \"my-bigtable-instance\"\n"
diff --git
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteSchemaTransformProvider.java
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteSchemaTransformProvider.java
index b57f198005d..1d5c78c6699 100644
---
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteSchemaTransformProvider.java
+++
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteSchemaTransformProvider.java
@@ -90,7 +90,7 @@ public class BigtableWriteSchemaTransformProvider
+ "This transform requires the Google Cloud project ID, Bigtable
instance ID, and table ID.\n"
+ "The input PCollection should be schema-compliant mutations or keyed
rows.\n"
+ "Example usage:\n"
- + " - type: WriteToBigtable\n"
+ + " - type: WriteToBigTable\n"
+ " input: input\n"
+ " config:\n"
+ " project: \"my-gcp-project\"\n"
diff --git
a/sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml/EmojiMap.ts
b/sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml/EmojiMap.ts
index f8e1959b3b5..800ec6aa9ee 100644
---
a/sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml/EmojiMap.ts
+++
b/sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml/EmojiMap.ts
@@ -41,8 +41,7 @@ export const transformEmojiMap: Record<string, string> = {
WriteToAvro: '⬆️📁',
ReadFromBigQuery: '⬇️📊',
WriteToBigQuery: '⬆️📊',
- ReadFromBigtable: '⬇️📋',
- WriteToBigtable: '⬆️📋',
+ WriteToBigTable: '⬆️📋',
ReadFromCsv: '⬇️📝',
WriteToCsv: '⬆️📝',
ReadFromIceberg: '⬇️🧊',
diff --git a/sdks/python/apache_beam/yaml/standard_io.yaml
b/sdks/python/apache_beam/yaml/standard_io.yaml
index b6050738651..2d2c2af6da1 100644
--- a/sdks/python/apache_beam/yaml/standard_io.yaml
+++ b/sdks/python/apache_beam/yaml/standard_io.yaml
@@ -588,27 +588,28 @@
config:
gradle_target: 'sdks:java:io:expansion-service:shadowJar'
-# Bigtable
+#BigTable
- type: renaming
transforms:
- 'ReadFromBigtable': 'ReadFromBigtable'
- 'WriteToBigtable': 'WriteToBigtable'
+ 'ReadFromBigTable': 'ReadFromBigTable'
+ 'WriteToBigTable': 'WriteToBigTable'
config:
mappings:
- 'ReadFromBigtable':
+ #Temp removing read from bigTable IO
+ 'ReadFromBigTable':
project: 'project_id'
instance: 'instance_id'
table: 'table_id'
flatten: "flatten"
- 'WriteToBigtable':
+ 'WriteToBigTable':
project: 'project_id'
instance: 'instance_id'
table: 'table_id'
underlying_provider:
type: beamJar
transforms:
- 'ReadFromBigtable':
'beam:schematransform:org.apache.beam:bigtable_read:v1'
- 'WriteToBigtable':
'beam:schematransform:org.apache.beam:bigtable_write:v1'
+ 'ReadFromBigTable':
'beam:schematransform:org.apache.beam:bigtable_read:v1'
+ 'WriteToBigTable':
'beam:schematransform:org.apache.beam:bigtable_write:v1'
config:
gradle_target:
'sdks:java:io:google-cloud-platform:expansion-service:shadowJar'
diff --git a/sdks/python/apache_beam/yaml/tests/bigtable.yaml
b/sdks/python/apache_beam/yaml/tests/bigtable.yaml
index d659eeb1968..2f97b83c6e9 100644
--- a/sdks/python/apache_beam/yaml/tests/bigtable.yaml
+++ b/sdks/python/apache_beam/yaml/tests/bigtable.yaml
@@ -27,7 +27,7 @@ fixtures:
config:
bucket: "gs://temp-storage-for-end-to-end-tests/temp-it"
- # Tests for Bigtable YAML IO
+ # Tests for BigTable YAML IO
pipelines:
- pipeline:
@@ -78,7 +78,7 @@ pipelines:
# fields are already of the correct type (String, Long) or are
optional.
# We only need to convert fields that are Strings in YAML but
need to be Bytes in Java.
- - type: WriteToBigtable
+ - type: WriteToBigTable
config:
project: 'apache-beam-testing'
instance: "{BT_INSTANCE}"
@@ -86,7 +86,7 @@ pipelines:
- pipeline:
type: chain
transforms:
- - type: ReadFromBigtable
+ - type: ReadFromBigTable
config:
project: 'apache-beam-testing'
instance: "{BT_INSTANCE}"
@@ -133,7 +133,7 @@ pipelines:
- pipeline:
type: chain
transforms:
- - type: ReadFromBigtable
+ - type: ReadFromBigTable
config:
project: 'apache-beam-testing'
instance: "{BT_INSTANCE}"
