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 2020/02/10 18:09:54 UTC
[kafka] branch trunk updated (3b1c613 -> d76fa1b)
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 3b1c613 KAFKA-9423: Refine layout of configuration options on website and make individual settings directly linkable (#7955)
add d76fa1b KAFKA-9487: Follow-up PR of Kafka-9445 (#8033)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 14 +++--
...eQueryParams.java => StoreQueryParameters.java} | 61 +++++++++-------------
.../internals/InternalTopologyBuilder.java | 4 ++
.../streams/processor/internals/StreamThread.java | 4 ++
.../processor/internals/StreamsMetadataState.java | 5 +-
.../state/internals/QueryableStoreProvider.java | 14 ++---
.../internals/StreamThreadStateStoreProvider.java | 57 ++++++++++++--------
.../state/internals/WrappingStoreProvider.java | 14 ++---
.../streams/integration/EosIntegrationTest.java | 4 +-
.../GlobalKTableEOSIntegrationTest.java | 10 ++--
.../integration/GlobalKTableIntegrationTest.java | 18 +++----
.../KStreamAggregationIntegrationTest.java | 4 +-
.../OptimizedKTableIntegrationTest.java | 6 +--
.../integration/QueryableStateIntegrationTest.java | 38 +++++++-------
.../integration/StoreQueryIntegrationTest.java | 60 ++++++++++-----------
.../integration/StoreUpgradeIntegrationTest.java | 22 ++++----
.../StreamStreamJoinIntegrationTest.java | 4 +-
.../internals/InternalStreamsBuilderTest.java | 4 +-
.../CompositeReadOnlyKeyValueStoreTest.java | 6 +--
.../CompositeReadOnlySessionStoreTest.java | 6 +--
.../CompositeReadOnlyWindowStoreTest.java | 6 +--
.../internals/QueryableStoreProviderTest.java | 16 +++---
.../StreamThreadStateStoreProviderTest.java | 33 ++++++------
.../state/internals/WrappingStoreProviderTest.java | 8 +--
.../apache/kafka/test/StateStoreProviderStub.java | 8 +--
25 files changed, 216 insertions(+), 210 deletions(-)
rename streams/src/main/java/org/apache/kafka/streams/{StoreQueryParams.java => StoreQueryParameters.java} (54%)