Hi there ! I have implemented Apache Ignite Flink integration. The design is based on using IgniteQueue as a sink for Flink DataStreams. The IgniteSink implements RichSinkFunction and enable custom implementation of Data sinks. The Data sink consumes DataStreams and forwards them to IgniteQueue.
Please review this PR https://github.com/apache/ignite/pull/550 and share feedback. Regards Saikat On Mon, Feb 8, 2016 at 10:57 PM, Saikat Maitra <[email protected]> wrote: > Thank you Roman !!! > > On Mon, Feb 8, 2016 at 3:20 PM, Roman Shtykh <[email protected]> > wrote: > >> Hi Saikat, >> Probably [1] can give you some pointers where to start. >> [1] >> http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-and-Spark-Integration-and-Acceleration-td82.html >> -Roman >> >> >> On Monday, February 8, 2016 2:25 AM, Saikat Maitra < >> [email protected]> wrote: >> >> >> Hi, >> >> I am looking forward to taking up this ticket >> https://issues.apache.org/jira/browse/IGNITE-813 (Apache Flink >> Integration). >> >> I wanted to understand which module will be suitable for integration. Any >> reference to similar integration or pointers to design discussion will be >> helpful. >> >> Regards >> Saikat >> >> >> >> > >
