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/03 18:55:41 UTC
[kafka] branch trunk updated (fd9fdd8 -> 14c2449)
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 fd9fdd8 MINOR: Update doc for 3.1 (#11539)
add 14c2449 KAFKA-13491: IQv2 framework (#11557)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
gradle/spotbugs-exclude.xml | 8 +-
.../org/apache/kafka/streams/KafkaStreams.java | 121 ++++-
...Exception.java => StreamsStoppedException.java} | 14 +-
.../apache/kafka/streams/processor/StateStore.java | 33 ++
.../kafka/streams/processor/StateStoreContext.java | 4 +-
.../apache/kafka/streams/query/FailureReason.java | 56 +++
.../org/apache/kafka/streams/query/Position.java | 177 +++++++
.../apache/kafka/streams/query/PositionBound.java | 109 ++++
.../java/org/apache/kafka/streams/query/Query.java | 35 +-
.../apache/kafka/streams/query/QueryResult.java | 210 ++++++++
.../kafka/streams/query/StateQueryRequest.java | 225 +++++++++
.../kafka/streams/query/StateQueryResult.java | 114 +++++
.../org/apache/kafka/streams/state/Stores.java | 19 +-
.../state/internals/CachingKeyValueStore.java | 3 +-
...ava => InMemoryKeyValueBytesStoreSupplier.java} | 13 +-
.../state/internals/InMemoryKeyValueStore.java | 24 +-
.../state/internals/InMemorySessionStore.java | 18 +-
.../state/internals/InMemoryWindowStore.java | 23 +-
...ValueToTimestampedKeyValueByteStoreAdapter.java | 21 +
.../state/internals/MemoryNavigableLRUCache.java | 17 +
...PeekingKeyValueIterator.java => PingQuery.java} | 12 +-
.../kafka/streams/state/internals/Position.java | 98 ----
.../state/internals/RocksDBSessionStore.java | 18 +-
.../streams/state/internals/RocksDBStore.java | 23 +-
.../state/internals/RocksDBWindowStore.java | 20 +-
.../streams/state/internals/StoreQueryUtils.java | 65 +++
.../internals/TimestampedKeyValueStoreBuilder.java | 17 +
.../internals/TimestampedWindowStoreBuilder.java | 17 +
.../WindowToTimestampedWindowByteStoreAdapter.java | 20 +
.../streams/state/internals/WrappedStateStore.java | 19 +
.../streams/integration/IQv2IntegrationTest.java | 440 ++++++++++++++++
.../integration/IQv2StoreIntegrationTest.java | 557 +++++++++++++++++++++
.../integration/utils/IntegrationTestUtils.java | 37 ++
.../kafka/streams/query/PositionBoundTest.java | 96 ++++
.../apache/kafka/streams/query/PositionTest.java | 224 +++++++++
.../CachingInMemoryKeyValueStoreTest.java | 3 +-
.../state/internals/InMemoryKeyValueStoreTest.java | 3 +-
.../state/internals/InMemorySessionStoreTest.java | 3 +-
.../state/internals/InMemoryWindowStoreTest.java | 3 +-
.../streams/state/internals/PositionTest.java | 66 ---
.../state/internals/RocksDBSessionStoreTest.java | 3 +-
.../streams/state/internals/RocksDBStoreTest.java | 5 +-
.../state/internals/RocksDBWindowStoreTest.java | 3 +-
44 files changed, 2722 insertions(+), 276 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/errors/{StreamsNotStartedException.java => StreamsStoppedException.java} (64%)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/FailureReason.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/Position.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/PositionBound.java
copy connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java => streams/src/main/java/org/apache/kafka/streams/query/Query.java (54%)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/StateQueryRequest.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/StateQueryResult.java
copy streams/src/main/java/org/apache/kafka/streams/state/internals/{RocksDbKeyValueBytesStoreSupplier.java => InMemoryKeyValueBytesStoreSupplier.java} (70%)
copy streams/src/main/java/org/apache/kafka/streams/state/internals/{PeekingKeyValueIterator.java => PingQuery.java} (74%)
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/Position.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/IQv2IntegrationTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/query/PositionBoundTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/query/PositionTest.java
delete mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/PositionTest.java