kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated (71c5729 -> 0c76fbb)
Date Wed, 15 Jan 2020 19:50:09 GMT
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 71c5729  KAFKA-6144: Add KeyQueryMetadata APIs to KafkaStreams (#7960)
     add 0c76fbb  KAFKA-6144: IQ option to query standbys (#7962)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     |  59 ++++++++----
 .../streams/processor/internals/StreamThread.java  |  19 ++--
 .../state/internals/QueryableStoreProvider.java    |  22 +++--
 .../internals/StreamThreadStateStoreProvider.java  |  56 +++++++-----
 .../state/internals/WrappingStoreProvider.java     |  23 ++---
 .../integration/QueryableStateIntegrationTest.java | 101 +++++++++++++++++++--
 .../kafka/streams/integration/StoreQuerySuite.java |  49 ++++++++++
 .../integration/SuppressionIntegrationTest.java    |   2 +-
 .../processor/internals/StreamThreadTest.java      |  18 ++--
 .../CompositeReadOnlyKeyValueStoreTest.java        |  18 ++--
 .../CompositeReadOnlySessionStoreTest.java         |  15 +--
 .../CompositeReadOnlyWindowStoreTest.java          |  62 ++++++++++---
 .../internals/QueryableStoreProviderTest.java      |  18 ++--
 .../StreamThreadStateStoreProviderTest.java        |  39 ++++----
 .../state/internals/WrappingStoreProviderTest.java |   4 +-
 .../apache/kafka/test/StateStoreProviderStub.java  |  10 +-
 16 files changed, 365 insertions(+), 150 deletions(-)
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/StoreQuerySuite.java


Mime
View raw message