I was taking KafkaIO as an example of x-lang when I was doing something
related:

   - python transform:
   
https://github.com/apache/beam/blob/e1fdb9884898a673285b3b932fa99ae019b9c7b5/sdks/python/apache_beam/io/kafka.py#L110
   - java transform:
   
https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L559
   - python pipeline:
   
https://github.com/apache/beam/blob/master/sdks/python/apache_beam/io/external/xlang_kafkaio_it_test.py#L87


On Wed, Nov 11, 2020 at 11:07 AM Ke Wu <ke.wu...@gmail.com> wrote:

> Hello,
>
> Is there an example demonstrating how a cross language pipeline look like?
> e.g. a pipeline where it is composes of Java and Python code/transforms.
>
> Best,
> Ke

Reply via email to