Hi Saikat, Thank you for the PR! I will review it.Please see my comments at jira. -Roman
On Sunday, March 13, 2016 6:07 PM, Saikat Maitra <saikat.mai...@gmail.com> wrote: 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. RegardsSaikat On Mon, Feb 8, 2016 at 10:57 PM, Saikat Maitra <saikat.mai...@gmail.com> wrote: Thank you Roman !!! On Mon, Feb 8, 2016 at 3:20 PM, Roman Shtykh <rsht...@yahoo.com.invalid> 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 <saikat.mai...@gmail.com> 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