From 7793982b12ac2eaa8aef66b017599d74131a0f36 Mon Sep 17 00:00:00 2001 From: Derrick Williams Date: Mon, 21 Sep 2026 17:08:50 +0000 Subject: [PATCH] fix Bigtable naming --- .../BigtableReadSchemaTransformProvider.java | 2 +- .../BigtableWriteSchemaTransformProvider.java | 2 +- .../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 ca4caee2e469..0491a21d60b4 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 String description() { + "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 1d5c78c6699e..b57f198005d3 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 String description() { + "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 800ec6aa9eea..f8e1959b3b54 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,7 +41,8 @@ export const transformEmojiMap: Record = { WriteToAvro: '⬆️📁', ReadFromBigQuery: '⬇️📊', WriteToBigQuery: '⬆️📊', - WriteToBigTable: '⬆️📋', + ReadFromBigtable: '⬇️📋', + 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 c41dd6f2e07f..a8691317d3ca 100644 --- a/sdks/python/apache_beam/yaml/standard_io.yaml +++ b/sdks/python/apache_beam/yaml/standard_io.yaml @@ -588,28 +588,27 @@ config: gradle_target: 'sdks:java:io:expansion-service:shadowJar' -#BigTable +# Bigtable - type: renaming transforms: - 'ReadFromBigTable': 'ReadFromBigTable' - 'WriteToBigTable': 'WriteToBigTable' + 'ReadFromBigtable': 'ReadFromBigtable' + 'WriteToBigtable': 'WriteToBigtable' config: mappings: - #Temp removing read from bigTable IO - 'ReadFromBigTable': + '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 2f97b83c6e92..d659eeb1968f 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}"