blob: dff74e9d437a9c3db1db4ee96b7818915c6038b4 [file] [log] [blame]
Apache Ignite Flink Sink Module
-----------------------------------
Apache Ignite Flink Sink module is a streaming connector to inject Flink data into Ignite cache.
Starting data transfer to Ignite can be done with the following steps.
1. Import Ignite Flink Sink Module in Maven Project
If you are using Maven to manage dependencies of your project, you can add Flink module
dependency like this (replace '${ignite.version}' with actual Ignite version you are
interested in):
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
...
<dependencies>
...
<dependency>
<groupId>org.apache.ignite</groupId>
<artifactId>ignite-flink-ext</artifactId>
<version>${ignite-flink-ext.version}</version>
</dependency>
...
</dependencies>
...
</project>
2. Create an Ignite configuration file (see example-ignite.xml) and make sure it is accessible from the sink.
3. Make sure your data input to the sink is specified. For example `input.addSink(igniteSinkObject)`