Google Git
Sign in
apache / storm-site / 553ca57e4e37c342861887cd8dd404f44d39b4f9 / . / content / releases / current / javadocs / org / apache / storm / streams / PairStream.html
blob: 5e98308955a5ffb549eff1b83d56674f22c5b653 [file] [log] [blame]
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<!-- NewPage -->
<html lang="en">
<head>
<!-- Generated by javadoc -->
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>PairStream (Storm 2.4.0 API)</title>
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
<body>
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
parent.document.title="PairStream (Storm 2.4.0 API)";
}
}
catch(err) {
}
//-->
var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
var tableTab = "tableTab";
var activeTableTab = "activeTableTab";
</script>
<noscript>
<div>JavaScript is disabled on your browser.</div>
</noscript>
<!-- ========= START OF TOP NAVBAR ======= -->
<div class="topNav"><a name="navbar.top">
<!-- -->
</a>
<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
<a name="navbar.top.firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="../../../../overview-summary.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
<li><a href="class-use/PairStream.html">Use</a></li>
<li><a href="package-tree.html">Tree</a></li>
<li><a href="../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../index-all.html">Index</a></li>
<li><a href="../../../../help-doc.html">Help</a></li>
</ul>
</div>
<div class="subNav">
<ul class="navList">
<li><a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams"><span class="typeNameLink">Prev&nbsp;Class</span></a></li>
<li><a href="../../../../org/apache/storm/streams/ProcessorNode.html" title="class in org.apache.storm.streams"><span class="typeNameLink">Next&nbsp;Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../index.html?org/apache/storm/streams/PairStream.html" target="_top">Frames</a></li>
<li><a href="PairStream.html" target="_top">No&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_top");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<div>
<ul class="subNavList">
<li>Summary:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li><a href="#fields.inherited.from.class.org.apache.storm.streams.Stream">Field</a>&nbsp;|&nbsp;</li>
<li>Constr&nbsp;|&nbsp;</li>
<li><a href="#method.summary">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail:&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li>Constr&nbsp;|&nbsp;</li>
<li><a href="#method.detail">Method</a></li>
</ul>
</div>
<a name="skip.navbar.top">
<!-- -->
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
<!-- ======== START OF CLASS DATA ======== -->
<div class="header">
<div class="subTitle">org.apache.storm.streams</div>
<h2 title="Class PairStream" class="title">Class PairStream&lt;K,V&gt;</h2>
</div>
<div class="contentContainer">
<ul class="inheritance">
<li><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li>
<li>
<ul class="inheritance">
<li><a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">org.apache.storm.streams.Stream</a>&lt;<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;K,V&gt;&gt;</li>
<li>
<ul class="inheritance">
<li>org.apache.storm.streams.PairStream&lt;K,V&gt;</li>
</ul>
</li>
</ul>
</li>
</ul>
<div class="description">
<ul class="blockList">
<li class="blockList">
<hr>
<br>
<pre><a href="../../../../org/apache/storm/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.storm.annotation">@InterfaceStability.Unstable</a>
public class <span class="typeNameLabel">PairStream&lt;K,V&gt;</span>
extends <a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">Stream</a>&lt;<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;K,V&gt;&gt;</pre>
<div class="block"><p>Represents a stream of key-value pairs.</p></div>
</li>
</ul>
</div>
<div class="summary">
<ul class="blockList">
<li class="blockList">
<!-- =========== FIELD SUMMARY =========== -->
<ul class="blockList">
<li class="blockList"><a name="field.summary">
<!-- -->
</a>
<h3>Field Summary</h3>
<ul class="blockList">
<li class="blockList"><a name="fields.inherited.from.class.org.apache.storm.streams.Stream">
<!-- -->
</a>
<h3>Fields inherited from class&nbsp;org.apache.storm.streams.<a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">Stream</a></h3>
<code><a href="../../../../org/apache/storm/streams/Stream.html#KEY">KEY</a>, <a href="../../../../org/apache/storm/streams/Stream.html#KEY_VALUE">KEY_VALUE</a>, <a href="../../../../org/apache/storm/streams/Stream.html#node">node</a>, <a href="../../../../org/apache/storm/streams/Stream.html#stream">stream</a>, <a href="../../../../org/apache/storm/streams/Stream.html#streamBuilder">streamBuilder</a>, <a href="../../../../org/apache/storm/streams/Stream.html#VALUE">VALUE</a></code></li>
</ul>
</li>
</ul>
<!-- ========== METHOD SUMMARY =========== -->
<ul class="blockList">
<li class="blockList"><a name="method.summary">
<!-- -->
</a>
<h3>Method Summary</h3>
<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd">&nbsp;</span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd">&nbsp;</span></span></caption>
<tr>
<th class="colFirst" scope="col">Modifier and Type</th>
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr id="i0" class="altColor">
<td class="colFirst"><code>&lt;A,R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#aggregateByKey-org.apache.storm.streams.operations.CombinerAggregator-">aggregateByKey</a></span>(<a href="../../../../org/apache/storm/streams/operations/CombinerAggregator.html" title="interface in org.apache.storm.streams.operations">CombinerAggregator</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,A,? extends R&gt;&nbsp;aggregator)</code>
<div class="block">Aggregates the values for each key of this stream using the given <a href="../../../../org/apache/storm/streams/operations/CombinerAggregator.html" title="interface in org.apache.storm.streams.operations"><code>CombinerAggregator</code></a>.</div>
</td>
</tr>
<tr id="i1" class="rowColor">
<td class="colFirst"><code>&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#aggregateByKey-R-org.apache.storm.streams.operations.BiFunction-org.apache.storm.streams.operations.BiFunction-">aggregateByKey</a></span>(R&nbsp;initialValue,
<a href="../../../../org/apache/storm/streams/operations/BiFunction.html" title="interface in org.apache.storm.streams.operations">BiFunction</a>&lt;? super R,? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;accumulator,
<a href="../../../../org/apache/storm/streams/operations/BiFunction.html" title="interface in org.apache.storm.streams.operations">BiFunction</a>&lt;? super R,? super R,? extends R&gt;&nbsp;combiner)</code>
<div class="block">Aggregates the values for each key of this stream using the given initial value, accumulator and combiner.</div>
</td>
</tr>
<tr id="i2" class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;[]</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#branch-org.apache.storm.streams.operations.Predicate...-">branch</a></span>(<a href="../../../../org/apache/storm/streams/operations/Predicate.html" title="interface in org.apache.storm.streams.operations">Predicate</a>&lt;? super <a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;...&nbsp;predicates)</code>
<div class="block">Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.</div>
</td>
</tr>
<tr id="i3" class="rowColor">
<td class="colFirst"><code>&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a>&lt;V1&gt;&gt;&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#coGroupByKey-org.apache.storm.streams.PairStream-">coGroupByKey</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</code>
<div class="block">Groups the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i4" class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#countByKey--">countByKey</a></span>()</code>
<div class="block">Counts the values for each key of this stream.</div>
</td>
</tr>
<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#filter-org.apache.storm.streams.operations.Predicate-">filter</a></span>(<a href="../../../../org/apache/storm/streams/operations/Predicate.html" title="interface in org.apache.storm.streams.operations">Predicate</a>&lt;? super <a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;&nbsp;predicate)</code>
<div class="block">Returns a stream consisting of the elements of this stream that matches the given filter.</div>
</td>
</tr>
<tr id="i6" class="altColor">
<td class="colFirst"><code>&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#flatMapValues-org.apache.storm.streams.operations.FlatMapFunction-">flatMapValues</a></span>(<a href="../../../../org/apache/storm/streams/operations/FlatMapFunction.html" title="interface in org.apache.storm.streams.operations">FlatMapFunction</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;function)</code>
<div class="block">Return a new stream by applying a <a href="../../../../org/apache/storm/streams/operations/FlatMapFunction.html" title="interface in org.apache.storm.streams.operations"><code>FlatMapFunction</code></a> function to the value of each key-value pairs in this stream.</div>
</td>
</tr>
<tr id="i7" class="rowColor">
<td class="colFirst"><code>&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,V1&gt;&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#fullOuterJoin-org.apache.storm.streams.PairStream-">fullOuterJoin</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</code>
<div class="block">Does a full outer join of the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i8" class="altColor">
<td class="colFirst"><code>&lt;R,V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#fullOuterJoin-org.apache.storm.streams.PairStream-org.apache.storm.streams.operations.ValueJoiner-">fullOuterJoin</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream,
<a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations">ValueJoiner</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? super V1,? extends R&gt;&nbsp;valueJoiner)</code>
<div class="block">Does a full outer join of the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i9" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#groupByKey--">groupByKey</a></span>()</code>
<div class="block">Returns a new stream where the values are grouped by the keys.</div>
</td>
</tr>
<tr id="i10" class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#groupByKeyAndWindow-org.apache.storm.streams.windowing.Window-">groupByKeyAndWindow</a></span>(<a href="../../../../org/apache/storm/streams/windowing/Window.html" title="interface in org.apache.storm.streams.windowing">Window</a>&lt;?,?&gt;&nbsp;window)</code>
<div class="block">Returns a new stream where the values are grouped by keys and the given window.</div>
</td>
</tr>
<tr id="i11" class="rowColor">
<td class="colFirst"><code>&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,V1&gt;&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#join-org.apache.storm.streams.PairStream-">join</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</code>
<div class="block">Join the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i12" class="altColor">
<td class="colFirst"><code>&lt;R,V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#join-org.apache.storm.streams.PairStream-org.apache.storm.streams.operations.ValueJoiner-">join</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream,
<a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations">ValueJoiner</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? super V1,? extends R&gt;&nbsp;valueJoiner)</code>
<div class="block">Join the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i13" class="rowColor">
<td class="colFirst"><code>&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,V1&gt;&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#leftOuterJoin-org.apache.storm.streams.PairStream-">leftOuterJoin</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</code>
<div class="block">Does a left outer join of the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i14" class="altColor">
<td class="colFirst"><code>&lt;R,V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#leftOuterJoin-org.apache.storm.streams.PairStream-org.apache.storm.streams.operations.ValueJoiner-">leftOuterJoin</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream,
<a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations">ValueJoiner</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? super V1,? extends R&gt;&nbsp;valueJoiner)</code>
<div class="block">Does a left outer join of the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i15" class="rowColor">
<td class="colFirst"><code>&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#mapValues-org.apache.storm.streams.operations.Function-">mapValues</a></span>(<a href="../../../../org/apache/storm/streams/operations/Function.html" title="interface in org.apache.storm.streams.operations">Function</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;function)</code>
<div class="block">Returns a new stream by applying a <a href="../../../../org/apache/storm/streams/operations/Function.html" title="interface in org.apache.storm.streams.operations"><code>Function</code></a> to the value of each key-value pairs in this stream.</div>
</td>
</tr>
<tr id="i16" class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#peek-org.apache.storm.streams.operations.Consumer-">peek</a></span>(<a href="../../../../org/apache/storm/streams/operations/Consumer.html" title="interface in org.apache.storm.streams.operations">Consumer</a>&lt;? super <a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;&nbsp;action)</code>
<div class="block">Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as they are consumed from the resulting stream.</div>
</td>
</tr>
<tr id="i17" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#reduceByKey-org.apache.storm.streams.operations.Reducer-">reduceByKey</a></span>(<a href="../../../../org/apache/storm/streams/operations/Reducer.html" title="interface in org.apache.storm.streams.operations">Reducer</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;reducer)</code>
<div class="block">Performs a reduction on the values for each key of this stream by repeatedly applying the reducer.</div>
</td>
</tr>
<tr id="i18" class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#reduceByKeyAndWindow-org.apache.storm.streams.operations.Reducer-org.apache.storm.streams.windowing.Window-">reduceByKeyAndWindow</a></span>(<a href="../../../../org/apache/storm/streams/operations/Reducer.html" title="interface in org.apache.storm.streams.operations">Reducer</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;reducer,
<a href="../../../../org/apache/storm/streams/windowing/Window.html" title="interface in org.apache.storm.streams.windowing">Window</a>&lt;?,?&gt;&nbsp;window)</code>
<div class="block">Returns a new stream where the values that arrive within a window having the same key will be reduced by repeatedly applying the reducer.</div>
</td>
</tr>
<tr id="i19" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#repartition-int-">repartition</a></span>(int&nbsp;parallelism)</code>
<div class="block">Returns a new stream with the given value of parallelism.</div>
</td>
</tr>
<tr id="i20" class="altColor">
<td class="colFirst"><code>&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,V1&gt;&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#rightOuterJoin-org.apache.storm.streams.PairStream-">rightOuterJoin</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</code>
<div class="block">Does a right outer join of the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i21" class="rowColor">
<td class="colFirst"><code>&lt;R,V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#rightOuterJoin-org.apache.storm.streams.PairStream-org.apache.storm.streams.operations.ValueJoiner-">rightOuterJoin</a></span>(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream,
<a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations">ValueJoiner</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? super V1,? extends R&gt;&nbsp;valueJoiner)</code>
<div class="block">Does a right outer join of the values of this stream with the values having the same key from the other stream.</div>
</td>
</tr>
<tr id="i22" class="altColor">
<td class="colFirst"><code>&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/StreamState.html" title="class in org.apache.storm.streams">StreamState</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#updateStateByKey-R-org.apache.storm.streams.operations.BiFunction-">updateStateByKey</a></span>(R&nbsp;initialValue,
<a href="../../../../org/apache/storm/streams/operations/BiFunction.html" title="interface in org.apache.storm.streams.operations">BiFunction</a>&lt;? super R,? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;stateUpdateFn)</code>
<div class="block">Update the state by applying the given state update function to the previous state of the key and the new value for the key.</div>
</td>
</tr>
<tr id="i23" class="rowColor">
<td class="colFirst"><code>&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/StreamState.html" title="class in org.apache.storm.streams">StreamState</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#updateStateByKey-org.apache.storm.streams.operations.StateUpdater-">updateStateByKey</a></span>(<a href="../../../../org/apache/storm/streams/operations/StateUpdater.html" title="interface in org.apache.storm.streams.operations">StateUpdater</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;stateUpdater)</code>
<div class="block">Update the state by applying the given state update function to the previous state of the key and the new value for the key.</div>
</td>
</tr>
<tr id="i24" class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/streams/PairStream.html#window-org.apache.storm.streams.windowing.Window-">window</a></span>(<a href="../../../../org/apache/storm/streams/windowing/Window.html" title="interface in org.apache.storm.streams.windowing">Window</a>&lt;?,?&gt;&nbsp;window)</code>
<div class="block">Returns a new stream consisting of the elements that fall within the window as specified by the window parameter.</div>
</td>
</tr>
</table>
<ul class="blockList">
<li class="blockList"><a name="methods.inherited.from.class.org.apache.storm.streams.Stream">
<!-- -->
</a>
<h3>Methods inherited from class&nbsp;org.apache.storm.streams.<a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">Stream</a></h3>
<code><a href="../../../../org/apache/storm/streams/Stream.html#aggregate-org.apache.storm.streams.operations.CombinerAggregator-">aggregate</a>, <a href="../../../../org/apache/storm/streams/Stream.html#aggregate-R-org.apache.storm.streams.operations.BiFunction-org.apache.storm.streams.operations.BiFunction-">aggregate</a>, <a href="../../../../org/apache/storm/streams/Stream.html#count--">count</a>, <a href="../../../../org/apache/storm/streams/Stream.html#flatMap-org.apache.storm.streams.operations.FlatMapFunction-">flatMap</a>, <a href="../../../../org/apache/storm/streams/Stream.html#flatMapToPair-org.apache.storm.streams.operations.PairFlatMapFunction-">flatMapToPair</a>, <a href="../../../../org/apache/storm/streams/Stream.html#forEach-org.apache.storm.streams.operations.Consumer-">forEach</a>, <a href="../../../../org/apache/storm/streams/Stream.html#map-org.apache.storm.streams.operations.Function-">map</a>, <a href="../../../../org/apache/storm/streams/Stream.html#mapToPair-org.apache.storm.streams.operations.PairFunction-">mapToPair</a>, <a href="../../../../org/apache/storm/streams/Stream.html#partitionBy-org.apache.storm.tuple.Fields-int-">partitionBy</a>, <a href="../../../../org/apache/storm/streams/Stream.html#print--">print</a>, <a href="../../../../org/apache/storm/streams/Stream.html#reduce-org.apache.storm.streams.operations.Reducer-">reduce</a>, <a href="../../../../org/apache/storm/streams/Stream.html#stateQuery-org.apache.storm.streams.StreamState-">stateQuery</a>, <a href="../../../../org/apache/storm/streams/Stream.html#to-org.apache.storm.topology.IBasicBolt-">to</a>, <a href="../../../../org/apache/storm/streams/Stream.html#to-org.apache.storm.topology.IBasicBolt-int-">to</a>, <a href="../../../../org/apache/storm/streams/Stream.html#to-org.apache.storm.topology.IRichBolt-">to</a>, <a href="../../../../org/apache/storm/streams/Stream.html#to-org.apache.storm.topology.IRichBolt-int-">to</a></code></li>
</ul>
<ul class="blockList">
<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
<!-- -->
</a>
<h3>Methods inherited from class&nbsp;java.lang.<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3>
<code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--" title="class or interface in java.lang">clone</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-" title="class or interface in java.lang">equals</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--" title="class or interface in java.lang">finalize</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--" title="class or interface in java.lang">getClass</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--" title="class or interface in java.lang">hashCode</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--" title="class or interface in java.lang">notify</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--" title="class or interface in java.lang">toString</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--" title="class or interface in java.lang">wait</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-" title="class or interface in java.lang">wait</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-" title="class or interface in java.lang">wait</a></code></li>
</ul>
</li>
</ul>
</li>
</ul>
</div>
<div class="details">
<ul class="blockList">
<li class="blockList">
<!-- ============ METHOD DETAIL ========== -->
<ul class="blockList">
<li class="blockList"><a name="method.detail">
<!-- -->
</a>
<h3>Method Detail</h3>
<a name="mapValues-org.apache.storm.streams.operations.Function-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>mapValues</h4>
<pre>public&nbsp;&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;mapValues(<a href="../../../../org/apache/storm/streams/operations/Function.html" title="interface in org.apache.storm.streams.operations">Function</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;function)</pre>
<div class="block"><p>Returns a new stream by applying a <a href="../../../../org/apache/storm/streams/operations/Function.html" title="interface in org.apache.storm.streams.operations"><code>Function</code></a> to the value of each key-value pairs in this stream.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>function</code> - the mapping function</dd>
<dd><code>R</code> - the result type</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="flatMapValues-org.apache.storm.streams.operations.FlatMapFunction-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>flatMapValues</h4>
<pre>public&nbsp;&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;flatMapValues(<a href="../../../../org/apache/storm/streams/operations/FlatMapFunction.html" title="interface in org.apache.storm.streams.operations">FlatMapFunction</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;function)</pre>
<div class="block"><p>Return a new stream by applying a <a href="../../../../org/apache/storm/streams/operations/FlatMapFunction.html" title="interface in org.apache.storm.streams.operations"><code>FlatMapFunction</code></a> function to the value of each key-value pairs in this stream.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>function</code> - the flatmap function</dd>
<dd><code>R</code> - the result type</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="aggregateByKey-java.lang.Object-org.apache.storm.streams.operations.BiFunction-org.apache.storm.streams.operations.BiFunction-">
<!-- -->
</a><a name="aggregateByKey-R-org.apache.storm.streams.operations.BiFunction-org.apache.storm.streams.operations.BiFunction-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>aggregateByKey</h4>
<pre>public&nbsp;&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;aggregateByKey(R&nbsp;initialValue,
<a href="../../../../org/apache/storm/streams/operations/BiFunction.html" title="interface in org.apache.storm.streams.operations">BiFunction</a>&lt;? super R,? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;accumulator,
<a href="../../../../org/apache/storm/streams/operations/BiFunction.html" title="interface in org.apache.storm.streams.operations">BiFunction</a>&lt;? super R,? super R,? extends R&gt;&nbsp;combiner)</pre>
<div class="block"><p>Aggregates the values for each key of this stream using the given initial value, accumulator and combiner.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>initialValue</code> - the initial value of the result</dd>
<dd><code>accumulator</code> - the accumulator</dd>
<dd><code>combiner</code> - the combiner</dd>
<dd><code>R</code> - the result type</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="aggregateByKey-org.apache.storm.streams.operations.CombinerAggregator-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>aggregateByKey</h4>
<pre>public&nbsp;&lt;A,R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;aggregateByKey(<a href="../../../../org/apache/storm/streams/operations/CombinerAggregator.html" title="interface in org.apache.storm.streams.operations">CombinerAggregator</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,A,? extends R&gt;&nbsp;aggregator)</pre>
<div class="block"><p>Aggregates the values for each key of this stream using the given <a href="../../../../org/apache/storm/streams/operations/CombinerAggregator.html" title="interface in org.apache.storm.streams.operations"><code>CombinerAggregator</code></a>.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>aggregator</code> - the combiner aggregator</dd>
<dd><code>A</code> - the accumulator type</dd>
<dd><code>R</code> - the result type</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="countByKey--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>countByKey</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a>&gt;&nbsp;countByKey()</pre>
<div class="block"><p>Counts the values for each key of this stream.</p></div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="reduceByKey-org.apache.storm.streams.operations.Reducer-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>reduceByKey</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;reduceByKey(<a href="../../../../org/apache/storm/streams/operations/Reducer.html" title="interface in org.apache.storm.streams.operations">Reducer</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;reducer)</pre>
<div class="block"><p>Performs a reduction on the values for each key of this stream by repeatedly applying the reducer.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>reducer</code> - the reducer</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="groupByKey--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>groupByKey</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;&nbsp;groupByKey()</pre>
<div class="block"><p>Returns a new stream where the values are grouped by the keys.</p></div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="groupByKeyAndWindow-org.apache.storm.streams.windowing.Window-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>groupByKeyAndWindow</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;&nbsp;groupByKeyAndWindow(<a href="../../../../org/apache/storm/streams/windowing/Window.html" title="interface in org.apache.storm.streams.windowing">Window</a>&lt;?,?&gt;&nbsp;window)</pre>
<div class="block"><p>Returns a new stream where the values are grouped by keys and the given window. The values that arrive within a window having the same key will be merged together and returned as an Iterable of values mapped to the key.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>window</code> - the window configuration</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="reduceByKeyAndWindow-org.apache.storm.streams.operations.Reducer-org.apache.storm.streams.windowing.Window-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>reduceByKeyAndWindow</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;reduceByKeyAndWindow(<a href="../../../../org/apache/storm/streams/operations/Reducer.html" title="interface in org.apache.storm.streams.operations">Reducer</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;reducer,
<a href="../../../../org/apache/storm/streams/windowing/Window.html" title="interface in org.apache.storm.streams.windowing">Window</a>&lt;?,?&gt;&nbsp;window)</pre>
<div class="block"><p>Returns a new stream where the values that arrive within a window having the same key will be reduced by repeatedly applying the reducer.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>reducer</code> - the reducer</dd>
<dd><code>window</code> - the window configuration</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="peek-org.apache.storm.streams.operations.Consumer-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>peek</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;peek(<a href="../../../../org/apache/storm/streams/operations/Consumer.html" title="interface in org.apache.storm.streams.operations">Consumer</a>&lt;? super <a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;&nbsp;action)</pre>
<div class="block"><p><p>Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as they are consumed from the resulting stream.</p></p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Overrides:</span></dt>
<dd><code><a href="../../../../org/apache/storm/streams/Stream.html#peek-org.apache.storm.streams.operations.Consumer-">peek</a></code>&nbsp;in class&nbsp;<code><a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">Stream</a>&lt;<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;</code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>action</code> - the action to perform on the element as they are consumed from the stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="filter-org.apache.storm.streams.operations.Predicate-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>filter</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;filter(<a href="../../../../org/apache/storm/streams/operations/Predicate.html" title="interface in org.apache.storm.streams.operations">Predicate</a>&lt;? super <a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;&nbsp;predicate)</pre>
<div class="block"><p><p>Returns a stream consisting of the elements of this stream that matches the given filter.</p></p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Overrides:</span></dt>
<dd><code><a href="../../../../org/apache/storm/streams/Stream.html#filter-org.apache.storm.streams.operations.Predicate-">filter</a></code>&nbsp;in class&nbsp;<code><a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">Stream</a>&lt;<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;</code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>predicate</code> - the predicate to apply to each element to determine if it should be included</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="join-org.apache.storm.streams.PairStream-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>join</h4>
<pre>public&nbsp;&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,V1&gt;&gt;&nbsp;join(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</pre>
<div class="block"><p>Join the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this stream is carried forward to the joined stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="join-org.apache.storm.streams.PairStream-org.apache.storm.streams.operations.ValueJoiner-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>join</h4>
<pre>public&nbsp;&lt;R,V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;join(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream,
<a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations">ValueJoiner</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? super V1,? extends R&gt;&nbsp;valueJoiner)</pre>
<div class="block"><p>Join the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this stream is carried forward to the joined stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>valueJoiner</code> - the <a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations"><code>ValueJoiner</code></a></dd>
<dd><code>R</code> - the type of the values resulting from the join</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="leftOuterJoin-org.apache.storm.streams.PairStream-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>leftOuterJoin</h4>
<pre>public&nbsp;&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,V1&gt;&gt;&nbsp;leftOuterJoin(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</pre>
<div class="block"><p>Does a left outer join of the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this stream is carried forward to the joined stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="leftOuterJoin-org.apache.storm.streams.PairStream-org.apache.storm.streams.operations.ValueJoiner-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>leftOuterJoin</h4>
<pre>public&nbsp;&lt;R,V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;leftOuterJoin(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream,
<a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations">ValueJoiner</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? super V1,? extends R&gt;&nbsp;valueJoiner)</pre>
<div class="block"><p>Does a left outer join of the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this stream is carried forward to the joined stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>valueJoiner</code> - the <a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations"><code>ValueJoiner</code></a></dd>
<dd><code>R</code> - the type of the values resulting from the join</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="rightOuterJoin-org.apache.storm.streams.PairStream-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>rightOuterJoin</h4>
<pre>public&nbsp;&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,V1&gt;&gt;&nbsp;rightOuterJoin(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</pre>
<div class="block"><p>Does a right outer join of the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this stream is carried forward to the joined stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="rightOuterJoin-org.apache.storm.streams.PairStream-org.apache.storm.streams.operations.ValueJoiner-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>rightOuterJoin</h4>
<pre>public&nbsp;&lt;R,V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;rightOuterJoin(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream,
<a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations">ValueJoiner</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? super V1,? extends R&gt;&nbsp;valueJoiner)</pre>
<div class="block"><p>Does a right outer join of the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this stream is carried forward to the joined stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>valueJoiner</code> - the <a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations"><code>ValueJoiner</code></a></dd>
<dd><code>R</code> - the type of the values resulting from the join</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="fullOuterJoin-org.apache.storm.streams.PairStream-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>fullOuterJoin</h4>
<pre>public&nbsp;&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,V1&gt;&gt;&nbsp;fullOuterJoin(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</pre>
<div class="block"><p>Does a full outer join of the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this stream is carried forward to the joined stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="fullOuterJoin-org.apache.storm.streams.PairStream-org.apache.storm.streams.operations.ValueJoiner-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>fullOuterJoin</h4>
<pre>public&nbsp;&lt;R,V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;fullOuterJoin(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream,
<a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations">ValueJoiner</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? super V1,? extends R&gt;&nbsp;valueJoiner)</pre>
<div class="block"><p>Does a full outer join of the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this stream is carried forward to the joined stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>valueJoiner</code> - the <a href="../../../../org/apache/storm/streams/operations/ValueJoiner.html" title="interface in org.apache.storm.streams.operations"><code>ValueJoiner</code></a></dd>
<dd><code>R</code> - the type of the values resulting from the join</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="window-org.apache.storm.streams.windowing.Window-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>window</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;window(<a href="../../../../org/apache/storm/streams/windowing/Window.html" title="interface in org.apache.storm.streams.windowing">Window</a>&lt;?,?&gt;&nbsp;window)</pre>
<div class="block"><p><p>Returns a new stream consisting of the elements that fall within the window as specified by the window parameter. The <a href="../../../../org/apache/storm/streams/windowing/Window.html" title="interface in org.apache.storm.streams.windowing"><code>Window</code></a> specification could be used to specify sliding or tumbling windows based on time duration or event count. For example, <pre> // time duration based sliding window stream.window(SlidingWindows.of(Duration.minutes(10), Duration.minutes(1));</p><p>// count based sliding window stream.window(SlidingWindows.of(Count.(10), Count.of(2)));</p><p>// time duration based tumbling window stream.window(TumblingWindows.of(Duration.seconds(10)); </pre></p></p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Overrides:</span></dt>
<dd><code><a href="../../../../org/apache/storm/streams/Stream.html#window-org.apache.storm.streams.windowing.Window-">window</a></code>&nbsp;in class&nbsp;<code><a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">Stream</a>&lt;<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;</code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>window</code> - the window configuration</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
<dt><span class="seeLabel">See Also:</span></dt>
<dd><a href="../../../../org/apache/storm/streams/windowing/SlidingWindows.html" title="class in org.apache.storm.streams.windowing"><code>SlidingWindows</code></a>,
<a href="../../../../org/apache/storm/streams/windowing/TumblingWindows.html" title="class in org.apache.storm.streams.windowing"><code>TumblingWindows</code></a></dd>
</dl>
</li>
</ul>
<a name="repartition-int-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>repartition</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&nbsp;repartition(int&nbsp;parallelism)</pre>
<div class="block"><p><p>Returns a new stream with the given value of parallelism. Further operations on this stream would execute at this level of parallelism.</p></p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Overrides:</span></dt>
<dd><code><a href="../../../../org/apache/storm/streams/Stream.html#repartition-int-">repartition</a></code>&nbsp;in class&nbsp;<code><a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">Stream</a>&lt;<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;</code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>parallelism</code> - the parallelism value</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
<a name="branch-org.apache.storm.streams.operations.Predicate...-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>branch</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;[]&nbsp;branch(<a href="../../../../org/apache/storm/streams/operations/Predicate.html" title="interface in org.apache.storm.streams.operations">Predicate</a>&lt;? super <a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;...&nbsp;predicates)</pre>
<div class="block"><p><p>Returns an array of streams by splitting the given stream into multiple branches based on the given predicates. The predicates are applied in the given order to the values of this stream and the result is forwarded to the corresponding (index based) result stream based on the (index of) predicate that matches. <p> <b>Note:</b> If none of the predicates match a value, that value is dropped. </p></p></p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Overrides:</span></dt>
<dd><code><a href="../../../../org/apache/storm/streams/Stream.html#branch-org.apache.storm.streams.operations.Predicate...-">branch</a></code>&nbsp;in class&nbsp;<code><a href="../../../../org/apache/storm/streams/Stream.html" title="class in org.apache.storm.streams">Stream</a>&lt;<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;&gt;</code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>predicates</code> - the predicates</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>an array of result streams (branches) corresponding to the given predicates</dd>
</dl>
</li>
</ul>
<a name="updateStateByKey-java.lang.Object-org.apache.storm.streams.operations.BiFunction-">
<!-- -->
</a><a name="updateStateByKey-R-org.apache.storm.streams.operations.BiFunction-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>updateStateByKey</h4>
<pre>public&nbsp;&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/StreamState.html" title="class in org.apache.storm.streams">StreamState</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;updateStateByKey(R&nbsp;initialValue,
<a href="../../../../org/apache/storm/streams/operations/BiFunction.html" title="interface in org.apache.storm.streams.operations">BiFunction</a>&lt;? super R,? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;stateUpdateFn)</pre>
<div class="block"><p>Update the state by applying the given state update function to the previous state of the key and the new value for the key. This internally uses <a href="../../../../org/apache/storm/topology/IStatefulBolt.html" title="interface in org.apache.storm.topology"><code>IStatefulBolt</code></a> to save the state. Use <a href="../../../../org/apache/storm/Config.html#TOPOLOGY_STATE_PROVIDER"><code>Config.TOPOLOGY_STATE_PROVIDER</code></a> to choose the state implementation.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>stateUpdateFn</code> - the state update function</dd>
<dd><code>R</code> - the result type</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the <a href="../../../../org/apache/storm/streams/StreamState.html" title="class in org.apache.storm.streams"><code>StreamState</code></a> which can be used to query the state</dd>
</dl>
</li>
</ul>
<a name="updateStateByKey-org.apache.storm.streams.operations.StateUpdater-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>updateStateByKey</h4>
<pre>public&nbsp;&lt;R&gt;&nbsp;<a href="../../../../org/apache/storm/streams/StreamState.html" title="class in org.apache.storm.streams">StreamState</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,R&gt;&nbsp;updateStateByKey(<a href="../../../../org/apache/storm/streams/operations/StateUpdater.html" title="interface in org.apache.storm.streams.operations">StateUpdater</a>&lt;? super <a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>,? extends R&gt;&nbsp;stateUpdater)</pre>
<div class="block"><p>Update the state by applying the given state update function to the previous state of the key and the new value for the key. This internally uses <a href="../../../../org/apache/storm/topology/IStatefulBolt.html" title="interface in org.apache.storm.topology"><code>IStatefulBolt</code></a> to save the state. Use <a href="../../../../org/apache/storm/Config.html#TOPOLOGY_STATE_PROVIDER"><code>Config.TOPOLOGY_STATE_PROVIDER</code></a> to choose the state implementation.</p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>stateUpdater</code> - the state updater</dd>
<dd><code>R</code> - the result type</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the <a href="../../../../org/apache/storm/streams/StreamState.html" title="class in org.apache.storm.streams"><code>StreamState</code></a> which can be used to query the state</dd>
</dl>
</li>
</ul>
<a name="coGroupByKey-org.apache.storm.streams.PairStream-">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>coGroupByKey</h4>
<pre>public&nbsp;&lt;V1&gt;&nbsp;<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,<a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams">Pair</a>&lt;<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">V</a>&gt;,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a>&lt;V1&gt;&gt;&gt;&nbsp;coGroupByKey(<a href="../../../../org/apache/storm/streams/PairStream.html" title="class in org.apache.storm.streams">PairStream</a>&lt;<a href="../../../../org/apache/storm/streams/PairStream.html" title="type parameter in PairStream">K</a>,V1&gt;&nbsp;otherStream)</pre>
<div class="block"><p>Groups the values of this stream with the values having the same key from the other stream. <p> If stream1 has values - (k1, v1), (k2, v2), (k2, v3) <br/> and stream2 has values - (k1, x1), (k1, x2), (k3, x3) <br/> The the co-grouped stream would contain - (k1, ([v1], [x1, x2]), (k2, ([v2, v3], [])), (k3, ([], [x3])) </p> <p> Note: The parallelism of this stream is carried forward to the co-grouped stream. </p></p></div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other stream</dd>
<dd><code>V1</code> - the type of the values in the other stream</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the new stream</dd>
</dl>
</li>
</ul>
</li>
</ul>
</li>
</ul>
</div>
</div>
<!-- ========= END OF CLASS DATA ========= -->
<!-- ======= START OF BOTTOM NAVBAR ====== -->
<div class="bottomNav"><a name="navbar.bottom">
<!-- -->
</a>
<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
<a name="navbar.bottom.firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="../../../../overview-summary.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
<li><a href="class-use/PairStream.html">Use</a></li>
<li><a href="package-tree.html">Tree</a></li>
<li><a href="../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../index-all.html">Index</a></li>
<li><a href="../../../../help-doc.html">Help</a></li>
</ul>
<div class="aboutLanguage"><script type="text/javascript" src="../../../../highlight.pack.js"></script>
<script type="text/javascript"><!--
hljs.initHighlightingOnLoad();
//--></script></div>
</div>
<div class="subNav">
<ul class="navList">
<li><a href="../../../../org/apache/storm/streams/Pair.html" title="class in org.apache.storm.streams"><span class="typeNameLink">Prev&nbsp;Class</span></a></li>
<li><a href="../../../../org/apache/storm/streams/ProcessorNode.html" title="class in org.apache.storm.streams"><span class="typeNameLink">Next&nbsp;Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../index.html?org/apache/storm/streams/PairStream.html" target="_top">Frames</a></li>
<li><a href="PairStream.html" target="_top">No&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_bottom");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<div>
<ul class="subNavList">
<li>Summary:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li><a href="#fields.inherited.from.class.org.apache.storm.streams.Stream">Field</a>&nbsp;|&nbsp;</li>
<li>Constr&nbsp;|&nbsp;</li>
<li><a href="#method.summary">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail:&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li>Constr&nbsp;|&nbsp;</li>
<li><a href="#method.detail">Method</a></li>
</ul>
</div>
<a name="skip.navbar.bottom">
<!-- -->
</a></div>
<!-- ======== END OF BOTTOM NAVBAR ======= -->
<p class="legalCopy"><small>Copyright &#169; 2022 <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p>
</body>
</html>