FYI this functionality exists in scio. See here: https://github.com/spotify/scio/blob/2b321224723a292e7fc8f5b299d4006470ad4353/scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/BigtableDoFn.java#L35
On Tue, Dec 24, 2024 at 10:43 AM XQ Hu via user <user@beam.apache.org> wrote: > I created one example here > https://github.com/liferoad/beam-multi_language_inference by following > https://github.com/apache/beam/tree/master/sdks/python/apache_beam/examples/inference/multi_language_inference. > This is not the same as what you asked for. But this should work if you > package BigTableEnrichmentHandler > like PytorchModelHandlerKeyedTensorWrapper in the example. > > On Tue, Dec 24, 2024 at 3:56 AM Bartosz Kotwica < > bartosz.kotw...@allegro.com> wrote: > >> Hi Apache Beam Team, >> I hope this message finds you well. >> I am working on a project that involves using multi-language pipelines in >> Java. Specifically, I am trying to integrate a Python-based transformation, >> Enrichment, with BigTableEnrichmentHandler within my Java code. Despite >> several attempts, I am uncertain if this integration is feasible. I could >> not find a way to create a handler and subsequently use it for the >> transformation. >> >> Could you please provide support or share a minimal working example of >> such a configuration? >> >> Thank you in advance for your help. >> Best regards, >> Bartosz Kotwica > >
