Hi, I have been working on implementing the Apache Ignite Runner to run Apache Beam pipeline. I have created IgniteRunner and IgnitePipelineOptions. I have implemented the normalize pipeline method and currently working on run method implementation for Pipeline and IgnitePipelineTranslator.
Jira : https://issues.apache.org/jira/browse/BEAM-9045 PR : https://github.com/apache/beam/pull/12593 Please review and feel free to share any feedback or questions. Regards, Saikat