You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vv...@apache.org on 2021/12/21 01:08:04 UTC

[kafka] branch trunk updated (5747788 -> 018fb88)

This is an automated email from the ASF dual-hosted git repository.

vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 5747788  KAFKA-13525: Implement KeyQuery in Streams IQv2 (#11582)
     add 018fb88  KAFKA-13557: Remove swapResult from the public API (#11617)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/streams/query/QueryResult.java    | 115 ++++-----------------
 .../query/internals/AbstractQueryResult.java       |  80 ++++++++++++++
 .../streams/query/internals/FailedQueryResult.java |  89 ++++++++++++++++
 .../query/internals/InternalQueryResultUtil.java   |  51 +++++++++
 .../query/internals/SucceededQueryResult.java      | 102 ++++++++++++++++++
 .../state/internals/MeteredKeyValueStore.java      |  11 +-
 6 files changed, 349 insertions(+), 99 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/internals/AbstractQueryResult.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/internals/FailedQueryResult.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/internals/InternalQueryResultUtil.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/internals/SucceededQueryResult.java