blob: 804f0ea2749e8311f44e0a63d4a83bc5f59f351b [file] [log] [blame]
<!DOCTYPE HTML>
<html lang="en">
<head>
<!-- Generated by javadoc (17) -->
<title>org.apache.kafka.streams.kstream Class Hierarchy (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="tree: package: org.apache.kafka.streams.kstream">
<meta name="generator" content="javadoc/PackageTreeWriter">
<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-tree-page">
<script type="text/javascript">var pathtoroot = "../../../../../";
loadScripts(document, 'script');</script>
<noscript>
<div>JavaScript is disabled on your browser.</div>
</noscript>
<div class="flex-box">
<header role="banner" class="flex-header">
<nav role="navigation">
<!-- ========= START OF TOP NAVBAR ======= -->
<div class="top-nav" id="navbar-top">
<div class="skip-nav"><a href="#skip-navbar-top" title="Skip navigation links">Skip navigation links</a></div>
<ul id="navbar-top-firstrow" class="nav-list" title="Navigation">
<li><a href="../../../../../index.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li>Class</li>
<li class="nav-bar-cell1-rev">Tree</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#tree">Help</a></li>
</ul>
</div>
<div class="sub-nav">
<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 class="title">Hierarchy For Package org.apache.kafka.streams.kstream</h1>
<span class="package-hierarchy-label">Package Hierarchies:</span>
<ul class="horizontal">
<li><a href="../../../../../overview-tree.html">All Packages</a></li>
</ul>
</div>
<section class="hierarchy">
<h2 title="Class Hierarchy">Class Hierarchy</h2>
<ul>
<li class="circle">java.lang.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html" class="type-name-link external-link" title="class or interface in java.lang">Object</a>
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Branched.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Branched</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Consumed.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Consumed</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ForeachProcessor.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">ForeachProcessor</a>&lt;K,<wbr>V&gt; (implements org.apache.kafka.streams.processor.api.<a href="../processor/api/Processor.html" title="interface in org.apache.kafka.streams.processor.api">Processor</a>&lt;KIn,<wbr>VIn,<wbr>KOut,<wbr>VOut&gt;)</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Grouped.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Grouped</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Joined.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Joined</a>&lt;K,<wbr>V,<wbr>VO&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Materialized.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Materialized</a>&lt;K,<wbr>V,<wbr>S&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Named.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Named</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Printed.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Printed</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Produced.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Produced</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Repartitioned.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Repartitioned</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.common.serialization.<a href="../../common/serialization/Serdes.WrapperSerde.html" class="type-name-link" title="class in org.apache.kafka.common.serialization">Serdes.WrapperSerde</a>&lt;T&gt; (implements org.apache.kafka.common.serialization.<a href="../../common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a>&lt;T&gt;)
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="WindowedSerdes.SessionWindowedSerde.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">WindowedSerdes.SessionWindowedSerde</a>&lt;T&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="WindowedSerdes.TimeWindowedSerde.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">WindowedSerdes.TimeWindowedSerde</a>&lt;T&gt;</li>
</ul>
</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="SessionWindowedDeserializer.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">SessionWindowedDeserializer</a>&lt;T&gt; (implements org.apache.kafka.common.serialization.<a href="../../common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization">Deserializer</a>&lt;T&gt;)</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="SessionWindowedSerializer.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">SessionWindowedSerializer</a>&lt;T&gt; (implements org.apache.kafka.streams.kstream.internals.WindowedSerializer&lt;T&gt;)</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="SessionWindows.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">SessionWindows</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="SlidingWindows.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">SlidingWindows</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="StreamJoined.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">StreamJoined</a>&lt;K,<wbr>V1,<wbr>V2&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="TableJoined.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">TableJoined</a>&lt;K,<wbr>KO&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="TimeWindowedDeserializer.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">TimeWindowedDeserializer</a>&lt;T&gt; (implements org.apache.kafka.common.serialization.<a href="../../common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization">Deserializer</a>&lt;T&gt;)</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="TimeWindowedSerializer.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">TimeWindowedSerializer</a>&lt;T&gt; (implements org.apache.kafka.streams.kstream.internals.WindowedSerializer&lt;T&gt;)</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Window.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Window</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Windowed.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Windowed</a>&lt;K&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="WindowedSerdes.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">WindowedSerdes</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Windows.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">Windows</a>&lt;W&gt;
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="JoinWindows.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">JoinWindows</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="TimeWindows.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">TimeWindows</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="UnlimitedWindows.html" class="type-name-link" title="class in org.apache.kafka.streams.kstream">UnlimitedWindows</a></li>
</ul>
</li>
</ul>
</li>
</ul>
</section>
<section class="hierarchy">
<h2 title="Interface Hierarchy">Interface Hierarchy</h2>
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Aggregator.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Aggregator</a>&lt;K,<wbr>V,<wbr>VA&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="BranchedKStream.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">BranchedKStream</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="CogroupedKStream.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">CogroupedKStream</a>&lt;K,<wbr>VOut&gt;</li>
<li class="circle">org.apache.kafka.streams.processor.<a href="../processor/ConnectedStoreProvider.html" class="type-name-link" title="interface in org.apache.kafka.streams.processor">ConnectedStoreProvider</a>
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="TransformerSupplier.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">TransformerSupplier</a>&lt;K,<wbr>V,<wbr>R&gt; (also extends java.util.function.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/function/Supplier.html" title="class or interface in java.util.function" class="external-link">Supplier</a>&lt;T&gt;)</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueTransformerSupplier.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueTransformerSupplier</a>&lt;V,<wbr>VR&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueTransformerWithKeySupplier.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueTransformerWithKeySupplier</a>&lt;K,<wbr>V,<wbr>VR&gt; (also extends java.util.function.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/function/Supplier.html" title="class or interface in java.util.function" class="external-link">Supplier</a>&lt;T&gt;)</li>
</ul>
</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="EmitStrategy.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">EmitStrategy</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ForeachAction.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ForeachAction</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="GlobalKTable.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">GlobalKTable</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Initializer.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Initializer</a>&lt;VA&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="KeyValueMapper.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a>&lt;K,<wbr>V,<wbr>VR&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="KGroupedStream.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">KGroupedStream</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="KGroupedTable.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">KGroupedTable</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="KStream.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">KStream</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="KTable.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">KTable</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Merger.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Merger</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.NamedOperation&lt;T&gt;
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Suppressed.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Suppressed</a>&lt;K&gt;</li>
</ul>
</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Predicate.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Predicate</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Reducer.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Reducer</a>&lt;V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="SessionWindowedCogroupedKStream.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">SessionWindowedCogroupedKStream</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="SessionWindowedKStream.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">SessionWindowedKStream</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">java.util.function.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/function/Supplier.html" class="type-name-link external-link" title="class or interface in java.util.function">Supplier</a>&lt;T&gt;
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="TransformerSupplier.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">TransformerSupplier</a>&lt;K,<wbr>V,<wbr>R&gt; (also extends org.apache.kafka.streams.processor.<a href="../processor/ConnectedStoreProvider.html" title="interface in org.apache.kafka.streams.processor">ConnectedStoreProvider</a>)</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueTransformerWithKeySupplier.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueTransformerWithKeySupplier</a>&lt;K,<wbr>V,<wbr>VR&gt; (also extends org.apache.kafka.streams.processor.<a href="../processor/ConnectedStoreProvider.html" title="interface in org.apache.kafka.streams.processor">ConnectedStoreProvider</a>)</li>
</ul>
</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Suppressed.BufferConfig.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Suppressed.BufferConfig</a>&lt;BC&gt;
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Suppressed.EagerBufferConfig.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Suppressed.EagerBufferConfig</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Suppressed.StrictBufferConfig.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Suppressed.StrictBufferConfig</a></li>
</ul>
</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="TimeWindowedCogroupedKStream.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">TimeWindowedCogroupedKStream</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="TimeWindowedKStream.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">TimeWindowedKStream</a>&lt;K,<wbr>V&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Transformer.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">Transformer</a>&lt;K,<wbr>V,<wbr>R&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueJoiner.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a>&lt;V1,<wbr>V2,<wbr>VR&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueJoinerWithKey.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueJoinerWithKey</a>&lt;K1,<wbr>V1,<wbr>V2,<wbr>VR&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueMapper.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueMapper</a>&lt;V,<wbr>VR&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueMapperWithKey.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueMapperWithKey</a>&lt;K,<wbr>V,<wbr>VR&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueTransformer.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueTransformer</a>&lt;V,<wbr>VR&gt;</li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="ValueTransformerWithKey.html" class="type-name-link" title="interface in org.apache.kafka.streams.kstream">ValueTransformerWithKey</a>&lt;K,<wbr>V,<wbr>VR&gt;</li>
</ul>
</section>
<section class="hierarchy">
<h2 title="Enum Class Hierarchy">Enum Class Hierarchy</h2>
<ul>
<li class="circle">java.lang.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html" class="type-name-link external-link" title="class or interface in java.lang">Object</a>
<ul>
<li class="circle">java.lang.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Enum.html" class="type-name-link external-link" title="class or interface in java.lang">Enum</a>&lt;E&gt; (implements java.lang.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Comparable.html" title="class or interface in java.lang" class="external-link">Comparable</a>&lt;T&gt;, java.lang.constant.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/constant/Constable.html" title="class or interface in java.lang.constant" class="external-link">Constable</a>, java.io.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/Serializable.html" title="class or interface in java.io" class="external-link">Serializable</a>)
<ul>
<li class="circle">org.apache.kafka.streams.kstream.<a href="EmitStrategy.StrategyType.html" class="type-name-link" title="enum class in org.apache.kafka.streams.kstream">EmitStrategy.StrategyType</a></li>
<li class="circle">org.apache.kafka.streams.kstream.<a href="Materialized.StoreType.html" class="type-name-link" title="enum class in org.apache.kafka.streams.kstream">Materialized.StoreType</a></li>
</ul>
</li>
</ul>
</li>
</ul>
</section>
</main>
</div>
</div>
</body>
</html>