@lukecwik here is the example: https://github.com/lyft/beam/blob/release-2.8.0-lyft/sdks/python/custom-source-example.py
and the translator extension: https://github.com/lyft/beam/blob/release-2.8.0-lyft/runners/flink/src/main/java/org/apache/beam/runners/flink/LyftFlinkStreamingPortableTranslations.java#L52 [ Full content available at: https://github.com/apache/beam/pull/6328 ] This message was relayed via gitbox.apache.org for [email protected]
