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

Reply via email to