[ https://issues.apache.org/jira/browse/IGNITE-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193521#comment-15193521 ]
Saikat Maitra commented on IGNITE-813: -------------------------------------- [~roman_s] Roman, I have implemented similar to Flink streaming connectors https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/index.html but instead of using Ignite FileSystem I am using IgniteQueue as a sink for storing the computation results. The code changes is similar to StormStreamer but I extended RichSinkFunction to collect the computation data and persist in IgniteQueue. Regards Saikat > Apache Flink Integration > ------------------------ > > Key: IGNITE-813 > URL: https://issues.apache.org/jira/browse/IGNITE-813 > Project: Ignite > Issue Type: New Feature > Reporter: Suminda Dharmasena > Assignee: Saikat Maitra > -- This message was sent by Atlassian JIRA (v6.3.4#6332)