content/releases/current/javadocs/org/apache/storm/trident/Stream.html - storm-site - Git at Google

 <!DOCTYPE HTML>
 <html lang="de">
 <head>
 <!-- Generated by javadoc (17) -->
 <title>Stream (Storm 2.6.2 API)</title>
 <meta name="viewport" content="width=device-width, initial-scale=1">
 <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
 <meta name="description" content="declaration: package: org.apache.storm.trident, class: Stream">
 <meta name="generator" content="javadoc/ClassWriterImpl">
 <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
 <link rel="stylesheet" type="text/css" href="../../../../script-dir/jquery-ui.min.css" title="Style">
 <link rel="stylesheet" type="text/css" href="../../../../jquery-ui.overrides.css" title="Style">
 <script type="text/javascript" src="../../../../script.js"></script>
 <script type="text/javascript" src="../../../../script-dir/jquery-3.6.1.min.js"></script>
 <script type="text/javascript" src="../../../../script-dir/jquery-ui.min.js"></script>
 </head>
 <body class="class-declaration-page">
 <script type="text/javascript">var evenRowColor = "even-row-color";
 var oddRowColor = "odd-row-color";
 var tableTab = "table-tab";
 var activeTableTab = "active-table-tab";
 var pathtoroot = "../../../../";
 loadScripts(document, 'script');</script>
 <noscript>
 <div>JavaScript is disabled on your browser.</div>
 </noscript>
 <div class="flex-box">
 <header role="banner" class="flex-header">
 <nav role="navigation">
 <!-- ========= START OF TOP NAVBAR ======= -->
 <div class="top-nav" id="navbar-top">
 <div class="skip-nav"><a href="#skip-navbar-top" title="Skip navigation links">Skip navigation links</a></div>
 <ul id="navbar-top-firstrow" class="nav-list" title="Navigation">
 <li><a href="../../../../index.html">Overview</a></li>
 <li><a href="package-summary.html">Package</a></li>
 <li class="nav-bar-cell1-rev">Class</li>
 <li><a href="class-use/Stream.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#class">Help</a></li>
 </ul>
 </div>
 <div class="sub-nav">
 <div>
 <ul class="sub-nav-list">
 <li>Summary:&nbsp;</li>
 <li>Nested&nbsp;|&nbsp;</li>
 <li>Field&nbsp;|&nbsp;</li>
 <li><a href="#constructor-summary">Constr</a>&nbsp;|&nbsp;</li>
 <li><a href="#method-summary">Method</a></li>
 </ul>
 <ul class="sub-nav-list">
 <li>Detail:&nbsp;</li>
 <li>Field&nbsp;|&nbsp;</li>
 <li><a href="#constructor-detail">Constr</a>&nbsp;|&nbsp;</li>
 <li><a href="#method-detail">Method</a></li>
 </ul>
 </div>
 <div class="nav-list-search"><label for="search-input">SEARCH:</label>
 <input type="text" id="search-input" value="search" disabled="disabled">
 <input type="reset" id="reset-button" value="reset" disabled="disabled">
 </div>
 </div>
 <!-- ========= END OF TOP NAVBAR ========= -->
 <span class="skip-nav" id="skip-navbar-top"></span></nav>
 </header>
 <div class="flex-content">
 <main role="main">
 <!-- ======== START OF CLASS DATA ======== -->
 <div class="header">
 <div class="sub-title"><span class="package-label-in-type">Package</span>&nbsp;<a href="package-summary.html">org.apache.storm.trident</a></div>
 <h1 title="Class Stream" class="title">Class Stream</h1>
 </div>
 <div class="inheritance" title="Inheritance Tree"><a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html" title="class or interface in java.lang" class="external-link">java.lang.Object</a>
 <div class="inheritance">org.apache.storm.trident.Stream</div>
 </div>
 <section class="class-description" id="class-description">
 <dl class="notes">
 <dt>All Implemented Interfaces:</dt>
 <dd><code><a href="../topology/ResourceDeclarer.html" title="interface in org.apache.storm.topology">ResourceDeclarer</a>&lt;<a href="Stream.html" title="class in org.apache.storm.trident">Stream</a>&gt;</code>, <code><a href="fluent/IAggregatableStream.html" title="interface in org.apache.storm.trident.fluent">IAggregatableStream</a></code></dd>
 </dl>
 <hr>
 <div class="type-signature"><span class="modifiers">public class </span><span class="element-name type-name-label">Stream</span>
 <span class="extends-implements">extends <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html" title="class or interface in java.lang" class="external-link">Object</a>
 implements <a href="fluent/IAggregatableStream.html" title="interface in org.apache.storm.trident.fluent">IAggregatableStream</a>, <a href="../topology/ResourceDeclarer.html" title="interface in org.apache.storm.topology">ResourceDeclarer</a>&lt;<a href="Stream.html" title="class in org.apache.storm.trident">Stream</a>&gt;</span></div>
 <div class="block">A Stream represents the core data model in Trident, and can be thought of as a "stream" of tuples that are processed as a series of small
  batches. A stream is partitioned accross the nodes in the cluster, and operations are applied to a stream in parallel accross each
  partition.

  <p>There are five types of operations that can be performed on streams in Trident

  <p>1. **Partiton-Local Operations** - Operations that are applied locally to each partition and do not involve network transfer 2.
  **Repartitioning Operations** - Operations that change how tuples are partitioned across tasks(thus causing network transfer), but do not
  change the content of the stream. 3. **Aggregation Operations** - Operations that *may* repartition a stream (thus causing network
  transfer) 4. **Grouping Operations** - Operations that may repartition a stream on specific fields and group together tuples whose fields
  values are equal. 5. **Merge and Join Operations** - Operations that combine different streams together.</div>
 </section>
 <section class="summary">
 <ul class="summary-list">
 <!-- ======== CONSTRUCTOR SUMMARY ======== -->
 <li>
 <section class="constructor-summary" id="constructor-summary">
 <h2>Constructor Summary</h2>
 <div class="caption"><span>Constructors</span></div>
 <div class="summary-table three-column-summary">
 <div class="table-header col-first">Modifier</div>
 <div class="table-header col-second">Constructor</div>
 <div class="table-header col-last">Description</div>
 <div class="col-first even-row-color"><code>protected </code></div>
 <div class="col-constructor-name even-row-color"><code><a href="#%3Cinit%3E(org.apache.storm.trident.TridentTopology,java.lang.String,org.apache.storm.trident.planner.Node)" class="member-name-link">Stream</a><wbr>(<a href="TridentTopology.html" title="class in org.apache.storm.trident">TridentTopology</a>&nbsp;topology,
  <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;name,
  <a href="planner/Node.html" title="class in org.apache.storm.trident.planner">Node</a>&nbsp;node)</code></div>
 <div class="col-last even-row-color">&nbsp;</div>
 </div>
 </section>
 </li>
 <!-- ========== METHOD SUMMARY =========== -->
 <li>
 <section class="method-summary" id="method-summary">
 <h2>Method Summary</h2>
 <div id="method-summary-table">
 <div class="table-tabs" role="tablist" aria-orientation="horizontal"><button id="method-summary-table-tab0" role="tab" aria-selected="true" aria-controls="method-summary-table.tabpanel" tabindex="0" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table', 3)" class="active-table-tab">All Methods</button><button id="method-summary-table-tab2" role="tab" aria-selected="false" aria-controls="method-summary-table.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table-tab2', 3)" class="table-tab">Instance Methods</button><button id="method-summary-table-tab4" role="tab" aria-selected="false" aria-controls="method-summary-table.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table-tab4', 3)" class="table-tab">Concrete Methods</button></div>
 <div id="method-summary-table.tabpanel" role="tabpanel">
 <div class="summary-table three-column-summary" aria-labelledby="method-summary-table-tab0">
 <div class="table-header col-first">Modifier and Type</div>
 <div class="table-header col-second">Method</div>
 <div class="table-header col-last">Description</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#addSharedMemory(org.apache.storm.generated.SharedMemory)" class="member-name-link">addSharedMemory</a><wbr>(<a href="../generated/SharedMemory.html" title="class in org.apache.storm.generated">SharedMemory</a>&nbsp;request)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Add in request for shared memory that this component will use.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#aggregate(org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">aggregate</a><wbr>(<a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#aggregate(org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">aggregate</a><wbr>(<a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#aggregate(org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">aggregate</a><wbr>(<a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#aggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">aggregate</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#aggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">aggregate</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#aggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">aggregate</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#applyAssembly(org.apache.storm.trident.operation.Assembly)" class="member-name-link">applyAssembly</a><wbr>(<a href="operation/Assembly.html" title="interface in org.apache.storm.trident.operation">Assembly</a>&nbsp;assembly)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Applies an `Assembly` to this `Stream`.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#batchGlobal()" class="member-name-link">batchGlobal</a>()</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#broadcast()" class="member-name-link">broadcast</a>()</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="fluent/ChainedAggregatorDeclarer.html" title="class in org.apache.storm.trident.fluent">ChainedAggregatorDeclarer</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#chainedAgg()" class="member-name-link">chainedAgg</a>()</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#each(org.apache.storm.trident.operation.Function,org.apache.storm.tuple.Fields)" class="member-name-link">each</a><wbr>(<a href="operation/Function.html" title="interface in org.apache.storm.trident.operation">Function</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#each(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Filter)" class="member-name-link">each</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Filter.html" title="interface in org.apache.storm.trident.operation">Filter</a>&nbsp;filter)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#each(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Function,org.apache.storm.tuple.Fields)" class="member-name-link">each</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Function.html" title="interface in org.apache.storm.trident.operation">Function</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#filter(org.apache.storm.trident.operation.Filter)" class="member-name-link">filter</a><wbr>(<a href="operation/Filter.html" title="interface in org.apache.storm.trident.operation">Filter</a>&nbsp;filter)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream consisting of the elements of this stream that match the given filter.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#filter(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Filter)" class="member-name-link">filter</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Filter.html" title="interface in org.apache.storm.trident.operation">Filter</a>&nbsp;filter)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream consisting of the elements of this stream that match the given filter.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#flatMap(org.apache.storm.trident.operation.FlatMapFunction)" class="member-name-link">flatMap</a><wbr>(<a href="operation/FlatMapFunction.html" title="interface in org.apache.storm.trident.operation">FlatMapFunction</a>&nbsp;function)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided
  mapping function to each value.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#flatMap(org.apache.storm.trident.operation.FlatMapFunction,org.apache.storm.tuple.Fields)" class="member-name-link">flatMap</a><wbr>(<a href="operation/FlatMapFunction.html" title="interface in org.apache.storm.trident.operation">FlatMapFunction</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;outputFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided
  mapping function to each value.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getName()" class="member-name-link">getName</a>()</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns the label applied to the stream.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getOutputFields()" class="member-name-link">getOutputFields</a>()</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#global()" class="member-name-link">global</a>()</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="fluent/GroupedStream.html" title="class in org.apache.storm.trident.fluent">GroupedStream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#groupBy(org.apache.storm.tuple.Fields)" class="member-name-link">groupBy</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;fields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Grouping Operation.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#identityPartition()" class="member-name-link">identityPartition</a>()</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#localOrShuffle()" class="member-name-link">localOrShuffle</a>()</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#map(org.apache.storm.trident.operation.MapFunction)" class="member-name-link">map</a><wbr>(<a href="operation/MapFunction.html" title="interface in org.apache.storm.trident.operation">MapFunction</a>&nbsp;function)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream consisting of the result of applying the given mapping function to the values of this stream.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#map(org.apache.storm.trident.operation.MapFunction,org.apache.storm.tuple.Fields)" class="member-name-link">map</a><wbr>(<a href="operation/MapFunction.html" title="interface in org.apache.storm.trident.operation">MapFunction</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;outputFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream consisting of the result of applying the given mapping function to the values of this stream.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#max(java.util.Comparator)" class="member-name-link">max</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Comparator.html" title="class or interface in java.util" class="external-link">Comparator</a>&lt;<a href="tuple/TridentTuple.html" title="interface in org.apache.storm.trident.tuple">TridentTuple</a>&gt;&nbsp;comparator)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">This aggregator operation computes the maximum of tuples in a stream by using the given <code>comparator</code> with <code>
  TridentTuple</code>s.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#maxBy(java.lang.String)" class="member-name-link">maxBy</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;inputFieldName)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">This aggregator operation computes the maximum of tuples by the given <code>inputFieldName</code> and it is assumed that its value is an
  instance of <code>Comparable</code>.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>&lt;T&gt;&nbsp;<a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#maxBy(java.lang.String,java.util.Comparator)" class="member-name-link">maxBy</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;inputFieldName,
  <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Comparator.html" title="class or interface in java.util" class="external-link">Comparator</a>&lt;T&gt;&nbsp;comparator)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">This aggregator operation computes the maximum of tuples by the given <code>inputFieldName</code> in a stream by using the given <code>
  comparator</code>.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#min(java.util.Comparator)" class="member-name-link">min</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Comparator.html" title="class or interface in java.util" class="external-link">Comparator</a>&lt;<a href="tuple/TridentTuple.html" title="interface in org.apache.storm.trident.tuple">TridentTuple</a>&gt;&nbsp;comparator)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">This aggregator operation computes the minimum of tuples in a stream by using the given <code>comparator</code> with <code>
  TridentTuple</code>s.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#minBy(java.lang.String)" class="member-name-link">minBy</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;inputFieldName)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">This aggregator operation computes the minimum of tuples by the given <code>inputFieldName</code> and it is assumed that its value is an
  instance of <code>Comparable</code>.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>&lt;T&gt;&nbsp;<a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#minBy(java.lang.String,java.util.Comparator)" class="member-name-link">minBy</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;inputFieldName,
  <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Comparator.html" title="class or interface in java.util" class="external-link">Comparator</a>&lt;T&gt;&nbsp;comparator)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">This aggregator operation computes the minimum of tuples by the given <code>inputFieldName</code> in a stream by using the given <code>
  comparator</code>.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#name(java.lang.String)" class="member-name-link">name</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;name)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Applies a label to the stream.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#parallelismHint(int)" class="member-name-link">parallelismHint</a><wbr>(int&nbsp;hint)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Applies a parallelism hint to a stream.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partition(org.apache.storm.generated.Grouping)" class="member-name-link">partition</a><wbr>(<a href="../generated/Grouping.html" title="class in org.apache.storm.generated">Grouping</a>&nbsp;grouping)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partition(org.apache.storm.grouping.CustomStreamGrouping)" class="member-name-link">partition</a><wbr>(<a href="../grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a>&nbsp;partitioner)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionAggregate(org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">partitionAggregate</a><wbr>(<a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionAggregate(org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">partitionAggregate</a><wbr>(<a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionAggregate(org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">partitionAggregate</a><wbr>(<a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionAggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">partitionAggregate</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionAggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">partitionAggregate</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionAggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">partitionAggregate</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionBy(org.apache.storm.tuple.Fields)" class="member-name-link">partitionBy</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;fields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionPersist(org.apache.storm.trident.state.StateFactory,org.apache.storm.trident.state.StateUpdater)" class="member-name-link">partitionPersist</a><wbr>(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionPersist(org.apache.storm.trident.state.StateFactory,org.apache.storm.trident.state.StateUpdater,org.apache.storm.tuple.Fields)" class="member-name-link">partitionPersist</a><wbr>(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionPersist(org.apache.storm.trident.state.StateFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.StateUpdater)" class="member-name-link">partitionPersist</a><wbr>(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionPersist(org.apache.storm.trident.state.StateFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.StateUpdater,org.apache.storm.tuple.Fields)" class="member-name-link">partitionPersist</a><wbr>(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionPersist(org.apache.storm.trident.state.StateSpec,org.apache.storm.trident.state.StateUpdater)" class="member-name-link">partitionPersist</a><wbr>(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;stateSpec,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionPersist(org.apache.storm.trident.state.StateSpec,org.apache.storm.trident.state.StateUpdater,org.apache.storm.tuple.Fields)" class="member-name-link">partitionPersist</a><wbr>(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;stateSpec,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionPersist(org.apache.storm.trident.state.StateSpec,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.StateUpdater)" class="member-name-link">partitionPersist</a><wbr>(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;stateSpec,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#partitionPersist(org.apache.storm.trident.state.StateSpec,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.StateUpdater,org.apache.storm.tuple.Fields)" class="member-name-link">partitionPersist</a><wbr>(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;stateSpec,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#peek(org.apache.storm.trident.operation.Consumer)" class="member-name-link">peek</a><wbr>(<a href="operation/Consumer.html" title="interface in org.apache.storm.trident.operation">Consumer</a>&nbsp;action)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream consisting of the trident tuples of this stream, additionally performing the provided action on each trident tuple
  as they are consumed from the resulting stream.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#persistentAggregate(org.apache.storm.trident.state.StateFactory,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">persistentAggregate</a><wbr>(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#persistentAggregate(org.apache.storm.trident.state.StateFactory,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">persistentAggregate</a><wbr>(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#persistentAggregate(org.apache.storm.trident.state.StateFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">persistentAggregate</a><wbr>(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#persistentAggregate(org.apache.storm.trident.state.StateFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">persistentAggregate</a><wbr>(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#persistentAggregate(org.apache.storm.trident.state.StateSpec,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">persistentAggregate</a><wbr>(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;spec,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#persistentAggregate(org.apache.storm.trident.state.StateSpec,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">persistentAggregate</a><wbr>(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;spec,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#persistentAggregate(org.apache.storm.trident.state.StateSpec,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">persistentAggregate</a><wbr>(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;spec,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#persistentAggregate(org.apache.storm.trident.state.StateSpec,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)" class="member-name-link">persistentAggregate</a><wbr>(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;spec,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#project(org.apache.storm.tuple.Fields)" class="member-name-link">project</a><wbr>(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;keepFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Filters out fields from a stream, resulting in a Stream containing only the fields specified by `keepFields`.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#setCPULoad(java.lang.Number)" class="member-name-link">setCPULoad</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Number.html" title="class or interface in java.lang" class="external-link">Number</a>&nbsp;load)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Sets the CPU Load resource for the current operation.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#setMemoryLoad(java.lang.Number)" class="member-name-link">setMemoryLoad</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Number.html" title="class or interface in java.lang" class="external-link">Number</a>&nbsp;onHeap)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Sets the Memory Load resources for the current operation. offHeap becomes default.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#setMemoryLoad(java.lang.Number,java.lang.Number)" class="member-name-link">setMemoryLoad</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Number.html" title="class or interface in java.lang" class="external-link">Number</a>&nbsp;onHeap,
  <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Number.html" title="class or interface in java.lang" class="external-link">Number</a>&nbsp;offHeap)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Sets the Memory Load resources for the current operation.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#shuffle()" class="member-name-link">shuffle</a>()</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">## Repartitioning Operation.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#slidingWindow(int,int,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">slidingWindow</a><wbr>(int&nbsp;windowCount,
  int&nbsp;slideCount,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream of tuples which are aggregated results of a sliding window with every <code>windowCount</code> of tuples and slides the
  window after <code>slideCount</code>.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#slidingWindow(org.apache.storm.topology.base.BaseWindowedBolt.Duration,org.apache.storm.topology.base.BaseWindowedBolt.Duration,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">slidingWindow</a><wbr>(<a href="../topology/base/BaseWindowedBolt.Duration.html" title="class in org.apache.storm.topology.base">BaseWindowedBolt.Duration</a>&nbsp;windowDuration,
  <a href="../topology/base/BaseWindowedBolt.Duration.html" title="class in org.apache.storm.topology.base">BaseWindowedBolt.Duration</a>&nbsp;slidingInterval,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream of tuples which are aggregated results of a window which slides at duration of <code>slidingInterval</code> and completes
  a window at <code>windowDuration</code>.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#stateQuery(org.apache.storm.trident.TridentState,org.apache.storm.trident.state.QueryFunction,org.apache.storm.tuple.Fields)" class="member-name-link">stateQuery</a><wbr>(<a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a>&nbsp;state,
  <a href="state/QueryFunction.html" title="interface in org.apache.storm.trident.state">QueryFunction</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#stateQuery(org.apache.storm.trident.TridentState,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.QueryFunction,org.apache.storm.tuple.Fields)" class="member-name-link">stateQuery</a><wbr>(<a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a>&nbsp;state,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/QueryFunction.html" title="interface in org.apache.storm.trident.state">QueryFunction</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#toStream()" class="member-name-link">toStream</a>()</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">&nbsp;</div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#tumblingWindow(int,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">tumblingWindow</a><wbr>(int&nbsp;windowCount,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream of tuples which are aggregated results of a tumbling window with every <code>windowCount</code> of tuples.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#tumblingWindow(org.apache.storm.topology.base.BaseWindowedBolt.Duration,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">tumblingWindow</a><wbr>(<a href="../topology/base/BaseWindowedBolt.Duration.html" title="class in org.apache.storm.topology.base">BaseWindowedBolt.Duration</a>&nbsp;windowDuration,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream of tuples which are aggregated results of a window that tumbles at duration of <code>windowDuration</code>.</div>
 </div>
 <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#window(org.apache.storm.trident.windowing.config.WindowConfig,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">window</a><wbr>(<a href="windowing/config/WindowConfig.html" title="interface in org.apache.storm.trident.windowing.config">WindowConfig</a>&nbsp;windowConfig,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns stream of aggregated results based on the given window configuration.</div>
 </div>
 <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></code></div>
 <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#window(org.apache.storm.trident.windowing.config.WindowConfig,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)" class="member-name-link">window</a><wbr>(<a href="windowing/config/WindowConfig.html" title="interface in org.apache.storm.trident.windowing.config">WindowConfig</a>&nbsp;windowConfig,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</code></div>
 <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4">
 <div class="block">Returns a stream of aggregated results based on the given window configuration which uses inmemory windowing tuple store.</div>
 </div>
 </div>
 </div>
 </div>
 <div class="inherited-list">
 <h3 id="methods-inherited-from-class-java.lang.Object">Methods inherited from class&nbsp;java.lang.<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html" title="class or interface in java.lang" class="external-link">Object</a></h3>
 <code><a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#clone()" title="class or interface in java.lang" class="external-link">clone</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#equals(java.lang.Object)" title="class or interface in java.lang" class="external-link">equals</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#finalize()" title="class or interface in java.lang" class="external-link">finalize</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#getClass()" title="class or interface in java.lang" class="external-link">getClass</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#hashCode()" title="class or interface in java.lang" class="external-link">hashCode</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#notify()" title="class or interface in java.lang" class="external-link">notify</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#notifyAll()" title="class or interface in java.lang" class="external-link">notifyAll</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#toString()" title="class or interface in java.lang" class="external-link">toString</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#wait()" title="class or interface in java.lang" class="external-link">wait</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#wait(long)" title="class or interface in java.lang" class="external-link">wait</a>, <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Object.html#wait(long,int)" title="class or interface in java.lang" class="external-link">wait</a></code></div>
 </section>
 </li>
 </ul>
 </section>
 <section class="details">
 <ul class="details-list">
 <!-- ========= CONSTRUCTOR DETAIL ======== -->
 <li>
 <section class="constructor-details" id="constructor-detail">
 <h2>Constructor Details</h2>
 <ul class="member-list">
 <li>
 <section class="detail" id="&lt;init&gt;(org.apache.storm.trident.TridentTopology,java.lang.String,org.apache.storm.trident.planner.Node)">
 <h3>Stream</h3>
 <div class="member-signature"><span class="modifiers">protected</span>&nbsp;<span class="element-name">Stream</span><wbr><span class="parameters">(<a href="TridentTopology.html" title="class in org.apache.storm.trident">TridentTopology</a>&nbsp;topology,
  <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;name,
  <a href="planner/Node.html" title="class in org.apache.storm.trident.planner">Node</a>&nbsp;node)</span></div>
 </section>
 </li>
 </ul>
 </section>
 </li>
 <!-- ============ METHOD DETAIL ========== -->
 <li>
 <section class="method-details" id="method-detail">
 <h2>Method Details</h2>
 <ul class="member-list">
 <li>
 <section class="detail" id="name(java.lang.String)">
 <h3>name</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">name</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;name)</span></div>
 <div class="block">Applies a label to the stream. Naming a stream will append the label to the name of the bolt(s) created by Trident and will be
  visible in the Storm UI.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>name</code> - - The label to apply to the stream</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="parallelismHint(int)">
 <h3>parallelismHint</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">parallelismHint</span><wbr><span class="parameters">(int&nbsp;hint)</span></div>
 <div class="block">Applies a parallelism hint to a stream.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="setCPULoad(java.lang.Number)">
 <h3>setCPULoad</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">setCPULoad</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Number.html" title="class or interface in java.lang" class="external-link">Number</a>&nbsp;load)</span></div>
 <div class="block">Sets the CPU Load resource for the current operation.</div>
 <dl class="notes">
 <dt>Specified by:</dt>
 <dd><code><a href="../topology/ResourceDeclarer.html#setCPULoad(java.lang.Number)">setCPULoad</a></code>&nbsp;in interface&nbsp;<code><a href="../topology/ResourceDeclarer.html" title="interface in org.apache.storm.topology">ResourceDeclarer</a>&lt;<a href="Stream.html" title="class in org.apache.storm.trident">Stream</a>&gt;</code></dd>
 <dt>Parameters:</dt>
 <dd><code>load</code> - the amount of CPU</dd>
 <dt>Returns:</dt>
 <dd>this for chaining</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="setMemoryLoad(java.lang.Number)">
 <h3>setMemoryLoad</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">setMemoryLoad</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Number.html" title="class or interface in java.lang" class="external-link">Number</a>&nbsp;onHeap)</span></div>
 <div class="block">Sets the Memory Load resources for the current operation. offHeap becomes default.</div>
 <dl class="notes">
 <dt>Specified by:</dt>
 <dd><code><a href="../topology/ResourceDeclarer.html#setMemoryLoad(java.lang.Number)">setMemoryLoad</a></code>&nbsp;in interface&nbsp;<code><a href="../topology/ResourceDeclarer.html" title="interface in org.apache.storm.topology">ResourceDeclarer</a>&lt;<a href="Stream.html" title="class in org.apache.storm.trident">Stream</a>&gt;</code></dd>
 <dt>Parameters:</dt>
 <dd><code>onHeap</code> - the amount of on heap memory</dd>
 <dt>Returns:</dt>
 <dd>this for chaining</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="setMemoryLoad(java.lang.Number,java.lang.Number)">
 <h3>setMemoryLoad</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">setMemoryLoad</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Number.html" title="class or interface in java.lang" class="external-link">Number</a>&nbsp;onHeap,
  <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/Number.html" title="class or interface in java.lang" class="external-link">Number</a>&nbsp;offHeap)</span></div>
 <div class="block">Sets the Memory Load resources for the current operation.</div>
 <dl class="notes">
 <dt>Specified by:</dt>
 <dd><code><a href="../topology/ResourceDeclarer.html#setMemoryLoad(java.lang.Number,java.lang.Number)">setMemoryLoad</a></code>&nbsp;in interface&nbsp;<code><a href="../topology/ResourceDeclarer.html" title="interface in org.apache.storm.topology">ResourceDeclarer</a>&lt;<a href="Stream.html" title="class in org.apache.storm.trident">Stream</a>&gt;</code></dd>
 <dt>Parameters:</dt>
 <dd><code>onHeap</code> - the amount of on heap memory</dd>
 <dd><code>offHeap</code> - the amount of off heap memory</dd>
 <dt>Returns:</dt>
 <dd>this for chaining</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="addSharedMemory(org.apache.storm.generated.SharedMemory)">
 <h3>addSharedMemory</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">addSharedMemory</span><wbr><span class="parameters">(<a href="../generated/SharedMemory.html" title="class in org.apache.storm.generated">SharedMemory</a>&nbsp;request)</span></div>
 <div class="block"><span class="descfrm-type-label">Description copied from interface:&nbsp;<code><a href="../topology/ResourceDeclarer.html#addSharedMemory(org.apache.storm.generated.SharedMemory)">ResourceDeclarer</a></code></span></div>
 <div class="block">Add in request for shared memory that this component will use. See <a href="../topology/SharedOnHeap.html" title="class in org.apache.storm.topology"><code>SharedOnHeap</code></a>, <a href="../topology/SharedOffHeapWithinNode.html" title="class in org.apache.storm.topology"><code>SharedOffHeapWithinNode</code></a>, and <a href="../topology/SharedOffHeapWithinWorker.html" title="class in org.apache.storm.topology"><code>SharedOffHeapWithinWorker</code></a> for convenient ways to create shared memory requests.</div>
 <dl class="notes">
 <dt>Specified by:</dt>
 <dd><code><a href="../topology/ResourceDeclarer.html#addSharedMemory(org.apache.storm.generated.SharedMemory)">addSharedMemory</a></code>&nbsp;in interface&nbsp;<code><a href="../topology/ResourceDeclarer.html" title="interface in org.apache.storm.topology">ResourceDeclarer</a>&lt;<a href="Stream.html" title="class in org.apache.storm.trident">Stream</a>&gt;</code></dd>
 <dt>Parameters:</dt>
 <dd><code>request</code> - the shared memory request for this component</dd>
 <dt>Returns:</dt>
 <dd>this for chaining</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="project(org.apache.storm.tuple.Fields)">
 <h3>project</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">project</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;keepFields)</span></div>
 <div class="block">Filters out fields from a stream, resulting in a Stream containing only the fields specified by `keepFields`.

  <p>For example, if you had a Stream `mystream` containing the fields `["a", "b", "c","d"]`, calling"

  <p>```java mystream.project(new Fields("b", "d")) ```

  <p>would produce a stream containing only the fields `["b", "d"]`.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>keepFields</code> - The fields in the Stream to keep</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="groupBy(org.apache.storm.tuple.Fields)">
 <h3>groupBy</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="fluent/GroupedStream.html" title="class in org.apache.storm.trident.fluent">GroupedStream</a></span>&nbsp;<span class="element-name">groupBy</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;fields)</span></div>
 <div class="block">## Grouping Operation.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionBy(org.apache.storm.tuple.Fields)">
 <h3>partitionBy</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partitionBy</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;fields)</span></div>
 <div class="block">## Repartitioning Operation.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="partition(org.apache.storm.grouping.CustomStreamGrouping)">
 <h3>partition</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partition</span><wbr><span class="parameters">(<a href="../grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a>&nbsp;partitioner)</span></div>
 <div class="block">## Repartitioning Operation.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="partition(org.apache.storm.generated.Grouping)">
 <h3>partition</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partition</span><wbr><span class="parameters">(<a href="../generated/Grouping.html" title="class in org.apache.storm.generated">Grouping</a>&nbsp;grouping)</span></div>
 <div class="block">## Repartitioning Operation.

  <p>This method takes in a custom partitioning function that implements <a href="../grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping"><code>CustomStreamGrouping</code></a></div>
 </section>
 </li>
 <li>
 <section class="detail" id="shuffle()">
 <h3>shuffle</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">shuffle</span>()</div>
 <div class="block">## Repartitioning Operation.

  <p>Use random round robin algorithm to evenly redistribute tuples across all target partitions.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="localOrShuffle()">
 <h3>localOrShuffle</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">localOrShuffle</span>()</div>
 <div class="block">## Repartitioning Operation.

  <p>Use random round robin algorithm to evenly redistribute tuples across all target partitions, with a preference for local tasks.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="global()">
 <h3>global</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">global</span>()</div>
 <div class="block">## Repartitioning Operation.

  <p>All tuples are sent to the same partition. The same partition is chosen for all batches in the stream.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="batchGlobal()">
 <h3>batchGlobal</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">batchGlobal</span>()</div>
 <div class="block">## Repartitioning Operation.

  <p>All tuples in the batch are sent to the same partition. Different batches in the stream may go to different partitions.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="broadcast()">
 <h3>broadcast</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">broadcast</span>()</div>
 <div class="block">## Repartitioning Operation.

  <p>Every tuple is replicated to all target partitions. This can useful during DRPC – for example, if you need to do a stateQuery on
  every partition of data.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="identityPartition()">
 <h3>identityPartition</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">identityPartition</span>()</div>
 <div class="block">## Repartitioning Operation.</div>
 </section>
 </li>
 <li>
 <section class="detail" id="applyAssembly(org.apache.storm.trident.operation.Assembly)">
 <h3>applyAssembly</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">applyAssembly</span><wbr><span class="parameters">(<a href="operation/Assembly.html" title="interface in org.apache.storm.trident.operation">Assembly</a>&nbsp;assembly)</span></div>
 <div class="block">Applies an `Assembly` to this `Stream`.</div>
 <dl class="notes">
 <dt>See Also:</dt>
 <dd>
 <ul class="see-list">
 <li><a href="operation/Assembly.html" title="interface in org.apache.storm.trident.operation"><code>Assembly</code></a></li>
 </ul>
 </dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="each(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Function,org.apache.storm.tuple.Fields)">
 <h3>each</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">each</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Function.html" title="interface in org.apache.storm.trident.operation">Function</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 <dl class="notes">
 <dt>Specified by:</dt>
 <dd><code><a href="fluent/IAggregatableStream.html#each(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Function,org.apache.storm.tuple.Fields)">each</a></code>&nbsp;in interface&nbsp;<code><a href="fluent/IAggregatableStream.html" title="interface in org.apache.storm.trident.fluent">IAggregatableStream</a></code></dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="each(org.apache.storm.trident.operation.Function,org.apache.storm.tuple.Fields)">
 <h3>each</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">each</span><wbr><span class="parameters">(<a href="operation/Function.html" title="interface in org.apache.storm.trident.operation">Function</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="each(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Filter)">
 <h3>each</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">each</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Filter.html" title="interface in org.apache.storm.trident.operation">Filter</a>&nbsp;filter)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionAggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>partitionAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partitionAggregate</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 <dl class="notes">
 <dt>Specified by:</dt>
 <dd><code><a href="fluent/IAggregatableStream.html#partitionAggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">partitionAggregate</a></code>&nbsp;in interface&nbsp;<code><a href="fluent/IAggregatableStream.html" title="interface in org.apache.storm.trident.fluent">IAggregatableStream</a></code></dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionAggregate(org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>partitionAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partitionAggregate</span><wbr><span class="parameters">(<a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionAggregate(org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)">
 <h3>partitionAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partitionAggregate</span><wbr><span class="parameters">(<a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionAggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)">
 <h3>partitionAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partitionAggregate</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionAggregate(org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)">
 <h3>partitionAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partitionAggregate</span><wbr><span class="parameters">(<a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionAggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)">
 <h3>partitionAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">partitionAggregate</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="stateQuery(org.apache.storm.trident.TridentState,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.QueryFunction,org.apache.storm.tuple.Fields)">
 <h3>stateQuery</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">stateQuery</span><wbr><span class="parameters">(<a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a>&nbsp;state,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/QueryFunction.html" title="interface in org.apache.storm.trident.state">QueryFunction</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="stateQuery(org.apache.storm.trident.TridentState,org.apache.storm.trident.state.QueryFunction,org.apache.storm.tuple.Fields)">
 <h3>stateQuery</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">stateQuery</span><wbr><span class="parameters">(<a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a>&nbsp;state,
  <a href="state/QueryFunction.html" title="interface in org.apache.storm.trident.state">QueryFunction</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionPersist(org.apache.storm.trident.state.StateFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.StateUpdater,org.apache.storm.tuple.Fields)">
 <h3>partitionPersist</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">partitionPersist</span><wbr><span class="parameters">(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionPersist(org.apache.storm.trident.state.StateSpec,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.StateUpdater,org.apache.storm.tuple.Fields)">
 <h3>partitionPersist</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">partitionPersist</span><wbr><span class="parameters">(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;stateSpec,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionPersist(org.apache.storm.trident.state.StateFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.StateUpdater)">
 <h3>partitionPersist</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">partitionPersist</span><wbr><span class="parameters">(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionPersist(org.apache.storm.trident.state.StateSpec,org.apache.storm.tuple.Fields,org.apache.storm.trident.state.StateUpdater)">
 <h3>partitionPersist</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">partitionPersist</span><wbr><span class="parameters">(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;stateSpec,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionPersist(org.apache.storm.trident.state.StateFactory,org.apache.storm.trident.state.StateUpdater,org.apache.storm.tuple.Fields)">
 <h3>partitionPersist</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">partitionPersist</span><wbr><span class="parameters">(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionPersist(org.apache.storm.trident.state.StateSpec,org.apache.storm.trident.state.StateUpdater,org.apache.storm.tuple.Fields)">
 <h3>partitionPersist</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">partitionPersist</span><wbr><span class="parameters">(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;stateSpec,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionPersist(org.apache.storm.trident.state.StateFactory,org.apache.storm.trident.state.StateUpdater)">
 <h3>partitionPersist</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">partitionPersist</span><wbr><span class="parameters">(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="partitionPersist(org.apache.storm.trident.state.StateSpec,org.apache.storm.trident.state.StateUpdater)">
 <h3>partitionPersist</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">partitionPersist</span><wbr><span class="parameters">(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;stateSpec,
  <a href="state/StateUpdater.html" title="interface in org.apache.storm.trident.state">StateUpdater</a>&nbsp;updater)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="filter(org.apache.storm.trident.operation.Filter)">
 <h3>filter</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">filter</span><wbr><span class="parameters">(<a href="operation/Filter.html" title="interface in org.apache.storm.trident.operation">Filter</a>&nbsp;filter)</span></div>
 <div class="block">Returns a stream consisting of the elements of this stream that match the given filter.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>filter</code> - the filter to apply to each trident tuple to determine if it should be included.</dd>
 <dt>Returns:</dt>
 <dd>the new stream</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="filter(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Filter)">
 <h3>filter</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">filter</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Filter.html" title="interface in org.apache.storm.trident.operation">Filter</a>&nbsp;filter)</span></div>
 <div class="block">Returns a stream consisting of the elements of this stream that match the given filter.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>inputFields</code> - the fields of the input trident tuple to be selected.</dd>
 <dd><code>filter</code> - the filter to apply to each trident tuple to determine if it should be included.</dd>
 <dt>Returns:</dt>
 <dd>the new stream</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="map(org.apache.storm.trident.operation.MapFunction)">
 <h3>map</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">map</span><wbr><span class="parameters">(<a href="operation/MapFunction.html" title="interface in org.apache.storm.trident.operation">MapFunction</a>&nbsp;function)</span></div>
 <div class="block">Returns a stream consisting of the result of applying the given mapping function to the values of this stream.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>function</code> - a mapping function to be applied to each value in this stream.</dd>
 <dt>Returns:</dt>
 <dd>the new stream</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="map(org.apache.storm.trident.operation.MapFunction,org.apache.storm.tuple.Fields)">
 <h3>map</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">map</span><wbr><span class="parameters">(<a href="operation/MapFunction.html" title="interface in org.apache.storm.trident.operation">MapFunction</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;outputFields)</span></div>
 <div class="block">Returns a stream consisting of the result of applying the given mapping function to the values of this stream. This method replaces
  old output fields with new output fields, achieving T -> V conversion.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>function</code> - a mapping function to be applied to each value in this stream.</dd>
 <dd><code>outputFields</code> - new output fields</dd>
 <dt>Returns:</dt>
 <dd>the new stream</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="flatMap(org.apache.storm.trident.operation.FlatMapFunction)">
 <h3>flatMap</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">flatMap</span><wbr><span class="parameters">(<a href="operation/FlatMapFunction.html" title="interface in org.apache.storm.trident.operation">FlatMapFunction</a>&nbsp;function)</span></div>
 <div class="block">Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided
  mapping function to each value. This has the effect of applying a one-to-many transformation to the values of the stream, and then
  flattening the resulting elements into a new stream.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>function</code> - a mapping function to be applied to each value in this stream which produces new values.</dd>
 <dt>Returns:</dt>
 <dd>the new stream</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="flatMap(org.apache.storm.trident.operation.FlatMapFunction,org.apache.storm.tuple.Fields)">
 <h3>flatMap</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">flatMap</span><wbr><span class="parameters">(<a href="operation/FlatMapFunction.html" title="interface in org.apache.storm.trident.operation">FlatMapFunction</a>&nbsp;function,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;outputFields)</span></div>
 <div class="block">Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided
  mapping function to each value. This has the effect of applying a one-to-many transformation to the values of the stream, and then
  flattening the resulting elements into a new stream. This method replaces old output fields with new output fields, achieving T -> V
  conversion.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>function</code> - a mapping function to be applied to each value in this stream which produces new values.</dd>
 <dd><code>outputFields</code> - new output fields</dd>
 <dt>Returns:</dt>
 <dd>the new stream</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="peek(org.apache.storm.trident.operation.Consumer)">
 <h3>peek</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">peek</span><wbr><span class="parameters">(<a href="operation/Consumer.html" title="interface in org.apache.storm.trident.operation">Consumer</a>&nbsp;action)</span></div>
 <div class="block">Returns a stream consisting of the trident tuples of this stream, additionally performing the provided action on each trident tuple
  as they are consumed from the resulting stream. This is mostly useful for debugging to see the tuples as they flow past a certain
  point in a pipeline.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>action</code> - the action to perform on the trident tuple as they are consumed from the stream</dd>
 <dt>Returns:</dt>
 <dd>the new stream</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="chainedAgg()">
 <h3>chainedAgg</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="fluent/ChainedAggregatorDeclarer.html" title="class in org.apache.storm.trident.fluent">ChainedAggregatorDeclarer</a></span>&nbsp;<span class="element-name">chainedAgg</span>()</div>
 </section>
 </li>
 <li>
 <section class="detail" id="minBy(java.lang.String)">
 <h3>minBy</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">minBy</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;inputFieldName)</span></div>
 <div class="block">This aggregator operation computes the minimum of tuples by the given <code>inputFieldName</code> and it is assumed that its value is an
  instance of <code>Comparable</code>. If the value of tuple with field <code>inputFieldName</code> is not an instance of <code>Comparable</code> then
  it throws <code>ClassCastException</code></div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>inputFieldName</code> - input field name</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="minBy(java.lang.String,java.util.Comparator)">
 <h3>minBy</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="type-parameters">&lt;T&gt;</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">minBy</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;inputFieldName,
  <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Comparator.html" title="class or interface in java.util" class="external-link">Comparator</a>&lt;T&gt;&nbsp;comparator)</span></div>
 <div class="block">This aggregator operation computes the minimum of tuples by the given <code>inputFieldName</code> in a stream by using the given <code>
  comparator</code>. If the value of tuple with field <code>inputFieldName</code> is not an instance of <code>T</code> then it throws <code>
  ClassCastException</code></div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>inputFieldName</code> - input field name</dd>
 <dd><code>comparator</code> - comparator used in for finding minimum of two tuple values of <code>inputFieldName</code>.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="min(java.util.Comparator)">
 <h3>min</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">min</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Comparator.html" title="class or interface in java.util" class="external-link">Comparator</a>&lt;<a href="tuple/TridentTuple.html" title="interface in org.apache.storm.trident.tuple">TridentTuple</a>&gt;&nbsp;comparator)</span></div>
 <div class="block">This aggregator operation computes the minimum of tuples in a stream by using the given <code>comparator</code> with <code>
  TridentTuple</code>s.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>comparator</code> - comparator used in for finding minimum of two tuple values.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="maxBy(java.lang.String)">
 <h3>maxBy</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">maxBy</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;inputFieldName)</span></div>
 <div class="block">This aggregator operation computes the maximum of tuples by the given <code>inputFieldName</code> and it is assumed that its value is an
  instance of <code>Comparable</code>. If the value of tuple with field <code>inputFieldName</code> is not an instance of <code>Comparable</code> then
  it throws <code>ClassCastException</code></div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>inputFieldName</code> - input field name</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="maxBy(java.lang.String,java.util.Comparator)">
 <h3>maxBy</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="type-parameters">&lt;T&gt;</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">maxBy</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>&nbsp;inputFieldName,
  <a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Comparator.html" title="class or interface in java.util" class="external-link">Comparator</a>&lt;T&gt;&nbsp;comparator)</span></div>
 <div class="block">This aggregator operation computes the maximum of tuples by the given <code>inputFieldName</code> in a stream by using the given <code>
  comparator</code>. If the value of tuple with field <code>inputFieldName</code> is not an instance of <code>T</code> then it throws <code>
  ClassCastException</code></div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>inputFieldName</code> - input field name</dd>
 <dd><code>comparator</code> - comparator used in for finding maximum of two tuple values of <code>inputFieldName</code>.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="max(java.util.Comparator)">
 <h3>max</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">max</span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Comparator.html" title="class or interface in java.util" class="external-link">Comparator</a>&lt;<a href="tuple/TridentTuple.html" title="interface in org.apache.storm.trident.tuple">TridentTuple</a>&gt;&nbsp;comparator)</span></div>
 <div class="block">This aggregator operation computes the maximum of tuples in a stream by using the given <code>comparator</code> with <code>
  TridentTuple</code>s.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>comparator</code> - comparator used in for finding maximum of two tuple values.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="aggregate(org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>aggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">aggregate</span><wbr><span class="parameters">(<a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="aggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>aggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">aggregate</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="aggregate(org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)">
 <h3>aggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">aggregate</span><wbr><span class="parameters">(<a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="aggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)">
 <h3>aggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">aggregate</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="aggregate(org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)">
 <h3>aggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">aggregate</span><wbr><span class="parameters">(<a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="aggregate(org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)">
 <h3>aggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">aggregate</span><wbr><span class="parameters">(<a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="tumblingWindow(int,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>tumblingWindow</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">tumblingWindow</span><wbr><span class="parameters">(int&nbsp;windowCount,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 <div class="block">Returns a stream of tuples which are aggregated results of a tumbling window with every <code>windowCount</code> of tuples.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>windowCount</code> - represents number of tuples in the window</dd>
 <dd><code>windowStoreFactory</code> - intermediary tuple store for storing windowing tuples</dd>
 <dd><code>inputFields</code> - projected fields for aggregator</dd>
 <dd><code>aggregator</code> - aggregator to run on the window of tuples to compute the result and emit to the stream.</dd>
 <dd><code>functionFields</code> - fields of values to emit with aggregation.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="tumblingWindow(org.apache.storm.topology.base.BaseWindowedBolt.Duration,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>tumblingWindow</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">tumblingWindow</span><wbr><span class="parameters">(<a href="../topology/base/BaseWindowedBolt.Duration.html" title="class in org.apache.storm.topology.base">BaseWindowedBolt.Duration</a>&nbsp;windowDuration,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 <div class="block">Returns a stream of tuples which are aggregated results of a window that tumbles at duration of <code>windowDuration</code>.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>windowDuration</code> - represents tumbling window duration configuration</dd>
 <dd><code>windowStoreFactory</code> - intermediary tuple store for storing windowing tuples</dd>
 <dd><code>inputFields</code> - projected fields for aggregator</dd>
 <dd><code>aggregator</code> - aggregator to run on the window of tuples to compute the result and emit to the stream.</dd>
 <dd><code>functionFields</code> - fields of values to emit with aggregation.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="slidingWindow(int,int,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>slidingWindow</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">slidingWindow</span><wbr><span class="parameters">(int&nbsp;windowCount,
  int&nbsp;slideCount,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 <div class="block">Returns a stream of tuples which are aggregated results of a sliding window with every <code>windowCount</code> of tuples and slides the
  window after <code>slideCount</code>.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>windowCount</code> - represents tuples count of a window</dd>
 <dd><code>slideCount</code> - the number of tuples after which the window slides</dd>
 <dd><code>windowStoreFactory</code> - intermediary tuple store for storing windowing tuples</dd>
 <dd><code>inputFields</code> - projected fields for aggregator</dd>
 <dd><code>aggregator</code> - aggregator to run on the window of tuples to compute the result and emit to the stream.</dd>
 <dd><code>functionFields</code> - fields of values to emit with aggregation.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="slidingWindow(org.apache.storm.topology.base.BaseWindowedBolt.Duration,org.apache.storm.topology.base.BaseWindowedBolt.Duration,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>slidingWindow</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">slidingWindow</span><wbr><span class="parameters">(<a href="../topology/base/BaseWindowedBolt.Duration.html" title="class in org.apache.storm.topology.base">BaseWindowedBolt.Duration</a>&nbsp;windowDuration,
  <a href="../topology/base/BaseWindowedBolt.Duration.html" title="class in org.apache.storm.topology.base">BaseWindowedBolt.Duration</a>&nbsp;slidingInterval,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 <div class="block">Returns a stream of tuples which are aggregated results of a window which slides at duration of <code>slidingInterval</code> and completes
  a window at <code>windowDuration</code>.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>windowDuration</code> - represents window duration configuration</dd>
 <dd><code>slidingInterval</code> - the time duration after which the window slides</dd>
 <dd><code>windowStoreFactory</code> - intermediary tuple store for storing windowing tuples</dd>
 <dd><code>inputFields</code> - projected fields for aggregator</dd>
 <dd><code>aggregator</code> - aggregator to run on the window of tuples to compute the result and emit to the stream.</dd>
 <dd><code>functionFields</code> - fields of values to emit with aggregation.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="window(org.apache.storm.trident.windowing.config.WindowConfig,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>window</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">window</span><wbr><span class="parameters">(<a href="windowing/config/WindowConfig.html" title="interface in org.apache.storm.trident.windowing.config">WindowConfig</a>&nbsp;windowConfig,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 <div class="block">Returns a stream of aggregated results based on the given window configuration which uses inmemory windowing tuple store.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>windowConfig</code> - window configuration like window length and slide length.</dd>
 <dd><code>inputFields</code> - input fields</dd>
 <dd><code>aggregator</code> - aggregator to run on the window of tuples to compute the result and emit to the stream.</dd>
 <dd><code>functionFields</code> - fields of values to emit with aggregation.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="window(org.apache.storm.trident.windowing.config.WindowConfig,org.apache.storm.trident.windowing.WindowsStoreFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.Aggregator,org.apache.storm.tuple.Fields)">
 <h3>window</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">window</span><wbr><span class="parameters">(<a href="windowing/config/WindowConfig.html" title="interface in org.apache.storm.trident.windowing.config">WindowConfig</a>&nbsp;windowConfig,
  <a href="windowing/WindowsStoreFactory.html" title="interface in org.apache.storm.trident.windowing">WindowsStoreFactory</a>&nbsp;windowStoreFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/Aggregator.html" title="interface in org.apache.storm.trident.operation">Aggregator</a>&nbsp;aggregator,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 <div class="block">Returns stream of aggregated results based on the given window configuration.</div>
 <dl class="notes">
 <dt>Parameters:</dt>
 <dd><code>windowConfig</code> - window configuration like window length and slide length.</dd>
 <dd><code>windowStoreFactory</code> - intermediary tuple store for storing tuples for windowing</dd>
 <dd><code>inputFields</code> - input fields</dd>
 <dd><code>aggregator</code> - aggregator to run on the window of tuples to compute the result and emit to the stream.</dd>
 <dd><code>functionFields</code> - fields of values to emit with aggregation.</dd>
 <dt>Returns:</dt>
 <dd>the new stream with this operation.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="persistentAggregate(org.apache.storm.trident.state.StateFactory,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)">
 <h3>persistentAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">persistentAggregate</span><wbr><span class="parameters">(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="persistentAggregate(org.apache.storm.trident.state.StateSpec,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)">
 <h3>persistentAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">persistentAggregate</span><wbr><span class="parameters">(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;spec,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="persistentAggregate(org.apache.storm.trident.state.StateFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)">
 <h3>persistentAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">persistentAggregate</span><wbr><span class="parameters">(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="persistentAggregate(org.apache.storm.trident.state.StateSpec,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.CombinerAggregator,org.apache.storm.tuple.Fields)">
 <h3>persistentAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">persistentAggregate</span><wbr><span class="parameters">(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;spec,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/CombinerAggregator.html" title="interface in org.apache.storm.trident.operation">CombinerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="persistentAggregate(org.apache.storm.trident.state.StateFactory,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)">
 <h3>persistentAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">persistentAggregate</span><wbr><span class="parameters">(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="persistentAggregate(org.apache.storm.trident.state.StateSpec,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)">
 <h3>persistentAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">persistentAggregate</span><wbr><span class="parameters">(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;spec,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="persistentAggregate(org.apache.storm.trident.state.StateFactory,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)">
 <h3>persistentAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">persistentAggregate</span><wbr><span class="parameters">(<a href="state/StateFactory.html" title="interface in org.apache.storm.trident.state">StateFactory</a>&nbsp;stateFactory,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="persistentAggregate(org.apache.storm.trident.state.StateSpec,org.apache.storm.tuple.Fields,org.apache.storm.trident.operation.ReducerAggregator,org.apache.storm.tuple.Fields)">
 <h3>persistentAggregate</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="TridentState.html" title="class in org.apache.storm.trident">TridentState</a></span>&nbsp;<span class="element-name">persistentAggregate</span><wbr><span class="parameters">(<a href="state/StateSpec.html" title="class in org.apache.storm.trident.state">StateSpec</a>&nbsp;spec,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;inputFields,
  <a href="operation/ReducerAggregator.html" title="interface in org.apache.storm.trident.operation">ReducerAggregator</a>&nbsp;agg,
  <a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a>&nbsp;functionFields)</span></div>
 </section>
 </li>
 <li>
 <section class="detail" id="toStream()">
 <h3>toStream</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="Stream.html" title="class in org.apache.storm.trident">Stream</a></span>&nbsp;<span class="element-name">toStream</span>()</div>
 <dl class="notes">
 <dt>Specified by:</dt>
 <dd><code><a href="fluent/IAggregatableStream.html#toStream()">toStream</a></code>&nbsp;in interface&nbsp;<code><a href="fluent/IAggregatableStream.html" title="interface in org.apache.storm.trident.fluent">IAggregatableStream</a></code></dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="getName()">
 <h3>getName</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></span>&nbsp;<span class="element-name">getName</span>()</div>
 <div class="block">Returns the label applied to the stream.</div>
 <dl class="notes">
 <dt>Returns:</dt>
 <dd>the label applied to the stream.</dd>
 </dl>
 </section>
 </li>
 <li>
 <section class="detail" id="getOutputFields()">
 <h3>getOutputFields</h3>
 <div class="member-signature"><span class="modifiers">public</span>&nbsp;<span class="return-type"><a href="../tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a></span>&nbsp;<span class="element-name">getOutputFields</span>()</div>
 <dl class="notes">
 <dt>Specified by:</dt>
 <dd><code><a href="fluent/IAggregatableStream.html#getOutputFields()">getOutputFields</a></code>&nbsp;in interface&nbsp;<code><a href="fluent/IAggregatableStream.html" title="interface in org.apache.storm.trident.fluent">IAggregatableStream</a></code></dd>
 </dl>
 </section>
 </li>
 </ul>
 </section>
 </li>
 </ul>
 </section>
 <!-- ========= END OF CLASS DATA ========= -->
 </main>
 <footer role="contentinfo">
 <hr>
 <p class="legal-copy"><small>Copyright &#169; 2023 <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p>
 </footer>
 </div>
 </div>
 </body>
 </html>