This is an automated email from the ASF dual-hosted git repository. derrickaw pushed a commit to branch revert-40206-20260921_updateBigTableNaming in repository https://gitbox.apache.org/repos/asf/beam.git
commit 2766d56e4cd51d7738f10243da286594622da1f3 Author: Derrick Williams <[email protected]> AuthorDate: Wed Sep 23 12:59:15 2026 -0400 Revert "fix Bigtable naming (#40206)" 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 a8691317d3c..c41dd6f2e07 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}"
