Skip to content

Commit 5808923

Browse files
committed
fix generate external transforms
1 parent 0a09db3 commit 5808923

1 file changed

Lines changed: 35 additions & 1 deletion

File tree

sdks/standard_external_transforms.yaml

Lines changed: 35 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
# configuration in /sdks/standard_expansion_services.yaml.
2020
# Refer to gen_xlang_wrappers.py for more info.
2121
#
22-
# Last updated on: 2026-05-06
22+
# Last updated on: 2026-06-02
2323

2424
- default_service: sdks:java:io:expansion-service:shadowJar
2525
description: 'Outputs a PCollection of Beam Rows, each containing a single INT64
@@ -50,6 +50,40 @@
5050
type: int64
5151
identifier: beam:schematransform:org.apache.beam:generate_sequence:v1
5252
name: GenerateSequence
53+
- default_service: sdks:java:io:expansion-service:shadowJar
54+
description: ''
55+
destinations:
56+
python: apache_beam/io
57+
fields:
58+
- description: The MongoDB collection to read from.
59+
name: collection
60+
nullable: false
61+
type: str
62+
- description: The MongoDB database to read from.
63+
name: database
64+
nullable: false
65+
type: str
66+
- description: This option specifies whether and where to output rows that failed
67+
to be read.
68+
name: error_handling
69+
nullable: true
70+
type: Row(output=<class 'str'>)
71+
- description: An optional BSON filter to apply to the read. This should be a valid
72+
JSON string.
73+
name: filter
74+
nullable: true
75+
type: str
76+
- description: The schema in which the data is encoded, defined with JSON-schema
77+
syntax (https://json-schema.org/).
78+
name: schema
79+
nullable: false
80+
type: str
81+
- description: The connection URI for the MongoDB server.
82+
name: uri
83+
nullable: false
84+
type: str
85+
identifier: beam:schematransform:org.apache.beam:mongodb_read:v1
86+
name: MongodbRead
5387
- default_service: sdks:java:io:expansion-service:shadowJar
5488
description: ''
5589
destinations:

0 commit comments

Comments
 (0)