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
