Google Git
Sign in
apache / ignite-website / 8b28a1e209dc48b2c8ce46375ab5e85fdea55105 / . / releases / 1.0.0-rc3 / javadoc / org / apache / ignite / streamer / StreamerConfiguration.html
blob: 167658cd35ea53b29decd4c68e7066ded033ad7d [file] [log] [blame]
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<!-- NewPage -->
<html lang="en">
<head>
<META NAME="ROBOTS" CONTENT="NOINDEX">
<link rel="canonical" href="https://ignite.apache.org/releases/1.0.0-rc3/javadoc/org/apache/ignite/streamer/StreamerConfiguration.html" />
<!-- Generated by javadoc (version 1.7.0_21) on Tue Mar 24 10:27:31 MSK 2015 -->
<meta http-equiv="Content-Type" content="text/html" charset="UTF-8">
<title>StreamerConfiguration (Ignite 1.0.0-RC3)</title>
<meta name="date" content="2015-03-24">
<link rel="stylesheet" type="text/css" href="../../../../javadoc.css" title="Style">
<link rel='shortcut icon' href='http://gridgain.com/wp-content/uploads/2014/09/favicon.ico'/>
<link type='text/css' rel='stylesheet' href='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/styles/shCore.css'/>
<link type='text/css' rel='stylesheet' href='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/styles/shThemeDefault.css'/>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shCore.js'></script>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shLegacy.js'></script>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shBrushJava.js'></script>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shBrushPlain.js'></script>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shBrushJScript.js'></script>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shBrushBash.js'></script>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shBrushXml.js'></script>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shBrushScala.js'></script>
<script type='text/javascript' src='http://gridgain.com/wp-content/plugins/syntaxhighlighter/syntaxhighlighter3/scripts/shBrushGroovy.js'></script>
<script>
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
})(window,document,'script','https://www.google-analytics.com/analytics.js','ga');
ga('create', 'UA-61232409-1', 'auto');
ga('send', 'pageview');
</script></head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
parent.document.title="StreamerConfiguration (Ignite 1.0.0-RC3)";
}
//-->
</script>
<noscript>
<div>JavaScript is disabled on your browser.</div>
</noscript>
<!-- ========= START OF TOP NAVBAR ======= -->
<div class="topNav"><a name="navbar_top">
<!-- -->
</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="../../../../overview-summary.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
<li><a href="class-use/StreamerConfiguration.html">Use</a></li>
<li><a href="package-tree.html">Tree</a></li>
<li><a href="../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../index-all.html">Index</a></li>
<li><a href="../../../../help-doc.html">Help</a></li>
</ul>
<div class="aboutLanguage"><em>Apache Ignite - In-Memory Data Fabric</em></div>
</div>
<div class="subNav">
<ul class="navList">
<li>Prev Class</li>
<li><a href="../../../../org/apache/ignite/streamer/StreamerContext.html" title="interface in org.apache.ignite.streamer"><span class="strong">Next Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../index.html?org/apache/ignite/streamer/StreamerConfiguration.html" target="_top">Frames</a></li>
<li><a href="StreamerConfiguration.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="../../../../allclasses-noframe.html">All Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_top");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<div>
<ul class="subNavList">
<li>Summary:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li><a href="#field_summary">Field</a>&nbsp;|&nbsp;</li>
<li><a href="#constructor_summary">Constr</a>&nbsp;|&nbsp;</li>
<li><a href="#method_summary">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail:&nbsp;</li>
<li><a href="#field_detail">Field</a>&nbsp;|&nbsp;</li>
<li><a href="#constructor_detail">Constr</a>&nbsp;|&nbsp;</li>
<li><a href="#method_detail">Method</a></li>
</ul>
</div>
<a name="skip-navbar_top">
<!-- -->
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
<!-- ======== START OF CLASS DATA ======== -->
<div class="header">
<div class="subTitle">org.apache.ignite.streamer</div>
<h2 title="Class StreamerConfiguration" class="title">Class StreamerConfiguration</h2>
</div>
<div class="contentContainer">
<ul class="inheritance">
<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li>
<li>
<ul class="inheritance">
<li>org.apache.ignite.streamer.StreamerConfiguration</li>
</ul>
</li>
</ul>
<div class="description">
<ul class="blockList">
<li class="blockList">
<hr>
<br>
<pre>public class <span class="strong">StreamerConfiguration</span>
extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></pre>
<div class="block">Streamer configuration.</div>
</li>
</ul>
</div>
<div class="summary">
<ul class="blockList">
<li class="blockList">
<!-- =========== FIELD SUMMARY =========== -->
<ul class="blockList">
<li class="blockList"><a name="field_summary">
<!-- -->
</a>
<h3>Field Summary</h3>
<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Field Summary table, listing fields, and an explanation">
<caption><span>Fields</span><span class="tabEnd">&nbsp;</span></caption>
<tr>
<th class="colFirst" scope="col">Modifier and Type</th>
<th class="colLast" scope="col">Field and Description</th>
</tr>
<tr class="altColor">
<td class="colFirst"><code>static int</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#DFLT_MAX_CONCURRENT_SESSIONS">DFLT_MAX_CONCURRENT_SESSIONS</a></strong></code>
<div class="block">By default maximum number of concurrent sessions is unlimited.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>static int</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#DFLT_MAX_FAILOVER_ATTEMPTS">DFLT_MAX_FAILOVER_ATTEMPTS</a></strong></code>
<div class="block">Default value for maximum failover attempts.</div>
</td>
</tr>
</table>
</li>
</ul>
<!-- ======== CONSTRUCTOR SUMMARY ======== -->
<ul class="blockList">
<li class="blockList"><a name="constructor_summary">
<!-- -->
</a>
<h3>Constructor Summary</h3>
<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
<caption><span>Constructors</span><span class="tabEnd">&nbsp;</span></caption>
<tr>
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
<td class="colOne"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#StreamerConfiguration()">StreamerConfiguration</a></strong>()</code>&nbsp;</td>
</tr>
<tr class="rowColor">
<td class="colOne"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#StreamerConfiguration(org.apache.ignite.streamer.StreamerConfiguration)">StreamerConfiguration</a></strong>(<a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html" title="class in org.apache.ignite.streamer">StreamerConfiguration</a>&nbsp;c)</code>&nbsp;</td>
</tr>
</table>
</li>
</ul>
<!-- ========== METHOD SUMMARY =========== -->
<ul class="blockList">
<li class="blockList"><a name="method_summary">
<!-- -->
</a>
<h3>Method Summary</h3>
<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
<caption><span>Methods</span><span class="tabEnd">&nbsp;</span></caption>
<tr>
<th class="colFirst" scope="col">Modifier and Type</th>
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr class="altColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getMaximumConcurrentSessions()">getMaximumConcurrentSessions</a></strong>()</code>
<div class="block">Gets maximum number of concurrent events to be processed by streamer.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getMaximumFailoverAttempts()">getMaximumFailoverAttempts</a></strong>()</code>
<div class="block">Gets maximum number of failover attempts to try when pipeline execution has failed.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getName()">getName</a></strong>()</code>
<div class="block">Gets streamer name.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/ignite/streamer/StreamerEventRouter.html" title="interface in org.apache.ignite.streamer">StreamerEventRouter</a></code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getRouter()">getRouter</a></strong>()</code>
<div class="block">Gets streamer event router.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><span class='angle_bracket'>&lt;</span><a href="../../../../org/apache/ignite/streamer/StreamerStage.html" title="interface in org.apache.ignite.streamer">StreamerStage</a><span class='angle_bracket'>&gt;</span></code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getStages()">getStages</a></strong>()</code>
<div class="block">Gets collection of streamer stages.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>int</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getThreadPoolSize()">getThreadPoolSize</a></strong>()</code>
<div class="block">Gets streamer pool size.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><span class='angle_bracket'>&lt;</span><a href="../../../../org/apache/ignite/streamer/StreamerWindow.html" title="interface in org.apache.ignite.streamer">StreamerWindow</a><span class='angle_bracket'>&gt;</span></code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getWindows()">getWindows</a></strong>()</code>
<div class="block">Gets collection of streamer event windows.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#isAtLeastOnce()">isAtLeastOnce</a></strong>()</code>
<div class="block">Gets flag indicating whether streamer should track event execution sessions and failover event execution
if any failure detected or any node on which execution happened has left the grid before successful response
is received.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#setAtLeastOnce(boolean)">setAtLeastOnce</a></strong>(boolean&nbsp;atLeastOnce)</code>&nbsp;</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#setMaximumConcurrentSessions(int)">setMaximumConcurrentSessions</a></strong>(int&nbsp;maxConcurrentSessions)</code>
<div class="block">Sets maximum number of concurrent sessions.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#setMaximumFailoverAttempts(int)">setMaximumFailoverAttempts</a></strong>(int&nbsp;maxFailoverAttempts)</code>
<div class="block">Sets maximum number of failover attempts.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#setName(java.lang.String)">setName</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;name)</code>
<div class="block">Sets the name of the streamer.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#setRouter(org.apache.ignite.streamer.StreamerEventRouter)">setRouter</a></strong>(<a href="../../../../org/apache/ignite/streamer/StreamerEventRouter.html" title="interface in org.apache.ignite.streamer">StreamerEventRouter</a>&nbsp;router)</code>
<div class="block">Sets router for streamer.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#setStages(java.util.Collection)">setStages</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><span class='angle_bracket'>&lt;</span><a href="../../../../org/apache/ignite/streamer/StreamerStage.html" title="interface in org.apache.ignite.streamer">StreamerStage</a><span class='angle_bracket'>&gt;</span>&nbsp;stages)</code>
<div class="block">Sets stages.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#setThreadPoolSize(int)">setThreadPoolSize</a></strong>(int&nbsp;poolSize)</code>
<div class="block">Sets streamer pool size.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#setWindows(java.util.Collection)">setWindows</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><span class='angle_bracket'>&lt;</span><a href="../../../../org/apache/ignite/streamer/StreamerWindow.html" title="interface in org.apache.ignite.streamer">StreamerWindow</a><span class='angle_bracket'>&gt;</span>&nbsp;win)</code>
<div class="block">Sets collection of streamer windows.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#toString()">toString</a></strong>()</code></td>
</tr>
</table>
<ul class="blockList">
<li class="blockList"><a name="methods_inherited_from_class_java.lang.Object">
<!-- -->
</a>
<h3>Methods inherited from class&nbsp;java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3>
<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long, int)" title="class or interface in java.lang">wait</a></code></li>
</ul>
</li>
</ul>
</li>
</ul>
</div>
<div class="details">
<ul class="blockList">
<li class="blockList">
<!-- ============ FIELD DETAIL =========== -->
<ul class="blockList">
<li class="blockList"><a name="field_detail">
<!-- -->
</a>
<h3>Field Detail</h3>
<a name="DFLT_MAX_CONCURRENT_SESSIONS">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>DFLT_MAX_CONCURRENT_SESSIONS</h4>
<pre>public static final&nbsp;int DFLT_MAX_CONCURRENT_SESSIONS</pre>
<div class="block">By default maximum number of concurrent sessions is unlimited.</div>
<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../constant-values.html#org.apache.ignite.streamer.StreamerConfiguration.DFLT_MAX_CONCURRENT_SESSIONS">Constant Field Values</a></dd></dl>
</li>
</ul>
<a name="DFLT_MAX_FAILOVER_ATTEMPTS">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>DFLT_MAX_FAILOVER_ATTEMPTS</h4>
<pre>public static final&nbsp;int DFLT_MAX_FAILOVER_ATTEMPTS</pre>
<div class="block">Default value for maximum failover attempts.</div>
<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../constant-values.html#org.apache.ignite.streamer.StreamerConfiguration.DFLT_MAX_FAILOVER_ATTEMPTS">Constant Field Values</a></dd></dl>
</li>
</ul>
</li>
</ul>
<!-- ========= CONSTRUCTOR DETAIL ======== -->
<ul class="blockList">
<li class="blockList"><a name="constructor_detail">
<!-- -->
</a>
<h3>Constructor Detail</h3>
<a name="StreamerConfiguration()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>StreamerConfiguration</h4>
<pre>public&nbsp;StreamerConfiguration()</pre>
</li>
</ul>
<a name="StreamerConfiguration(org.apache.ignite.streamer.StreamerConfiguration)">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>StreamerConfiguration</h4>
<pre>public&nbsp;StreamerConfiguration(<a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html" title="class in org.apache.ignite.streamer">StreamerConfiguration</a>&nbsp;c)</pre>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>c</code> - Configuration to copy.</dd></dl>
</li>
</ul>
</li>
</ul>
<!-- ============ METHOD DETAIL ========== -->
<ul class="blockList">
<li class="blockList"><a name="method_detail">
<!-- -->
</a>
<h3>Method Detail</h3>
<a name="getName()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getName</h4>
<pre>@Nullable
public&nbsp;<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;getName()</pre>
<div class="block">Gets streamer name. Must be unique within grid.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>Streamer name, if <code>null</code> then default streamer is returned.</dd></dl>
</li>
</ul>
<a name="setName(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setName</h4>
<pre>public&nbsp;void&nbsp;setName(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;name)</pre>
<div class="block">Sets the name of the streamer.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>name</code> - Name.</dd></dl>
</li>
</ul>
<a name="getRouter()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getRouter</h4>
<pre>@Nullable
public&nbsp;<a href="../../../../org/apache/ignite/streamer/StreamerEventRouter.html" title="interface in org.apache.ignite.streamer">StreamerEventRouter</a>&nbsp;getRouter()</pre>
<div class="block">Gets streamer event router.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>Event router, if <code>null</code> then events will be executed locally.</dd></dl>
</li>
</ul>
<a name="setRouter(org.apache.ignite.streamer.StreamerEventRouter)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setRouter</h4>
<pre>public&nbsp;void&nbsp;setRouter(<a href="../../../../org/apache/ignite/streamer/StreamerEventRouter.html" title="interface in org.apache.ignite.streamer">StreamerEventRouter</a>&nbsp;router)</pre>
<div class="block">Sets router for streamer.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>router</code> - Router.</dd></dl>
</li>
</ul>
<a name="getWindows()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getWindows</h4>
<pre>public&nbsp;<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><span class='angle_bracket'>&lt;</span><a href="../../../../org/apache/ignite/streamer/StreamerWindow.html" title="interface in org.apache.ignite.streamer">StreamerWindow</a><span class='angle_bracket'>&gt;</span>&nbsp;getWindows()</pre>
<div class="block">Gets collection of streamer event windows. At least one window should be configured. Each window
must have unique name.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>Streamer windows.</dd></dl>
</li>
</ul>
<a name="setWindows(java.util.Collection)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setWindows</h4>
<pre>public&nbsp;void&nbsp;setWindows(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><span class='angle_bracket'>&lt;</span><a href="../../../../org/apache/ignite/streamer/StreamerWindow.html" title="interface in org.apache.ignite.streamer">StreamerWindow</a><span class='angle_bracket'>&gt;</span>&nbsp;win)</pre>
<div class="block">Sets collection of streamer windows.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>win</code> - Window.</dd></dl>
</li>
</ul>
<a name="getStages()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getStages</h4>
<pre>public&nbsp;<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><span class='angle_bracket'>&lt;</span><a href="../../../../org/apache/ignite/streamer/StreamerStage.html" title="interface in org.apache.ignite.streamer">StreamerStage</a><span class='angle_bracket'>&gt;</span>&nbsp;getStages()</pre>
<div class="block">Gets collection of streamer stages. Streamer must have at least one stage to execute. Each stage
must have unique name.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>Collection of streamer stages.</dd></dl>
</li>
</ul>
<a name="setStages(java.util.Collection)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setStages</h4>
<pre>public&nbsp;void&nbsp;setStages(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><span class='angle_bracket'>&lt;</span><a href="../../../../org/apache/ignite/streamer/StreamerStage.html" title="interface in org.apache.ignite.streamer">StreamerStage</a><span class='angle_bracket'>&gt;</span>&nbsp;stages)</pre>
<div class="block">Sets stages.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>stages</code> - Stages.</dd></dl>
</li>
</ul>
<a name="isAtLeastOnce()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>isAtLeastOnce</h4>
<pre>public&nbsp;boolean&nbsp;isAtLeastOnce()</pre>
<div class="block">Gets flag indicating whether streamer should track event execution sessions and failover event execution
if any failure detected or any node on which execution happened has left the grid before successful response
is received.
<p>
Setting this flag to <code>true</code> will guarantee that all pipeline stages will be executed at least once for
each group of event submitted to streamer (or failure listener will be notified if failover cannot succeed).
However, it does not guarantee that each stage will be executed at most once.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd><code>True</code> if event should be processed at least once,
or <code>false</code> if failures can be safely ignored.</dd></dl>
</li>
</ul>
<a name="setAtLeastOnce(boolean)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setAtLeastOnce</h4>
<pre>public&nbsp;void&nbsp;setAtLeastOnce(boolean&nbsp;atLeastOnce)</pre>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>atLeastOnce</code> - <code>True</code> to guarantee that event will be processed at least once.</dd></dl>
</li>
</ul>
<a name="getMaximumFailoverAttempts()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getMaximumFailoverAttempts</h4>
<pre>public&nbsp;int&nbsp;getMaximumFailoverAttempts()</pre>
<div class="block">Gets maximum number of failover attempts to try when pipeline execution has failed. This parameter
is ignored if <a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#isAtLeastOnce()"><code>isAtLeastOnce()</code></a> is set to <code>false</code>.
<p>
If not set, default value is</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>Maximum number of failover attempts to try.</dd></dl>
</li>
</ul>
<a name="setMaximumFailoverAttempts(int)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setMaximumFailoverAttempts</h4>
<pre>public&nbsp;void&nbsp;setMaximumFailoverAttempts(int&nbsp;maxFailoverAttempts)</pre>
<div class="block">Sets maximum number of failover attempts.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>maxFailoverAttempts</code> - Maximum number of failover attempts.</dd><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getMaximumFailoverAttempts()"><code>getMaximumFailoverAttempts()</code></a></dd></dl>
</li>
</ul>
<a name="getMaximumConcurrentSessions()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getMaximumConcurrentSessions</h4>
<pre>public&nbsp;int&nbsp;getMaximumConcurrentSessions()</pre>
<div class="block">Gets maximum number of concurrent events to be processed by streamer. This property is taken into
account when <a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#isAtLeastOnce()"><code>isAtLeastOnce()</code></a> is set to <code>true</code>. If not positive, number of sessions
will not be limited by any value.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>Maximum number of concurrent events to be processed. If number of concurrent events is greater
then this value, caller will be blocked until enough responses are received.</dd></dl>
</li>
</ul>
<a name="setMaximumConcurrentSessions(int)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setMaximumConcurrentSessions</h4>
<pre>public&nbsp;void&nbsp;setMaximumConcurrentSessions(int&nbsp;maxConcurrentSessions)</pre>
<div class="block">Sets maximum number of concurrent sessions.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>maxConcurrentSessions</code> - Maximum number of concurrent sessions.</dd><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getMaximumConcurrentSessions()"><code>getMaximumConcurrentSessions()</code></a></dd></dl>
</li>
</ul>
<a name="getThreadPoolSize()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getThreadPoolSize</h4>
<pre>public&nbsp;int&nbsp;getThreadPoolSize()</pre>
<div class="block">Gets streamer pool size. Defines a thread pool size in which streamer stages will be executed.
<p>
If not specified, thread pool executor with max pool size equal to number of cores will be created.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>Streamer thread pool size.</dd></dl>
</li>
</ul>
<a name="setThreadPoolSize(int)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setThreadPoolSize</h4>
<pre>public&nbsp;void&nbsp;setThreadPoolSize(int&nbsp;poolSize)</pre>
<div class="block">Sets streamer pool size.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>poolSize</code> - Pool size.</dd><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../org/apache/ignite/streamer/StreamerConfiguration.html#getThreadPoolSize()"><code>getThreadPoolSize()</code></a></dd></dl>
</li>
</ul>
<a name="toString()">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>toString</h4>
<pre>public&nbsp;<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;toString()</pre>
<dl>
<dt><strong>Overrides:</strong></dt>
<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString()" title="class or interface in java.lang">toString</a></code>&nbsp;in class&nbsp;<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></code></dd>
</dl>
</li>
</ul>
</li>
</ul>
</li>
</ul>
</div>
</div>
<!-- ========= END OF CLASS DATA ========= -->
<!-- ======= START OF BOTTOM NAVBAR ====== -->
<div class="bottomNav"><a name="navbar_bottom">
<!-- -->
</a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="../../../../overview-summary.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
<li><a href="class-use/StreamerConfiguration.html">Use</a></li>
<li><a href="package-tree.html">Tree</a></li>
<li><a href="../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../index-all.html">Index</a></li>
<li><a href="../../../../help-doc.html">Help</a></li>
</ul>
<div class="aboutLanguage"><em>Apache Ignite - In-Memory Data Fabric</em></div>
</div>
<div class="subNav">
<ul class="navList">
<li>Prev Class</li>
<li><a href="../../../../org/apache/ignite/streamer/StreamerContext.html" title="interface in org.apache.ignite.streamer"><span class="strong">Next Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../index.html?org/apache/ignite/streamer/StreamerConfiguration.html" target="_top">Frames</a></li>
<li><a href="StreamerConfiguration.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="../../../../allclasses-noframe.html">All Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_bottom");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<div>
<ul class="subNavList">
<li>Summary:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li><a href="#field_summary">Field</a>&nbsp;|&nbsp;</li>
<li><a href="#constructor_summary">Constr</a>&nbsp;|&nbsp;</li>
<li><a href="#method_summary">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail:&nbsp;</li>
<li><a href="#field_detail">Field</a>&nbsp;|&nbsp;</li>
<li><a href="#constructor_detail">Constr</a>&nbsp;|&nbsp;</li>
<li><a href="#method_detail">Method</a></li>
</ul>
</div>
<a name="skip-navbar_bottom">
<!-- -->
</a></div>
<!-- ======== END OF BOTTOM NAVBAR ======= -->
<p class="legalCopy"><small><table width="100%" border="0" cellspacing=0 cellpadding=0 style="padding: 5px"> <tr> <td> <table style="padding-left: 0; margin: 0"> <tbody style="padding: 0; margin: 0"> <tr style="padding: 0; margin: 0"> <td> <a target=_blank href="https://incubator.apache.org/projects/ignite.html"><nobr>2015 Copyright &#169; Apache Software Foundation</nobr></a> </td> </tr> </tbody> </table> </td> <td width="100%" align="right" valign="center"> <a href="https://twitter.com/ApacheIgnite" class="twitter-follow-button" data-show-count="false" data-size="large">Follow @ApacheIgnite</a> <script>!function(d,s,id){var js,fjs=d.getElementsByTagName(s)[0],p=/^http:/.test(d.location)?'http':'https';if(!d.getElementById(id)){js=d.createElement(s);js.id=id;js.src=p+'://platform.twitter.com/widgets.js';fjs.parentNode.insertBefore(js,fjs);}}(document, 'script', 'twitter-wjs');</script> </td> </tr> <tr> <td colspan="2" valign="top" align="left"> <table style="padding-left: 0; margin: 0"> <tbody style="padding: 0; margin: 0"> <tr style="padding: 0; margin: 0"> <td> <b>Apache Ignite Fabric</b> </td> <td>:&nbsp;&nbsp; ver. <strong>1.0.0-RC3</strong> </td> </tr> <tr style="padding: 0; margin: 0"> <td> <b>Release Date</b> </td> <td>:&nbsp;&nbsp; March 24 2015 </td> </tr> </tbody> </table> </td> </tr> </table></small></p>
<!--FOOTER--><script type='text/javascript'>SyntaxHighlighter.all();dp.SyntaxHighlighter.HighlightAll('code');</script>
</body>
</html>