Google Git
Sign in
apache / kafka-site / refs/heads/asf-site / . / 0100 / javadoc / org / apache / kafka / streams / kstream / KTable.html
blob: 667b71102e0f50e21a7ca55df2eff3a2fb3cd5f7 [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 (version 1.7.0_80) on Thu Aug 04 13:19:28 BST 2016 -->
<title>KTable (kafka 0.10.0.1 API)</title>
<meta name="date" content="2016-08-04">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
parent.document.title="KTable (kafka 0.10.0.1 API)";
}
//-->
</script>
<noscript>
<div>JavaScript is disabled on your browser.</div>
</noscript>
<!-- ========= START OF TOP NAVBAR ======= -->
<div class="topNav"><a name="navbar_top">
<!-- -->
</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="../../../../../overview-summary.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
<li><a href="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/kafka/streams/kstream/KStreamBuilder.html" title="class in org.apache.kafka.streams.kstream"><span class="strong">Prev Class</span></a></li>
<li><a href="../../../../../org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream"><span class="strong">Next Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/kafka/streams/kstream/KTable.html" target="_top">Frames</a></li>
<li><a href="KTable.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_top");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<div>
<ul class="subNavList">
<li>Summary:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li>Field&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.kafka.streams.kstream</div>
<h2 title="Interface KTable" class="title">Interface KTable&lt;K,V&gt;</h2>
</div>
<div class="contentContainer">
<div class="description">
<ul class="blockList">
<li class="blockList">
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>K</code> - Type of primary keys</dd><dd><code>V</code> - Type of value changes</dd></dl>
<hr>
<br>
<pre>@InterfaceStability.Unstable
public interface <span class="strong">KTable&lt;K,V&gt;</span></pre>
<div class="block"><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> is an abstraction of a <i>changelog stream</i> from a primary-keyed table.
Each record in this stream is an update on the primary-keyed table with the record key as the primary key.
<p>
A <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> is either defined from one or multiple Kafka topics that are consumed message by message or
the result of a <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> transformation. An aggregation of a <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a> also yields a <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
<p>
A <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> can be transformed record by record, joined with another <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> or <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a>, or
can be re-partitioned and aggregated into a new <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.</div>
<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a></dd></dl>
</li>
</ul>
</div>
<div class="summary">
<ul class="blockList">
<li class="blockList">
<!-- ========== METHOD SUMMARY =========== -->
<ul class="blockList">
<li class="blockList"><a name="method_summary">
<!-- -->
</a>
<h3>Method Summary</h3>
<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
<caption><span>Methods</span><span class="tabEnd">&nbsp;</span></caption>
<tr>
<th class="colFirst" scope="col">Modifier and Type</th>
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#filter(org.apache.kafka.streams.kstream.Predicate)">filter</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream">Predicate</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;predicate)</code>
<div class="block">Create a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that consists of all elements of this stream which satisfy a predicate.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#filterNot(org.apache.kafka.streams.kstream.Predicate)">filterNot</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream">Predicate</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;predicate)</code>
<div class="block">Create a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that consists all elements of this stream which do not satisfy a predicate.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#foreach(org.apache.kafka.streams.kstream.ForeachAction)">foreach</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/ForeachAction.html" title="interface in org.apache.kafka.streams.kstream">ForeachAction</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;action)</code>
<div class="block">Perform an action on each element of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>&lt;K1,V1&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream">KGroupedTable</a>&lt;K1,V1&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper)">groupBy</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,<a href="../../../../../org/apache/kafka/streams/KeyValue.html" title="class in org.apache.kafka.streams">KeyValue</a>&lt;K1,V1&gt;&gt;&nbsp;selector)</code>
<div class="block">Group the records of this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> using the provided <a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><code>KeyValueMapper</code></a> and default serializers and deserializers.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>&lt;K1,V1&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream">KGroupedTable</a>&lt;K1,V1&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde)">groupBy</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,<a href="../../../../../org/apache/kafka/streams/KeyValue.html" title="class in org.apache.kafka.streams">KeyValue</a>&lt;K1,V1&gt;&gt;&nbsp;selector,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;K1&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;V1&gt;&nbsp;valueSerde)</code>
<div class="block">Group the records of this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> using the provided <a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><code>KeyValueMapper</code></a>.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>&lt;V1,R&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,R&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#join(org.apache.kafka.streams.kstream.KTable,%20org.apache.kafka.streams.kstream.ValueJoiner)">join</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,V1&gt;&nbsp;other,
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,V1,R&gt;&nbsp;joiner)</code>
<div class="block">Combine values of this stream with another <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> stream's elements of the same key using Inner Join.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>&lt;V1,R&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,R&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#leftJoin(org.apache.kafka.streams.kstream.KTable,%20org.apache.kafka.streams.kstream.ValueJoiner)">leftJoin</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,V1&gt;&nbsp;other,
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,V1,R&gt;&nbsp;joiner)</code>
<div class="block">Combine values of this stream with another <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> stream's elements of the same key using Left Join.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>&lt;V1&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,V1&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#mapValues(org.apache.kafka.streams.kstream.ValueMapper)">mapValues</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/ValueMapper.html" title="interface in org.apache.kafka.streams.kstream">ValueMapper</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,V1&gt;&nbsp;mapper)</code>
<div class="block">Create a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> by transforming the value of each element in this stream into a new value in the new stream.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>&lt;V1,R&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,R&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#outerJoin(org.apache.kafka.streams.kstream.KTable,%20org.apache.kafka.streams.kstream.ValueJoiner)">outerJoin</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,V1&gt;&nbsp;other,
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,V1,R&gt;&nbsp;joiner)</code>
<div class="block">Combine values of this stream with another <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> stream's elements of the same key using Outer Join.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#print()">print</a></strong>()</code>
<div class="block">Print the elements of this stream to <code>System.out</code>
Implementors will need to override toString for keys and values that are not of
type String, Integer etc to get meaningful information.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#print(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde)">print</a></strong>(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde)</code>
<div class="block">Print the elements of this stream to <code>System.out</code></div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#through(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String)">through</a></strong>(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde,
<a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;partitioner,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</code>
<div class="block">Materialize this stream to a topic, also creates a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> from the topic
using a customizable <a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><code>StreamPartitioner</code></a> to determine the distribution of records to partitions.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#through(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)">through</a></strong>(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</code>
<div class="block">Materialize this stream to a topic, also creates a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> from the topic.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#through(org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String)">through</a></strong>(<a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;partitioner,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</code>
<div class="block">Materialize this stream to a topic, also creates a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> from the topic using default serializers
and deserializers and a customizable <a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><code>StreamPartitioner</code></a> to determine the distribution of records to partitions.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#through(java.lang.String)">through</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</code>
<div class="block">Materialize this stream to a topic, also creates a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> from the topic
using default serializers and deserializers and producer's <code>DefaultPartitioner</code>.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#to(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String)">to</a></strong>(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde,
<a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;partitioner,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</code>
<div class="block">Materialize this stream to a topic using a customizable <a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><code>StreamPartitioner</code></a> to determine the distribution of records to partitions.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#to(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)">to</a></strong>(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</code>
<div class="block">Materialize this stream to a topic.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#to(org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String)">to</a></strong>(<a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;partitioner,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</code>
<div class="block">Materialize this stream to a topic using default serializers specified in the config
and a customizable <a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><code>StreamPartitioner</code></a> to determine the distribution of records to partitions.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#to(java.lang.String)">to</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</code>
<div class="block">Materialize this stream to a topic using default serializers specified in the config
and producer's <code>DefaultPartitioner</code>.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream">KStream</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#toStream()">toStream</a></strong>()</code>
<div class="block">Convert this stream to a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a>.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>&lt;K1&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream">KStream</a>&lt;K1,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#toStream(org.apache.kafka.streams.kstream.KeyValueMapper)">toStream</a></strong>(<a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,K1&gt;&nbsp;mapper)</code>
<div class="block">Convert this stream to a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a> using the given <a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><code>KeyValueMapper</code></a> to select
the new key.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#writeAsText(java.lang.String)">writeAsText</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;filePath)</code>
<div class="block">Write the elements of this stream to a file at the given path using default serializers and deserializers.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#writeAsText(java.lang.String,%20org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde)">writeAsText</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;filePath,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde)</code>
<div class="block">Write the elements of this stream to a file at the given path.</div>
</td>
</tr>
</table>
</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="filter(org.apache.kafka.streams.kstream.Predicate)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>filter</h4>
<pre><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;filter(<a href="../../../../../org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream">Predicate</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;predicate)</pre>
<div class="block">Create a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that consists of all elements of this stream which satisfy a predicate.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>predicate</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream"><code>Predicate</code></a></dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains only those records that satisfy the given predicate</dd></dl>
</li>
</ul>
<a name="filterNot(org.apache.kafka.streams.kstream.Predicate)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>filterNot</h4>
<pre><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;filterNot(<a href="../../../../../org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream">Predicate</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;predicate)</pre>
<div class="block">Create a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that consists all elements of this stream which do not satisfy a predicate.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>predicate</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream"><code>Predicate</code></a></dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains only those records that do not satisfy the given predicate</dd></dl>
</li>
</ul>
<a name="mapValues(org.apache.kafka.streams.kstream.ValueMapper)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>mapValues</h4>
<pre>&lt;V1&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,V1&gt;&nbsp;mapValues(<a href="../../../../../org/apache/kafka/streams/kstream/ValueMapper.html" title="interface in org.apache.kafka.streams.kstream">ValueMapper</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,V1&gt;&nbsp;mapper)</pre>
<div class="block">Create a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> by transforming the value of each element in this stream into a new value in the new stream.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>V1</code> - the value type of the new stream</dd><dt><span class="strong">Parameters:</span></dt><dd><code>mapper</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/ValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueMapper</code></a></dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains records with unmodified keys and new values of different type</dd></dl>
</li>
</ul>
<a name="print()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>print</h4>
<pre>void&nbsp;print()</pre>
<div class="block">Print the elements of this stream to <code>System.out</code>
Implementors will need to override toString for keys and values that are not of
type String, Integer etc to get meaningful information.</div>
</li>
</ul>
<a name="print(org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>print</h4>
<pre>void&nbsp;print(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde)</pre>
<div class="block">Print the elements of this stream to <code>System.out</code></div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>keySerde</code> - key serde used to send key-value pairs,
if not specified the default serde defined in the configs will be used</dd><dd><code>valSerde</code> - value serde used to send key-value pairs,
if not specified the default serde defined in the configs will be used
Implementors will need to override toString for keys and values that are not of
type String, Integer etc to get meaningful information.</dd></dl>
</li>
</ul>
<a name="writeAsText(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>writeAsText</h4>
<pre>void&nbsp;writeAsText(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;filePath)</pre>
<div class="block">Write the elements of this stream to a file at the given path using default serializers and deserializers.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>filePath</code> - name of file to write to
Implementors will need to override <code>toString</code> for keys and values that are not of
type <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang"><code>String</code></a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang"><code>Integer</code></a> etc. to get meaningful information.</dd></dl>
</li>
</ul>
<a name="writeAsText(java.lang.String, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>writeAsText</h4>
<pre>void&nbsp;writeAsText(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;filePath,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde)</pre>
<div class="block">Write the elements of this stream to a file at the given path.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>filePath</code> - name of file to write to</dd><dd><code>keySerde</code> - key serde used to send key-value pairs,
if not specified the default serde defined in the configs will be used</dd><dd><code>valSerde</code> - value serde used to send key-value pairs,
if not specified the default serde defined in the configs will be used
Implementors will need to override <code>toString</code> for keys and values that are not of
type <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang"><code>String</code></a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang"><code>Integer</code></a> etc. to get meaningful information.</dd></dl>
</li>
</ul>
<a name="through(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>through</h4>
<pre><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;through(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</pre>
<div class="block">Materialize this stream to a topic, also creates a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> from the topic
using default serializers and deserializers and producer's <code>DefaultPartitioner</code>.
This is equivalent to calling <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#to(java.lang.String)"><code>to(String)</code></a> and <a href="../../../../../org/apache/kafka/streams/kstream/KStreamBuilder.html#table(java.lang.String)"><code>KStreamBuilder.table(String)</code></a>.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>topic</code> - the topic name</dd>
<dt><span class="strong">Returns:</span></dt><dd>a new <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains the exact same records as this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a></dd></dl>
</li>
</ul>
<a name="through(org.apache.kafka.streams.processor.StreamPartitioner, java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>through</h4>
<pre><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;through(<a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;partitioner,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</pre>
<div class="block">Materialize this stream to a topic, also creates a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> from the topic using default serializers
and deserializers and a customizable <a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><code>StreamPartitioner</code></a> to determine the distribution of records to partitions.
This is equivalent to calling <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#to(java.lang.String)"><code>to(String)</code></a> and <a href="../../../../../org/apache/kafka/streams/kstream/KStreamBuilder.html#table(java.lang.String)"><code>KStreamBuilder.table(String)</code></a>.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>partitioner</code> - the function used to determine how records are distributed among partitions of the topic,
if not specified producer's <code>DefaultPartitioner</code> will be used</dd><dd><code>topic</code> - the topic name</dd>
<dt><span class="strong">Returns:</span></dt><dd>a new <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains the exact same records as this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a></dd></dl>
</li>
</ul>
<a name="through(org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde, java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>through</h4>
<pre><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;through(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</pre>
<div class="block">Materialize this stream to a topic, also creates a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> from the topic.
If <code>keySerde</code> provides a <code>org.apache.kafka.streams.kstream.internals.WindowedSerializer</code>
for the key <code>org.apache.kafka.streams.kstream.internals.WindowedStreamPartitioner</code> is used
&mdash; otherwise producer's <code>DefaultPartitioner</code> is used.
This is equivalent to calling <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#to(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)"><code>to(Serde, Serde, String)</code></a> and
<a href="../../../../../org/apache/kafka/streams/kstream/KStreamBuilder.html#table(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)"><code>KStreamBuilder.table(Serde, Serde, String)</code></a>.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>keySerde</code> - key serde used to send key-value pairs,
if not specified the default key serde defined in the configuration will be used</dd><dd><code>valSerde</code> - value serde used to send key-value pairs,
if not specified the default value serde defined in the configuration will be used</dd><dd><code>topic</code> - the topic name</dd>
<dt><span class="strong">Returns:</span></dt><dd>a new <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains the exact same records as this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a></dd></dl>
</li>
</ul>
<a name="through(org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde, org.apache.kafka.streams.processor.StreamPartitioner, java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>through</h4>
<pre><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;through(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde,
<a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;partitioner,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</pre>
<div class="block">Materialize this stream to a topic, also creates a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> from the topic
using a customizable <a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><code>StreamPartitioner</code></a> to determine the distribution of records to partitions.
This is equivalent to calling <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#to(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String)"><code>to(Serde, Serde, StreamPartitioner, String)</code></a> and
<a href="../../../../../org/apache/kafka/streams/kstream/KStreamBuilder.html#table(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)"><code>KStreamBuilder.table(Serde, Serde, String)</code></a>.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>keySerde</code> - key serde used to send key-value pairs,
if not specified the default key serde defined in the configuration will be used</dd><dd><code>valSerde</code> - value serde used to send key-value pairs,
if not specified the default value serde defined in the configuration will be used</dd><dd><code>partitioner</code> - the function used to determine how records are distributed among partitions of the topic,
if not specified and <code>keySerde</code> provides a <code>org.apache.kafka.streams.kstream.internals.WindowedSerializer</code> for the key
<code>org.apache.kafka.streams.kstream.internals.WindowedStreamPartitioner</code> will be used
&mdash; otherwise <code>DefaultPartitioner</code> will be used</dd><dd><code>topic</code> - the topic name</dd>
<dt><span class="strong">Returns:</span></dt><dd>a new <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains the exact same records as this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a></dd></dl>
</li>
</ul>
<a name="to(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>to</h4>
<pre>void&nbsp;to(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</pre>
<div class="block">Materialize this stream to a topic using default serializers specified in the config
and producer's <code>DefaultPartitioner</code>.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>topic</code> - the topic name</dd></dl>
</li>
</ul>
<a name="to(org.apache.kafka.streams.processor.StreamPartitioner, java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>to</h4>
<pre>void&nbsp;to(<a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;partitioner,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</pre>
<div class="block">Materialize this stream to a topic using default serializers specified in the config
and a customizable <a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><code>StreamPartitioner</code></a> to determine the distribution of records to partitions.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>partitioner</code> - the function used to determine how records are distributed among partitions of the topic,
if not specified producer's <code>DefaultPartitioner</code> will be used</dd><dd><code>topic</code> - the topic name</dd></dl>
</li>
</ul>
<a name="to(org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde, java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>to</h4>
<pre>void&nbsp;to(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</pre>
<div class="block">Materialize this stream to a topic. If <code>keySerde</code> provides a
<code>org.apache.kafka.streams.kstream.internals.WindowedSerializer</code> for the key
<code>org.apache.kafka.streams.kstream.internals.WindowedStreamPartitioner</code> is used
&mdash; otherwise producer's <code>DefaultPartitioner</code> is used.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>keySerde</code> - key serde used to send key-value pairs,
if not specified the default serde defined in the configs will be used</dd><dd><code>valSerde</code> - value serde used to send key-value pairs,
if not specified the default serde defined in the configs will be used</dd><dd><code>topic</code> - the topic name</dd></dl>
</li>
</ul>
<a name="to(org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde, org.apache.kafka.streams.processor.StreamPartitioner, java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>to</h4>
<pre>void&nbsp;to(<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;valSerde,
<a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;partitioner,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>&nbsp;topic)</pre>
<div class="block">Materialize this stream to a topic using a customizable <a href="../../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><code>StreamPartitioner</code></a> to determine the distribution of records to partitions.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>keySerde</code> - key serde used to send key-value pairs,
if not specified the default serde defined in the configs will be used</dd><dd><code>valSerde</code> - value serde used to send key-value pairs,
if not specified the default serde defined in the configs will be used</dd><dd><code>partitioner</code> - the function used to determine how records are distributed among partitions of the topic,
if not specified and <code>keySerde</code> provides a <code>org.apache.kafka.streams.kstream.internals.WindowedSerializer</code> for the key
<code>org.apache.kafka.streams.kstream.internals.WindowedStreamPartitioner</code> will be used
&mdash; otherwise <code>DefaultPartitioner</code> will be used</dd><dd><code>topic</code> - the topic name</dd></dl>
</li>
</ul>
<a name="toStream()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>toStream</h4>
<pre><a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream">KStream</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;toStream()</pre>
<div class="block">Convert this stream to a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a>.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a> that contains the same records as this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>;
the records are no longer treated as updates on a primary-keyed table,
but rather as normal key-value pairs in a record stream</dd></dl>
</li>
</ul>
<a name="toStream(org.apache.kafka.streams.kstream.KeyValueMapper)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>toStream</h4>
<pre>&lt;K1&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream">KStream</a>&lt;K1,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;toStream(<a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,K1&gt;&nbsp;mapper)</pre>
<div class="block">Convert this stream to a new instance of <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a> using the given <a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><code>KeyValueMapper</code></a> to select
the new key.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>K1</code> - the new key type</dd><dt><span class="strong">Parameters:</span></dt><dd><code>mapper</code> - @param mapper the instance of <a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><code>KeyValueMapper</code></a></dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a> that contains the transformed records from this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>;
the records are no longer treated as updates on a primary-keyed table,
but rather as normal key-value pairs in a record stream</dd></dl>
</li>
</ul>
<a name="join(org.apache.kafka.streams.kstream.KTable, org.apache.kafka.streams.kstream.ValueJoiner)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>join</h4>
<pre>&lt;V1,R&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,R&gt;&nbsp;join(<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,V1&gt;&nbsp;other,
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,V1,R&gt;&nbsp;joiner)</pre>
<div class="block">Combine values of this stream with another <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> stream's elements of the same key using Inner Join.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>V1</code> - the value type of the other stream</dd><dd><code>R</code> - the value type of the new stream</dd><dt><span class="strong">Parameters:</span></dt><dd><code>other</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> joined with this stream</dd><dd><code>joiner</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a></dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains join-records for each key and values computed by the given <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a>,
one for each matched record-pair with the same key</dd></dl>
</li>
</ul>
<a name="outerJoin(org.apache.kafka.streams.kstream.KTable, org.apache.kafka.streams.kstream.ValueJoiner)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>outerJoin</h4>
<pre>&lt;V1,R&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,R&gt;&nbsp;outerJoin(<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,V1&gt;&nbsp;other,
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,V1,R&gt;&nbsp;joiner)</pre>
<div class="block">Combine values of this stream with another <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> stream's elements of the same key using Outer Join.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>V1</code> - the value type of the other stream</dd><dd><code>R</code> - the value type of the new stream</dd><dt><span class="strong">Parameters:</span></dt><dd><code>other</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> joined with this stream</dd><dd><code>joiner</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a></dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains join-records for each key and values computed by the given <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a>,
one for each matched record-pair with the same key</dd></dl>
</li>
</ul>
<a name="leftJoin(org.apache.kafka.streams.kstream.KTable, org.apache.kafka.streams.kstream.ValueJoiner)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>leftJoin</h4>
<pre>&lt;V1,R&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,R&gt;&nbsp;leftJoin(<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,V1&gt;&nbsp;other,
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,V1,R&gt;&nbsp;joiner)</pre>
<div class="block">Combine values of this stream with another <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> stream's elements of the same key using Left Join.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>V1</code> - the value type of the other stream</dd><dd><code>R</code> - the value type of the new stream</dd><dt><span class="strong">Parameters:</span></dt><dd><code>other</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> joined with this stream</dd><dd><code>joiner</code> - the instance of <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a></dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that contains join-records for each key and values computed by the given <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a>,
one for each matched record-pair with the same key</dd></dl>
</li>
</ul>
<a name="groupBy(org.apache.kafka.streams.kstream.KeyValueMapper, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>groupBy</h4>
<pre>&lt;K1,V1&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream">KGroupedTable</a>&lt;K1,V1&gt;&nbsp;groupBy(<a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,<a href="../../../../../org/apache/kafka/streams/KeyValue.html" title="class in org.apache.kafka.streams">KeyValue</a>&lt;K1,V1&gt;&gt;&nbsp;selector,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;K1&gt;&nbsp;keySerde,
<a href="../../../../../org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;V1&gt;&nbsp;valueSerde)</pre>
<div class="block">Group the records of this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> using the provided <a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><code>KeyValueMapper</code></a>.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>K1</code> - the key type of the <a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KGroupedTable</code></a></dd><dd><code>V1</code> - the value type of the <a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KGroupedTable</code></a></dd><dt><span class="strong">Parameters:</span></dt><dd><code>selector</code> - select the grouping key and value to be aggregated</dd><dd><code>keySerde</code> - key serdes for materializing this stream,
if not specified the default serdes defined in the configs will be used</dd><dd><code>valueSerde</code> - value serdes for materializing this stream,
if not specified the default serdes defined in the configs will be used</dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KGroupedTable</code></a> that contains the re-partitioned records of this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a></dd></dl>
</li>
</ul>
<a name="groupBy(org.apache.kafka.streams.kstream.KeyValueMapper)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>groupBy</h4>
<pre>&lt;K1,V1&gt;&nbsp;<a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream">KGroupedTable</a>&lt;K1,V1&gt;&nbsp;groupBy(<a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>,<a href="../../../../../org/apache/kafka/streams/KeyValue.html" title="class in org.apache.kafka.streams">KeyValue</a>&lt;K1,V1&gt;&gt;&nbsp;selector)</pre>
<div class="block">Group the records of this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> using the provided <a href="../../../../../org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><code>KeyValueMapper</code></a> and default serializers and deserializers.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>K1</code> - the key type of the <a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KGroupedTable</code></a></dd><dd><code>V1</code> - the value type of the <a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KGroupedTable</code></a></dd><dt><span class="strong">Parameters:</span></dt><dd><code>selector</code> - select the grouping key and value to be aggregated</dd>
<dt><span class="strong">Returns:</span></dt><dd>a <a href="../../../../../org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KGroupedTable</code></a> that contains the re-partitioned records of this <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a></dd></dl>
</li>
</ul>
<a name="foreach(org.apache.kafka.streams.kstream.ForeachAction)">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>foreach</h4>
<pre>void&nbsp;foreach(<a href="../../../../../org/apache/kafka/streams/kstream/ForeachAction.html" title="interface in org.apache.kafka.streams.kstream">ForeachAction</a>&lt;<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">K</a>,<a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="type parameter in KTable">V</a>&gt;&nbsp;action)</pre>
<div class="block">Perform an action on each element of <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
Note that this is a terminal operation that returns void.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>action</code> - an action to perform on each element</dd></dl>
</li>
</ul>
</li>
</ul>
</li>
</ul>
</div>
</div>
<!-- ========= END OF CLASS DATA ========= -->
<!-- ======= START OF BOTTOM NAVBAR ====== -->
<div class="bottomNav"><a name="navbar_bottom">
<!-- -->
</a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="../../../../../overview-summary.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
<li><a href="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/kafka/streams/kstream/KStreamBuilder.html" title="class in org.apache.kafka.streams.kstream"><span class="strong">Prev Class</span></a></li>
<li><a href="../../../../../org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream"><span class="strong">Next Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/kafka/streams/kstream/KTable.html" target="_top">Frames</a></li>
<li><a href="KTable.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_bottom");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<div>
<ul class="subNavList">
<li>Summary:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li>Field&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 ======= -->
</body>
</html>