ahmedabu98 commented on code in PR #34515: URL: https://github.com/apache/beam/pull/34515#discussion_r2025499998
########## website/www/site/content/en/documentation/sdks/python-custom-multi-language-pipelines-guide.md: ########## @@ -270,6 +270,23 @@ inspect.signature(MyTransform) This metadata is generated directly from the provider's implementation. The class documentation is generated from the [optional **description** method](#additional-metadata). The signature information is generated from the `@SchemaFieldDescription` annotations in the [configuration object](#implement-a-configuration). +### Using Beam native Java SchemaTransforms +If there's an existing Beam native Java SchemaTransform you'd like to use, and you know which expansion service module it's in, you can connect to it using `BeamJarExpansionService`: + +```python +from apache_beam.transforms.external_transform_provider import ExternalTransformProvider +from apache_beam.transforms.external import BeamJarExpansionService + +identifier = "beam:schematransform:org.apache.beam:bigquery_fileloads:v1" +expansion_service = "sdks:java:io:google-cloud-platform:expansion-service:shadowJar" + +provider = ExternalTransformProvider(BeamJarExpansionService(expansion_service)) +BqFileLoads = provider.get_urn(identifier) + +with beam.Pipeline(argv=args) as p: + p | beam.Create(...) | MyTransform(table="project.dataset.table") Review Comment: Nice catch, fixed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
