Hi Raul, thanks a lot for reaching out to the Flink community. I'm really excited to see a Flink connector in Ignite. If you feel that the connector would be more suitable for our "connector library" feel free to open a JIRA and open a pull request.
Were there requests in the Ignite community to have an integration with Flink? On Thu, Mar 31, 2016 at 5:20 PM, Saikat Maitra <saikat.mai...@gmail.com> wrote: > Hi , > > I agree with Roman and Raul. > https://issues.apache.org/jira/browse/IGNITE-813 allows injecting data to > into cache via Data Streamer. Integrating with Ignite FileSystem for source > and sink will allow for bidirectional connector. It will also allow easier > implementation for DataStream transformations over Ignite FileSystem. > > Regards > Saikat > > On Thu, Mar 31, 2016 at 2:44 PM, Aljoscha Krettek <aljos...@apache.org> > wrote: > > > Hi, > > it should already be possible to use the Ignite FileSystem to store state > > since we just use the HDFS FileSystem interface for that. Of course, one > > would have to properly set up the jars and paths and everything for Flink > > to pick up the IGFS classes. > > > > Cheers, > > Aljoscha > > > > On Wed, 30 Mar 2016 at 16:50 Raul Kripalani <ra...@apache.org> wrote: > > > > > On Wed, Mar 30, 2016 at 2:20 PM, Roman <rsht...@yahoo.com.invalid> > > wrote: > > > > > > > Raul, > > > > > > > > Small comment from me. > > > > > > > > >* As a Flink sink => inject data directly into a cache via a > > > DataStreamer. > > > > After reviews, IGNITE-813 is exactly this functionality. > > > > > > > > > > > That's cool, Roman! The idea would be to host these (richer) modules as > > > Flink connectors, like they do with others: > > > > > > https://github.com/apache/flink/tree/master/flink-streaming-connectors > > > https://github.com/apache/flink/tree/master/flink-batch-connectors > > > > > >
