You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/12/01 00:26:37 UTC
[kafka] branch trunk updated: KAFKA-10722: Described the types of
the used state stores (#9607)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 90bc7e9 KAFKA-10722: Described the types of the used state stores (#9607)
90bc7e9 is described below
commit 90bc7e9777343568ea130fd48613696b5f6f3ece
Author: fml2 <53...@users.noreply.github.com>
AuthorDate: Tue Dec 1 01:25:47 2020 +0100
KAFKA-10722: Described the types of the used state stores (#9607)
Reviewer: Matthias J. Sax <ma...@confluent.io>
---
docs/streams/developer-guide/dsl-api.html | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html
index 33648f3..8304c7b 100644
--- a/docs/streams/developer-guide/dsl-api.html
+++ b/docs/streams/developer-guide/dsl-api.html
@@ -870,6 +870,12 @@
<p id="streams-developer-guide-dsl-transformations-stateful-overview">Stateful transformations depend on state for processing inputs and producing outputs and require a <a class="reference internal" href="../architecture.html#streams_architecture_state"><span class="std std-ref">state store</span></a> associated with the stream processor. For example, in aggregating operations, a windowing state store is used to collect the latest aggregation results per
window. In join operations, a windowing state store is used to collect all of the records received so far within the
defined window boundary.</p>
+ <p><b>Note:</b> Following store types are used regardless of the possibly specified type (via the parameter <code class="docutils literal"><span class="pre">materialized</span></code>):
+ <ul class="simple">
+ <li>non-windowed aggregations and non-windowed KTables use <a class="reference external" href="/{{version}}/javadoc/org/apache/kafka/streams/state/TimestampedKeyValueStore.html">TimestampedKeyValueStore</a>s</li>
+ <li>time-windowed aggregations and KStream-KStream joins use <a class="reference external" href="/{{version}}/javadoc/org/apache/kafka/streams/state/TimestampedWindowStore.html">TimestampedWindowStore</a>s</li>
+ <li>session windowed aggregations use <a class="reference external" href="/{{version}}/javadoc/org/apache/kafka/streams/state/SessionStore.html">SessionStore</a>s (there is no timestamped session store as of now)</li>
+ </ul>
<p>Note, that state stores are fault-tolerant.
In case of failure, Kafka Streams guarantees to fully restore all state stores prior to resuming the processing.
See <a class="reference internal" href="../architecture.html#streams_architecture_recovery"><span class="std std-ref">Fault Tolerance</span></a> for further information.</p>