Valentin Kulichenko created IGNITE-2822:
---
Summary: Continuous query local listener can be notified with
empty list of events
Key: IGNITE-2822
URL: https://issues.apache.org/jira/browse/IGNITE-2822
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.
GitHub user samaitra opened a pull request:
https://github.com/apache/ignite/pull/550
IGNITE-813 Apache Flink Integration
Apache Ignite Flink Sink Module
---
Apache Ignite Flink Sink module provides sink via Ignite queue.