| <!DOCTYPE HTML> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (17) --> |
| <title>org.apache.kafka.streams.kstream (kafka 3.6.1 API)</title> |
| <meta name="viewport" content="width=device-width, initial-scale=1"> |
| <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> |
| <meta name="description" content="declaration: package: org.apache.kafka.streams.kstream"> |
| <meta name="generator" content="javadoc/PackageWriterImpl"> |
| <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="../../../../../script-dir/jquery-ui.min.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="../../../../../jquery-ui.overrides.css" title="Style"> |
| <script type="text/javascript" src="../../../../../script.js"></script> |
| <script type="text/javascript" src="../../../../../script-dir/jquery-3.5.1.min.js"></script> |
| <script type="text/javascript" src="../../../../../script-dir/jquery-ui.min.js"></script> |
| </head> |
| <body class="package-declaration-page"> |
| <script type="text/javascript">var evenRowColor = "even-row-color"; |
| var oddRowColor = "odd-row-color"; |
| var tableTab = "table-tab"; |
| var activeTableTab = "active-table-tab"; |
| var pathtoroot = "../../../../../"; |
| loadScripts(document, 'script');</script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <div class="flex-box"> |
| <header role="banner" class="flex-header"> |
| <nav role="navigation"> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="top-nav" id="navbar-top"> |
| <div class="skip-nav"><a href="#skip-navbar-top" title="Skip navigation links">Skip navigation links</a></div> |
| <ul id="navbar-top-firstrow" class="nav-list" title="Navigation"> |
| <li><a href="../../../../../index.html">Overview</a></li> |
| <li class="nav-bar-cell1-rev">Package</li> |
| <li>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#package">Help</a></li> |
| </ul> |
| </div> |
| <div class="sub-nav"> |
| <div> |
| <ul class="sub-nav-list"> |
| <li>Package: </li> |
| <li><a href="#package-description">Description</a> | </li> |
| <li><a href="#related-package-summary">Related Packages</a> | </li> |
| <li><a href="#class-summary">Classes and Interfaces</a></li> |
| </ul> |
| </div> |
| <div class="nav-list-search"><label for="search-input">SEARCH:</label> |
| <input type="text" id="search-input" value="search" disabled="disabled"> |
| <input type="reset" id="reset-button" value="reset" disabled="disabled"> |
| </div> |
| </div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| <span class="skip-nav" id="skip-navbar-top"></span></nav> |
| </header> |
| <div class="flex-content"> |
| <main role="main"> |
| <div class="header"> |
| <h1 title="Package org.apache.kafka.streams.kstream" class="title">Package org.apache.kafka.streams.kstream</h1> |
| </div> |
| <hr> |
| <div class="package-signature">package <span class="element-name">org.apache.kafka.streams.kstream</span></div> |
| <section class="package-description" id="package-description"> |
| <div class="block">Provides a high-level programming model (DSL) to express a (stateful) data flow computation over input <a href="KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>streams</code></a> and <a href="KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>tables</code></a>. |
| Use <a href="../StreamsBuilder.html" title="class in org.apache.kafka.streams"><code>StreamsBuilder</code></a> as entry for your program.</div> |
| </section> |
| <section class="summary"> |
| <ul class="summary-list"> |
| <li> |
| <div id="related-package-summary"> |
| <div class="caption"><span>Related Packages</span></div> |
| <div class="summary-table two-column-summary"> |
| <div class="table-header col-first">Package</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-first even-row-color"><a href="../package-summary.html">org.apache.kafka.streams</a></div> |
| <div class="col-last even-row-color"> |
| <div class="block">Provides the Kafka Streams library for building streaming data applications.</div> |
| </div> |
| <div class="col-first odd-row-color"><a href="../errors/package-summary.html">org.apache.kafka.streams.errors</a></div> |
| <div class="col-last odd-row-color"> |
| <div class="block">Provides common exception classes for Streams applications.</div> |
| </div> |
| <div class="col-first even-row-color"><a href="../processor/package-summary.html">org.apache.kafka.streams.processor</a></div> |
| <div class="col-last even-row-color"> |
| <div class="block">Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.</div> |
| </div> |
| <div class="col-first odd-row-color"><a href="../query/package-summary.html">org.apache.kafka.streams.query</a></div> |
| <div class="col-last odd-row-color"> |
| <div class="block">Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.</div> |
| </div> |
| <div class="col-first even-row-color"><a href="../state/package-summary.html">org.apache.kafka.streams.state</a></div> |
| <div class="col-last even-row-color"> |
| <div class="block">Provides interfaces for managing the intermediate state of a stateful streams application.</div> |
| </div> |
| <div class="col-first odd-row-color"><a href="../test/package-summary.html">org.apache.kafka.streams.test</a></div> |
| <div class="col-last odd-row-color"> |
| <div class="block">Provides classes for testing Kafka Streams applications with mocked inputs.</div> |
| </div> |
| </div> |
| </div> |
| </li> |
| <li> |
| <div id="class-summary"> |
| <div class="table-tabs" role="tablist" aria-orientation="horizontal"><button id="class-summary-tab0" role="tab" aria-selected="true" aria-controls="class-summary.tabpanel" tabindex="0" onkeydown="switchTab(event)" onclick="show('class-summary', 'class-summary', 2)" class="active-table-tab">All Classes and Interfaces</button><button id="class-summary-tab1" role="tab" aria-selected="false" aria-controls="class-summary.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('class-summary', 'class-summary-tab1', 2)" class="table-tab">Interfaces</button><button id="class-summary-tab2" role="tab" aria-selected="false" aria-controls="class-summary.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('class-summary', 'class-summary-tab2', 2)" class="table-tab">Classes</button><button id="class-summary-tab3" role="tab" aria-selected="false" aria-controls="class-summary.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('class-summary', 'class-summary-tab3', 2)" class="table-tab">Enum Classes</button></div> |
| <div id="class-summary.tabpanel" role="tabpanel"> |
| <div class="summary-table two-column-summary" aria-labelledby="class-summary-tab0"> |
| <div class="table-header col-first">Class</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="Aggregator.html" title="interface in org.apache.kafka.streams.kstream">Aggregator</a><K,<wbr>V,<wbr>VA></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>Aggregator</code> interface for aggregating values of the given key.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="Branched.html" title="class in org.apache.kafka.streams.kstream">Branched</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">The <code>Branched</code> class is used to define the optional parameters when building branches with |
| <a href="BranchedKStream.html" title="interface in org.apache.kafka.streams.kstream"><code>BranchedKStream</code></a>.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="BranchedKStream.html" title="interface in org.apache.kafka.streams.kstream">BranchedKStream</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">Branches the records in the original stream based on the predicates supplied for the branch definitions.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="CogroupedKStream.html" title="interface in org.apache.kafka.streams.kstream">CogroupedKStream</a><K,<wbr>VOut></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>CogroupedKStream</code> is an abstraction of multiple <i>grouped</i> record streams of <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> pairs.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="Consumed.html" title="class in org.apache.kafka.streams.kstream">Consumed</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> |
| <div class="block">The <code>Consumed</code> class is used to define the optional parameters when using <a href="../StreamsBuilder.html" title="class in org.apache.kafka.streams"><code>StreamsBuilder</code></a> to |
| build instances of <a href="KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a>, <a href="KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>, and <a href="GlobalKTable.html" title="interface in org.apache.kafka.streams.kstream"><code>GlobalKTable</code></a>.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="EmitStrategy.html" title="interface in org.apache.kafka.streams.kstream">EmitStrategy</a></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">This interface controls the strategy that can be used to control how we emit results in a processor.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab3"><a href="EmitStrategy.StrategyType.html" title="enum class in org.apache.kafka.streams.kstream">EmitStrategy.StrategyType</a></div> |
| <div class="col-last even-row-color class-summary class-summary-tab3"> </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="ForeachAction.html" title="interface in org.apache.kafka.streams.kstream">ForeachAction</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>ForeachAction</code> interface for performing an action on a <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>key-value |
| pair</code></a>.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="ForeachProcessor.html" title="class in org.apache.kafka.streams.kstream">ForeachProcessor</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="GlobalKTable.html" title="interface in org.apache.kafka.streams.kstream">GlobalKTable</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>GlobalKTable</code> is an abstraction of a <i>changelog stream</i> from a primary-keyed table.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="Grouped.html" title="class in org.apache.kafka.streams.kstream">Grouped</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> |
| <div class="block">The class that is used to capture the key and value <a href="../../common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization"><code>Serde</code></a>s and set the part of name used for |
| repartition topics when performing <a href="KStream.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.Grouped)"><code>KStream.groupBy(KeyValueMapper, Grouped)</code></a>, <a href="KStream.html#groupByKey(org.apache.kafka.streams.kstream.Grouped)"><code>KStream.groupByKey(Grouped)</code></a>, or <a href="KTable.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.Grouped)"><code>KTable.groupBy(KeyValueMapper, Grouped)</code></a> operations.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="Initializer.html" title="interface in org.apache.kafka.streams.kstream">Initializer</a><VA></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>Initializer</code> interface for creating an initial value in aggregations.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="Joined.html" title="class in org.apache.kafka.streams.kstream">Joined</a><K,<wbr>V,<wbr>VO></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> |
| <div class="block">The <code>Joined</code> class represents optional params that can be passed to |
| <a href="KStream.html#join(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.Joined)"><code>KStream#join(KTable,...)</code></a> and |
| <a href="KStream.html#leftJoin(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoiner)"><code>KStream#leftJoin(KTable,...)</code></a> operations.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="JoinWindows.html" title="class in org.apache.kafka.streams.kstream">JoinWindows</a></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">The window specifications used for joins.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a><K,<wbr>V,<wbr>VR></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>KeyValueMapper</code> interface for mapping a <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>key-value pair</code></a> to a new value of arbitrary type.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="KGroupedStream.html" title="interface in org.apache.kafka.streams.kstream">KGroupedStream</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>KGroupedStream</code> is an abstraction of a <i>grouped</i> record stream of <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> pairs.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream">KGroupedTable</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>KGroupedTable</code> is an abstraction of a <i>re-grouped changelog stream</i> from a primary-keyed table, |
| usually on a different grouping key than the original primary key.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="KStream.html" title="interface in org.apache.kafka.streams.kstream">KStream</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>KStream</code> is an abstraction of a <i>record stream</i> of <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> pairs, i.e., each record is an |
| independent entity/event in the real world.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="KTable.html" title="interface in org.apache.kafka.streams.kstream">KTable</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>KTable</code> is an abstraction of a <i>changelog stream</i> from a primary-keyed table.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="Materialized.html" title="class in org.apache.kafka.streams.kstream">Materialized</a><K,<wbr>V,<wbr>S extends <a href="../processor/StateStore.html" title="interface in org.apache.kafka.streams.processor">StateStore</a>></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">Used to describe how a <a href="../processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a> should be materialized.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab3"><a href="Materialized.StoreType.html" title="enum class in org.apache.kafka.streams.kstream">Materialized.StoreType</a></div> |
| <div class="col-last even-row-color class-summary class-summary-tab3"> </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="Merger.html" title="interface in org.apache.kafka.streams.kstream">Merger</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">The interface for merging aggregate values for <a href="SessionWindows.html" title="class in org.apache.kafka.streams.kstream"><code>SessionWindows</code></a> with the given key.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="Named.html" title="class in org.apache.kafka.streams.kstream">Named</a></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="Predicate.html" title="interface in org.apache.kafka.streams.kstream">Predicate</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>Predicate</code> interface represents a predicate (boolean-valued function) of a <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> pair.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="Printed.html" title="class in org.apache.kafka.streams.kstream">Printed</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> |
| <div class="block">An object to define the options used when printing a <a href="KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a>.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="Produced.html" title="class in org.apache.kafka.streams.kstream">Produced</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">This class is used to provide the optional parameters when producing to new topics |
| using <a href="KStream.html#to(java.lang.String,org.apache.kafka.streams.kstream.Produced)"><code>KStream.to(String, Produced)</code></a>.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="Reducer.html" title="interface in org.apache.kafka.streams.kstream">Reducer</a><V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>Reducer</code> interface for combining two values of the same type into a new value.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="Repartitioned.html" title="class in org.apache.kafka.streams.kstream">Repartitioned</a><K,<wbr>V></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">This class is used to provide the optional parameters for internal repartition topics.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="SessionWindowedCogroupedKStream.html" title="interface in org.apache.kafka.streams.kstream">SessionWindowedCogroupedKStream</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>SessionWindowedCogroupKStream</code> is an abstraction of a <i>windowed</i> record stream of <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> pairs.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="SessionWindowedDeserializer.html" title="class in org.apache.kafka.streams.kstream">SessionWindowedDeserializer</a><T></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="SessionWindowedKStream.html" title="interface in org.apache.kafka.streams.kstream">SessionWindowedKStream</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>SessionWindowedKStream</code> is an abstraction of a <i>windowed</i> record stream of <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> pairs.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="SessionWindowedSerializer.html" title="class in org.apache.kafka.streams.kstream">SessionWindowedSerializer</a><T></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="SessionWindows.html" title="class in org.apache.kafka.streams.kstream">SessionWindows</a></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> |
| <div class="block">A session based window specification used for aggregating events into sessions.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="SlidingWindows.html" title="class in org.apache.kafka.streams.kstream">SlidingWindows</a></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">A sliding window used for aggregating events.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="StreamJoined.html" title="class in org.apache.kafka.streams.kstream">StreamJoined</a><K,<wbr>V1,<wbr>V2></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> |
| <div class="block">Class used to configure the name of the join processor, the repartition topic name, |
| state stores or state store names in Stream-Stream join.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="Suppressed.html" title="interface in org.apache.kafka.streams.kstream">Suppressed</a><K></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="Suppressed.BufferConfig.html" title="interface in org.apache.kafka.streams.kstream">Suppressed.BufferConfig</a><BC extends <a href="Suppressed.BufferConfig.html" title="interface in org.apache.kafka.streams.kstream">Suppressed.BufferConfig</a><BC>></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="Suppressed.EagerBufferConfig.html" title="interface in org.apache.kafka.streams.kstream">Suppressed.EagerBufferConfig</a></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">Marker interface for a buffer configuration that will strictly enforce size constraints |
| (bytes and/or number of records) on the buffer, so it is suitable for reducing duplicate |
| results downstream, but does not promise to eliminate them entirely.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="Suppressed.StrictBufferConfig.html" title="interface in org.apache.kafka.streams.kstream">Suppressed.StrictBufferConfig</a></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">Marker interface for a buffer configuration that is "strict" in the sense that it will strictly |
| enforce the time bound and never emit early.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="TableJoined.html" title="class in org.apache.kafka.streams.kstream">TableJoined</a><K,<wbr>KO></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">The <code>TableJoined</code> class represents optional parameters that can be passed to |
| <a href="KTable.html#join(org.apache.kafka.streams.kstream.KTable,java.util.function.Function,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.TableJoined)"><code>KTable#join(KTable,Function,...)</code></a> and |
| <a href="KTable.html#leftJoin(org.apache.kafka.streams.kstream.KTable,java.util.function.Function,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.TableJoined)"><code>KTable#leftJoin(KTable,Function,...)</code></a> |
| operations, for foreign key joins.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="TimeWindowedCogroupedKStream.html" title="interface in org.apache.kafka.streams.kstream">TimeWindowedCogroupedKStream</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>TimeWindowedCogroupKStream</code> is an abstraction of a <i>windowed</i> record stream of <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> pairs.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="TimeWindowedDeserializer.html" title="class in org.apache.kafka.streams.kstream">TimeWindowedDeserializer</a><T></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="TimeWindowedKStream.html" title="interface in org.apache.kafka.streams.kstream">TimeWindowedKStream</a><K,<wbr>V></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block"><code>TimeWindowedKStream</code> is an abstraction of a <i>windowed</i> record stream of <a href="../KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> pairs.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="TimeWindowedSerializer.html" title="class in org.apache.kafka.streams.kstream">TimeWindowedSerializer</a><T></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="TimeWindows.html" title="class in org.apache.kafka.streams.kstream">TimeWindows</a></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> |
| <div class="block">The fixed-size time-based window specifications used for aggregations.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="Transformer.html" title="interface in org.apache.kafka.streams.kstream">Transformer</a><K,<wbr>V,<wbr>R></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>Transformer</code> interface is for stateful mapping of an input record to zero, one, or multiple new output |
| records (both key and value type can be altered arbitrarily).</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="TransformerSupplier.html" title="interface in org.apache.kafka.streams.kstream">TransformerSupplier</a><K,<wbr>V,<wbr>R></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">A <code>TransformerSupplier</code> interface which can create one or more <a href="Transformer.html" title="interface in org.apache.kafka.streams.kstream"><code>Transformer</code></a> instances.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="UnlimitedWindows.html" title="class in org.apache.kafka.streams.kstream">UnlimitedWindows</a></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">The unlimited window specifications used for aggregations.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a><V1,<wbr>V2,<wbr>VR></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>ValueJoiner</code> interface for joining two values into a new value of arbitrary type.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="ValueJoinerWithKey.html" title="interface in org.apache.kafka.streams.kstream">ValueJoinerWithKey</a><K1,<wbr>V1,<wbr>V2,<wbr>VR></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>ValueJoinerWithKey</code> interface for joining two values into a new value of arbitrary type.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="ValueMapper.html" title="interface in org.apache.kafka.streams.kstream">ValueMapper</a><V,<wbr>VR></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>ValueMapper</code> interface for mapping a value to a new value of arbitrary type.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="ValueMapperWithKey.html" title="interface in org.apache.kafka.streams.kstream">ValueMapperWithKey</a><K,<wbr>V,<wbr>VR></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>ValueMapperWithKey</code> interface for mapping a value to a new value of arbitrary type.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="ValueTransformer.html" title="interface in org.apache.kafka.streams.kstream">ValueTransformer</a><V,<wbr>VR></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>ValueTransformer</code> interface for stateful mapping of a value to a new value (with possible new type).</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="ValueTransformerSupplier.html" title="interface in org.apache.kafka.streams.kstream">ValueTransformerSupplier</a><V,<wbr>VR></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">A <code>ValueTransformerSupplier</code> interface which can create one or more <a href="ValueTransformer.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueTransformer</code></a> instances.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab1"><a href="ValueTransformerWithKey.html" title="interface in org.apache.kafka.streams.kstream">ValueTransformerWithKey</a><K,<wbr>V,<wbr>VR></div> |
| <div class="col-last even-row-color class-summary class-summary-tab1"> |
| <div class="block">The <code>ValueTransformerWithKey</code> interface for stateful mapping of a value to a new value (with possible new type).</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab1"><a href="ValueTransformerWithKeySupplier.html" title="interface in org.apache.kafka.streams.kstream">ValueTransformerWithKeySupplier</a><K,<wbr>V,<wbr>VR></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab1"> |
| <div class="block">A <code>ValueTransformerWithKeySupplier</code> interface which can create one or more <a href="ValueTransformerWithKey.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueTransformerWithKey</code></a> instances.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="Window.html" title="class in org.apache.kafka.streams.kstream">Window</a></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> |
| <div class="block">A single window instance, defined by its start and end timestamp.</div> |
| </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="Windowed.html" title="class in org.apache.kafka.streams.kstream">Windowed</a><K></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">The result key type of a windowed stream aggregation.</div> |
| </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="WindowedSerdes.html" title="class in org.apache.kafka.streams.kstream">WindowedSerdes</a></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="WindowedSerdes.SessionWindowedSerde.html" title="class in org.apache.kafka.streams.kstream">WindowedSerdes.SessionWindowedSerde</a><T></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first even-row-color class-summary class-summary-tab2"><a href="WindowedSerdes.TimeWindowedSerde.html" title="class in org.apache.kafka.streams.kstream">WindowedSerdes.TimeWindowedSerde</a><T></div> |
| <div class="col-last even-row-color class-summary class-summary-tab2"> </div> |
| <div class="col-first odd-row-color class-summary class-summary-tab2"><a href="Windows.html" title="class in org.apache.kafka.streams.kstream">Windows</a><W extends <a href="Window.html" title="class in org.apache.kafka.streams.kstream">Window</a>></div> |
| <div class="col-last odd-row-color class-summary class-summary-tab2"> |
| <div class="block">The window specification for fixed size windows that is used to define window boundaries and grace period.</div> |
| </div> |
| </div> |
| </div> |
| </div> |
| </li> |
| </ul> |
| </section> |
| </main> |
| </div> |
| </div> |
| </body> |
| </html> |
