docs/extensions/flink/flink-streamer.html - ignite-website - Git at Google

 <!--
   Licensed to the Apache Software Foundation (ASF) under one or more
   contributor license agreements.  See the NOTICE file distributed with
   this work for additional information regarding copyright ownership.
   The ASF licenses this file to You under the Apache License, Version 2.0
   (the "License"); you may not use this file except in compliance with
   the License.  You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
 -->
 <!DOCTYPE html>


 <html lang="en">
 <head>
     <!-- Global site tag (gtag.js) - Google Analytics -->
     <script async src="https://www.googletagmanager.com/gtag/js?id=UA-1382082-1"></script>
     <script>
     window.dataLayer = window.dataLayer || [];
     function gtag(){dataLayer.push(arguments);}
     gtag('js', new Date());

     gtag('config', 'UA-61232409-1');
     </script>


     <meta charset="UTF-8">
     <title>Apache Flink Streamer | Ignite Documentation</title>

     <link rel="canonical" href="/docs/flink/flink-streamer" />


 	<link rel="stylesheet" href="/assets/css/styles.css?1658382975">
     <link rel="stylesheet" href="/assets/css/asciidoc-pygments.css">
     <link rel="shortcut icon" href="/favicon.ico">
     <meta name='viewport' content='width=device-width, height=device-height, initial-scale=1.0, minimum-scale=1.0'>

 	<link rel="stylesheet"
 	  href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/4.7.0/css/font-awesome.min.css">

     <script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jquery/1.7.1/jquery.min.js"></script>
     <script type="text/javascript" src="/assets/js/jquery.swiftype.autocomplete.js?1658382975"></script>
     <script type="text/javascript" src="/assets/js/anchor.min.js?1658382975"></script>


 </head>
 <body>
     <!--
   Licensed to the Apache Software Foundation (ASF) under one or more
   contributor license agreements.  See the NOTICE file distributed with
   this work for additional information regarding copyright ownership.
   The ASF licenses this file to You under the Apache License, Version 2.0
   (the "License"); you may not use this file except in compliance with
   the License.  You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
 -->

 <!--header>
     <button type='button' class='menu' title='Docs menu'>
 	  <img src="/assets/images/menu-icon.svg"/>
     </button>

     <nav>

     </nav>
     <form class='search'>
         <button class="search-close" type='button'><img src='/assets/images/cancel.svg'></button>
         <input type="search" placeholder="Search…" id="search-input">
     </form>
 	<button type='button' class='search-toggle'><img src='/assets/images/search.svg'></button>
     <button type='button' class='top-nav-toggle'>⋮</button>
     <a href="https://github.com/ignite" title='GitHub' class='github' target="_blank">
         <img src="/assets/images/github-gray.svg" alt="GitHub logo">
     </a>
 </header-->


     <!--
   Licensed to the Apache Software Foundation (ASF) under one or more
   contributor license agreements.  See the NOTICE file distributed with
   this work for additional information regarding copyright ownership.
   The ASF licenses this file to You under the Apache License, Version 2.0
   (the "License"); you may not use this file except in compliance with
   the License.  You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
 -->
 	 <link rel="stylesheet" href="/assets/css/docs.css">
 <section class='page-docs'>
     <!--
   Licensed to the Apache Software Foundation (ASF) under one or more
   contributor license agreements.  See the NOTICE file distributed with
   this work for additional information regarding copyright ownership.
   The ASF licenses this file to You under the Apache License, Version 2.0
   (the "License"); you may not use this file except in compliance with
   the License.  You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
 -->


 <nav class='left-nav' data-swiftype-index='false'>


     <li>


 <a href="/docs/extensions/aws/aws" class=''>Amazon S3 IP Finder</a>

 </li>

     <li>


 <a href="/docs/extensions/camel/camel-streamer" class=''>Apache Camel Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/flink/flink-streamer" class=''>Apache Flink Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/flume/flume-sink" class=''>Apache Flume Sink</a>

 </li>

     <li>


 <a href="/docs/extensions/azure/azure" class=''>Apache Ignite Azure Module</a>

 </li>

     <li>


 <a href="/docs/extensions/gce/gce" class=''>Apache Ignite GCE Module</a>

 </li>

     <li>


 <a href="/docs/extensions/pub-sub/pub-sub" class=''>Apache Ignite Pub/Sub Module</a>

 </li>

     <li>


 <a href="/docs/extensions/spring/spring-boot" class=''>Apache Ignite and Spring Boot</a>

 </li>

     <li>


 <a href="/docs/extensions/spring/spring-data" class=''>Apache Ignite and Spring Data</a>

 </li>

     <li>


 <a href="/docs/extensions/spring/spring-caching" class=''>Apache Ignite and Spring Cache</a>

 </li>

     <li>


 <a href="/docs/extensions/spring/spring-sessions" class=''>Apache Ignite and Spring Session</a>

 </li>

     <li>


 <a href="/docs/extensions/spring/spring-tx" class=''>Apache Ignite and Spring Transactions</a>

 </li>

     <li>


 <a href="/docs/extensions/kafka/kafka-streamer" class=''>Apache Kafka Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/storm/storm-streamer" class=''>Apache Storm Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/cdc/change-data-capture-extensions" class=''>Change Data Capture Extension</a>

 </li>

     <li>


 <a href="/docs/extensions/jms/jms-streamer" class=''>JMS Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/mqtt/mqtt-streamer" class=''>MQTT Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/perf-statistics/performance-statistics" class=''>Performance Statistics Extension</a>

 </li>

     <li>


 <a href="/docs/extensions/rocketmq/rocketmq-streamer" class=''>RocketMQ Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/topology-validator/topology-validator" class=''>Topology Validator</a>

 </li>

     <li>


 <a href="/docs/extensions/twitter/twitter-streamer" class=''>Twitter Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/zeromq/zeromq-streamer" class=''>ZeroMQ Streamer</a>

 </li>

     <li>


 <a href="/docs/extensions/zookeeper/zookeeper-ip" class=''>ZooKeeper IP Finder</a>

 </li>

 </nav>
 <div class="left-nav__overlay"></div>


     <article data-swiftype-index='true'>
         <a class='edit-link' href="/_docs/flink/flink-streamer.adoc" target="_blank">Edit</a>

             <h1>Apache Flink Streamer</h1>

         <div class="paragraph">
 <p>Apache Ignite Flink Sink module is a streaming connector to inject Flink data into Ignite cache. The sink emits its input
 data to Ignite cache. When creating a sink, an Ignite cache name and Ignite grid configuration file have to be provided.</p>
 </div>
 <div class="paragraph">
 <p>Starting data transfer to Ignite cache can be done with the following steps.</p>
 </div>
 <div class="olist arabic">
 <ol class="arabic">
 <li>
 <p>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 <code>${ignite-flink-ext.version}</code> with actual Ignite Flink Extension version you are
 interested in):</p>
 <code-tabs><code-tab data-tab='pom.xml'><div class="listingblock">
 <div class="content">
 <pre class="rouge highlight"><code data-lang="xml"><span class="nt">&lt;project</span> <span class="na">xmlns=</span><span class="s">"http://maven.apache.org/POM/4.0.0"</span>
     <span class="na">xmlns:xsi=</span><span class="s">"http://www.w3.org/2001/XMLSchema-instance"</span>
     <span class="na">xsi:schemaLocation=</span><span class="s">"http://maven.apache.org/POM/4.0.0
                         http://maven.apache.org/xsd/maven-4.0.0.xsd"</span><span class="nt">&gt;</span>
     ...
     <span class="nt">&lt;dependencies&gt;</span>
         ...
         <span class="nt">&lt;dependency&gt;</span>
             <span class="nt">&lt;groupId&gt;</span>org.apache.ignite<span class="nt">&lt;/groupId&gt;</span>
             <span class="nt">&lt;artifactId&gt;</span>ignite-flink-ext<span class="nt">&lt;/artifactId&gt;</span>
             <span class="nt">&lt;version&gt;</span>${ignite-flink-ext.version}<span class="nt">&lt;/version&gt;</span>
         <span class="nt">&lt;/dependency&gt;</span>
         ...
     <span class="nt">&lt;/dependencies&gt;</span>
     ...
 <span class="nt">&lt;/project&gt;</span></code></pre>
 </div>
 </div></code-tab></code-tabs>
 </li>
 <li>
 <p>Create an Ignite configuration file and make sure it is accessible from the sink.</p>
 </li>
 <li>
 <p>Make sure your data input to the sink is specified and start the sink.</p>
 <code-tabs><code-tab data-tab='Java'><div class="listingblock">
 <div class="content">
 <pre class="rouge highlight"><code data-lang="java"><span class="nc">IgniteSink</span> <span class="n">igniteSink</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">IgniteSink</span><span class="o">(</span><span class="s">"myCache"</span><span class="o">,</span> <span class="s">"ignite.xml"</span><span class="o">);</span>

 <span class="n">igniteSink</span><span class="o">.</span><span class="na">setAllowOverwrite</span><span class="o">(</span><span class="kc">true</span><span class="o">);</span>
 <span class="n">igniteSink</span><span class="o">.</span><span class="na">setAutoFlushFrequency</span><span class="o">(</span><span class="mi">10</span><span class="o">);</span>
 <span class="n">igniteSink</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>

 <span class="nc">DataStream</span><span class="o">&lt;</span><span class="nc">Map</span><span class="o">&gt;</span> <span class="n">stream</span> <span class="o">=</span> <span class="o">...;</span>

 <span class="c1">// Sink data into the grid.</span>
 <span class="n">stream</span><span class="o">.</span><span class="na">addSink</span><span class="o">(</span><span class="n">igniteSink</span><span class="o">);</span>
 <span class="k">try</span> <span class="o">{</span>
     <span class="n">env</span><span class="o">.</span><span class="na">execute</span><span class="o">();</span>
 <span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="nc">Exception</span> <span class="n">e</span><span class="o">){</span>
     <span class="c1">// Exception handling.</span>
 <span class="o">}</span>
 <span class="k">finally</span> <span class="o">{</span>
     <span class="n">igniteSink</span><span class="o">.</span><span class="na">stop</span><span class="o">();</span></code></pre>
 </div>
 </div></code-tab></code-tabs>
 </li>
 </ol>
 </div>
 <div class="paragraph">
 <p>Refer to the Javadocs of the <code>ignite-flink</code> module for more info on the available options.</p>
 </div>
         <!--
   Licensed to the Apache Software Foundation (ASF) under one or more
   contributor license agreements.  See the NOTICE file distributed with
   this work for additional information regarding copyright ownership.
   The ASF licenses this file to You under the Apache License, Version 2.0
   (the "License"); you may not use this file except in compliance with
   the License.  You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
 -->

 <div class="copyright">
  © 2022 The Apache Software Foundation.<br/>
 Apache, Apache Ignite, the Apache feather and the Apache Ignite logo are either registered trademarks or trademarks of The Apache Software Foundation.

 </div>

     </article>
     <!--
   Licensed to the Apache Software Foundation (ASF) under one or more
   contributor license agreements.  See the NOTICE file distributed with
   this work for additional information regarding copyright ownership.
   The ASF licenses this file to You under the Apache License, Version 2.0
   (the "License"); you may not use this file except in compliance with
   the License.  You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
 -->

 <nav class="right-nav" data-swiftype-index='false'>

     <!--
   Licensed to the Apache Software Foundation (ASF) under one or more
   contributor license agreements.  See the NOTICE file distributed with
   this work for additional information regarding copyright ownership.
   The ASF licenses this file to You under the Apache License, Version 2.0
   (the "License"); you may not use this file except in compliance with
   the License.  You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
 -->


 <footer>
 </footer>

 </nav>

 </section>
 <script type='module' src='/assets/js/code-copy-to-clipboard.js' async></script>

     <script>
     // inits deep anchors -- needs to be done here because of https://www.bryanbraun.com/anchorjs/#dont-run-it-too-late
     anchors.add('.page-docs h1, .page-docs h2, .page-docs h3:not(.discrete), .page-docs h4, .page-docs h5');
     anchors.options = {
         placement: 'right',
         visible: 'always'
     };
     </script>
 </body>
 <script type='module' src='/assets/js/index.js?1658382975' async></script>
 </html>
	<!--
	Licensed to the Apache Software Foundation (ASF) under one or more
	contributor license agreements. See the NOTICE file distributed with
	this work for additional information regarding copyright ownership.
	The ASF licenses this file to You under the Apache License, Version 2.0
	(the "License"); you may not use this file except in compliance with
	the License. You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	-->
	<!DOCTYPE html>



	<html lang="en">
	<head>
	<!-- Global site tag (gtag.js) - Google Analytics -->
	<script async src="https://www.googletagmanager.com/gtag/js?id=UA-1382082-1"></script>
	<script>
	window.dataLayer = window.dataLayer \|\| [];
	function gtag(){dataLayer.push(arguments);}
	gtag('js', new Date());

	gtag('config', 'UA-61232409-1');
	</script>



	<meta charset="UTF-8">
	<title>Apache Flink Streamer \| Ignite Documentation</title>

	<link rel="canonical" href="/docs/flink/flink-streamer" />


	<link rel="stylesheet" href="/assets/css/styles.css?1658382975">
	<link rel="stylesheet" href="/assets/css/asciidoc-pygments.css">
	<link rel="shortcut icon" href="/favicon.ico">
	<meta name='viewport' content='width=device-width, height=device-height, initial-scale=1.0, minimum-scale=1.0'>

	<link rel="stylesheet"
	href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/4.7.0/css/font-awesome.min.css">

	<script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jquery/1.7.1/jquery.min.js"></script>
	<script type="text/javascript" src="/assets/js/jquery.swiftype.autocomplete.js?1658382975"></script>
	<script type="text/javascript" src="/assets/js/anchor.min.js?1658382975"></script>


	</head>
	<body>
	<!--
	Licensed to the Apache Software Foundation (ASF) under one or more
	contributor license agreements. See the NOTICE file distributed with
	this work for additional information regarding copyright ownership.
	The ASF licenses this file to You under the Apache License, Version 2.0
	(the "License"); you may not use this file except in compliance with
	the License. You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	-->

	<!--header>
	<button type='button' class='menu' title='Docs menu'>
	<img src="/assets/images/menu-icon.svg"/>
	</button>

	<nav>

	</nav>
	<form class='search'>
	<button class="search-close" type='button'><img src='/assets/images/cancel.svg'></button>
	<input type="search" placeholder="Search…" id="search-input">
	</form>
	<button type='button' class='search-toggle'><img src='/assets/images/search.svg'></button>
	<button type='button' class='top-nav-toggle'>⋮</button>
	<a href="https://github.com/ignite" title='GitHub' class='github' target="_blank">
	<img src="/assets/images/github-gray.svg" alt="GitHub logo">
	</a>
	</header-->


	<!--
	Licensed to the Apache Software Foundation (ASF) under one or more
	contributor license agreements. See the NOTICE file distributed with
	this work for additional information regarding copyright ownership.
	The ASF licenses this file to You under the Apache License, Version 2.0
	(the "License"); you may not use this file except in compliance with
	the License. You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	-->
	<link rel="stylesheet" href="/assets/css/docs.css">
	<section class='page-docs'>
	<!--
	Licensed to the Apache Software Foundation (ASF) under one or more
	contributor license agreements. See the NOTICE file distributed with
	this work for additional information regarding copyright ownership.
	The ASF licenses this file to You under the Apache License, Version 2.0
	(the "License"); you may not use this file except in compliance with
	the License. You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	-->




	<nav class='left-nav' data-swiftype-index='false'>


	<li>


	<a href="/docs/extensions/aws/aws" class=''>Amazon S3 IP Finder</a>

	</li>

	<li>


	<a href="/docs/extensions/camel/camel-streamer" class=''>Apache Camel Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/flink/flink-streamer" class=''>Apache Flink Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/flume/flume-sink" class=''>Apache Flume Sink</a>

	</li>

	<li>


	<a href="/docs/extensions/azure/azure" class=''>Apache Ignite Azure Module</a>

	</li>

	<li>


	<a href="/docs/extensions/gce/gce" class=''>Apache Ignite GCE Module</a>

	</li>

	<li>


	<a href="/docs/extensions/pub-sub/pub-sub" class=''>Apache Ignite Pub/Sub Module</a>

	</li>

	<li>


	<a href="/docs/extensions/spring/spring-boot" class=''>Apache Ignite and Spring Boot</a>

	</li>

	<li>


	<a href="/docs/extensions/spring/spring-data" class=''>Apache Ignite and Spring Data</a>

	</li>

	<li>


	<a href="/docs/extensions/spring/spring-caching" class=''>Apache Ignite and Spring Cache</a>

	</li>

	<li>


	<a href="/docs/extensions/spring/spring-sessions" class=''>Apache Ignite and Spring Session</a>

	</li>

	<li>


	<a href="/docs/extensions/spring/spring-tx" class=''>Apache Ignite and Spring Transactions</a>

	</li>

	<li>


	<a href="/docs/extensions/kafka/kafka-streamer" class=''>Apache Kafka Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/storm/storm-streamer" class=''>Apache Storm Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/cdc/change-data-capture-extensions" class=''>Change Data Capture Extension</a>

	</li>

	<li>


	<a href="/docs/extensions/jms/jms-streamer" class=''>JMS Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/mqtt/mqtt-streamer" class=''>MQTT Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/perf-statistics/performance-statistics" class=''>Performance Statistics Extension</a>

	</li>

	<li>


	<a href="/docs/extensions/rocketmq/rocketmq-streamer" class=''>RocketMQ Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/topology-validator/topology-validator" class=''>Topology Validator</a>

	</li>

	<li>


	<a href="/docs/extensions/twitter/twitter-streamer" class=''>Twitter Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/zeromq/zeromq-streamer" class=''>ZeroMQ Streamer</a>

	</li>

	<li>


	<a href="/docs/extensions/zookeeper/zookeeper-ip" class=''>ZooKeeper IP Finder</a>

	</li>

	</nav>
	<div class="left-nav__overlay"></div>


	<article data-swiftype-index='true'>
	<a class='edit-link' href="/_docs/flink/flink-streamer.adoc" target="_blank">Edit</a>

	<h1>Apache Flink Streamer</h1>

	<div class="paragraph">
	<p>Apache Ignite Flink Sink module is a streaming connector to inject Flink data into Ignite cache. The sink emits its input
	data to Ignite cache. When creating a sink, an Ignite cache name and Ignite grid configuration file have to be provided.</p>
	</div>
	<div class="paragraph">
	<p>Starting data transfer to Ignite cache can be done with the following steps.</p>
	</div>
	<div class="olist arabic">
	<ol class="arabic">
	<li>
	<p>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 <code>${ignite-flink-ext.version}</code> with actual Ignite Flink Extension version you are
	interested in):</p>
	<code-tabs><code-tab data-tab='pom.xml'><div class="listingblock">
	<div class="content">
	<pre class="rouge highlight"><code data-lang="xml"><span class="nt"><project</span> <span class="na">xmlns=</span><span class="s">"http://maven.apache.org/POM/4.0.0"</span>
	<span class="na">xmlns:xsi=</span><span class="s">"http://www.w3.org/2001/XMLSchema-instance"</span>
	<span class="na">xsi:schemaLocation=</span><span class="s">"http://maven.apache.org/POM/4.0.0
	http://maven.apache.org/xsd/maven-4.0.0.xsd"</span><span class="nt">></span>
	...
	<span class="nt"><dependencies></span>
	...
	<span class="nt"><dependency></span>
	<span class="nt"><groupId></span>org.apache.ignite<span class="nt"></groupId></span>
	<span class="nt"><artifactId></span>ignite-flink-ext<span class="nt"></artifactId></span>
	<span class="nt"><version></span>${ignite-flink-ext.version}<span class="nt"></version></span>
	<span class="nt"></dependency></span>
	...
	<span class="nt"></dependencies></span>
	...
	<span class="nt"></project></span></code></pre>
	</div>
	</div></code-tab></code-tabs>
	</li>
	<li>
	<p>Create an Ignite configuration file and make sure it is accessible from the sink.</p>
	</li>
	<li>
	<p>Make sure your data input to the sink is specified and start the sink.</p>
	<code-tabs><code-tab data-tab='Java'><div class="listingblock">
	<div class="content">
	<pre class="rouge highlight"><code data-lang="java"><span class="nc">IgniteSink</span> <span class="n">igniteSink</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">IgniteSink</span><span class="o">(</span><span class="s">"myCache"</span><span class="o">,</span> <span class="s">"ignite.xml"</span><span class="o">);</span>

	<span class="n">igniteSink</span><span class="o">.</span><span class="na">setAllowOverwrite</span><span class="o">(</span><span class="kc">true</span><span class="o">);</span>
	<span class="n">igniteSink</span><span class="o">.</span><span class="na">setAutoFlushFrequency</span><span class="o">(</span><span class="mi">10</span><span class="o">);</span>
	<span class="n">igniteSink</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>

	<span class="nc">DataStream</span><span class="o"><</span><span class="nc">Map</span><span class="o">></span> <span class="n">stream</span> <span class="o">=</span> <span class="o">...;</span>

	<span class="c1">// Sink data into the grid.</span>
	<span class="n">stream</span><span class="o">.</span><span class="na">addSink</span><span class="o">(</span><span class="n">igniteSink</span><span class="o">);</span>
	<span class="k">try</span> <span class="o">{</span>
	<span class="n">env</span><span class="o">.</span><span class="na">execute</span><span class="o">();</span>
	<span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="nc">Exception</span> <span class="n">e</span><span class="o">){</span>
	<span class="c1">// Exception handling.</span>
	<span class="o">}</span>
	<span class="k">finally</span> <span class="o">{</span>
	<span class="n">igniteSink</span><span class="o">.</span><span class="na">stop</span><span class="o">();</span></code></pre>
	</div>
	</div></code-tab></code-tabs>
	</li>
	</ol>
	</div>
	<div class="paragraph">
	<p>Refer to the Javadocs of the <code>ignite-flink</code> module for more info on the available options.</p>
	</div>
	<!--
	Licensed to the Apache Software Foundation (ASF) under one or more
	contributor license agreements. See the NOTICE file distributed with
	this work for additional information regarding copyright ownership.
	The ASF licenses this file to You under the Apache License, Version 2.0
	(the "License"); you may not use this file except in compliance with
	the License. You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	-->

	<div class="copyright">
	© 2022 The Apache Software Foundation.<br/>
	Apache, Apache Ignite, the Apache feather and the Apache Ignite logo are either registered trademarks or trademarks of The Apache Software Foundation.

	</div>

	</article>
	<!--
	Licensed to the Apache Software Foundation (ASF) under one or more
	contributor license agreements. See the NOTICE file distributed with
	this work for additional information regarding copyright ownership.
	The ASF licenses this file to You under the Apache License, Version 2.0
	(the "License"); you may not use this file except in compliance with
	the License. You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	-->

	<nav class="right-nav" data-swiftype-index='false'>

	<!--
	Licensed to the Apache Software Foundation (ASF) under one or more
	contributor license agreements. See the NOTICE file distributed with
	this work for additional information regarding copyright ownership.
	The ASF licenses this file to You under the Apache License, Version 2.0
	(the "License"); you may not use this file except in compliance with
	the License. You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	-->


	<footer>
	</footer>

	</nav>

	</section>
	<script type='module' src='/assets/js/code-copy-to-clipboard.js' async></script>

	<script>
	// inits deep anchors -- needs to be done here because of https://www.bryanbraun.com/anchorjs/#dont-run-it-too-late
	anchors.add('.page-docs h1, .page-docs h2, .page-docs h3:not(.discrete), .page-docs h4, .page-docs h5');
	anchors.options = {
	placement: 'right',
	visible: 'always'
	};
	</script>
	</body>
	<script type='module' src='/assets/js/index.js?1658382975' async></script>
	</html>