This is an automated email from the ASF dual-hosted git repository.
jrmccluskey 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 07e8aaf226b fix Bigtable naming (#40206)
07e8aaf226b is described below
commit 07e8aaf226b5d801107020d4b1c6c6fc437bfb2d
Author: Derrick Williams <[email protected]>
AuthorDate: Tue Sep 22 14:00:12 2026 -0400
fix Bigtable naming (#40206)
---
.../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 ca4caee2e46..0491a21d60b 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 1d5c78c6699..b57f198005d 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 800ec6aa9ee..f8e1959b3b5 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<string, string> = {
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 c41dd6f2e07..a8691317d3c 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 2f97b83c6e9..d659eeb1968 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}"
