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
