[kafka] branch trunk updated (8d4bbf2 -> 2804257)

[vv...@apache.org]

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 8d4bbf2  MINOR: trivial cleanups, javadoc errors, omitted StateStore tests, etc. (#8130)
     add 2804257  KAFKA-10562: Properly invoke new StateStoreContext init (#9388)

No new revisions were added by this update.

Summary of changes:
 .../examples/wordcount/WordCountProcessorTest.java |  1 +
 .../wordcount/WordCountTransformerTest.java        |  1 +
 .../apache/kafka/streams/processor/StateStore.java |  4 ++
 .../internals/AbstractReadOnlyDecorator.java       |  8 ++++
 .../internals/AbstractReadWriteDecorator.java      | 11 ++++-
 .../processor/internals/ProcessorContextUtils.java | 34 ++++++++++++++
 .../AbstractRocksDBSegmentedBytesStore.java        |  1 +
 .../state/internals/CachingKeyValueStore.java      | 21 +++++++--
 .../state/internals/CachingSessionStore.java       | 11 ++++-
 .../state/internals/CachingWindowStore.java        | 16 ++++---
 .../internals/ChangeLoggingKeyValueBytesStore.java | 17 ++++++-
 .../internals/ChangeLoggingSessionBytesStore.java  | 12 ++++-
 .../internals/ChangeLoggingWindowBytesStore.java   | 18 +++++---
 .../state/internals/InMemoryKeyValueStore.java     |  1 +
 .../state/internals/InMemorySessionStore.java      |  1 +
 .../InMemoryTimeOrderedKeyValueBuffer.java         | 17 ++++++-
 .../state/internals/InMemoryWindowStore.java       |  1 +
 .../streams/state/internals/KeyValueSegment.java   |  8 ++--
 .../streams/state/internals/KeyValueSegments.java  |  2 +-
 ...ValueToTimestampedKeyValueByteStoreAdapter.java |  7 +++
 .../streams/state/internals/MemoryLRUCache.java    | 12 +++++
 .../state/internals/MeteredKeyValueStore.java      | 54 ++++++++++++++++++----
 .../state/internals/MeteredSessionStore.java       | 54 ++++++++++++++++++----
 .../internals/MeteredTimestampedKeyValueStore.java | 14 ++++++
 .../internals/MeteredTimestampedWindowStore.java   | 16 +++++++
 .../state/internals/MeteredWindowStore.java        | 54 ++++++++++++++++++----
 .../streams/state/internals/RocksDBStore.java      | 28 +++++++----
 .../state/internals/RocksDBWindowStore.java        | 15 ++++--
 .../internals/TimestampedKeyValueStoreBuilder.java |  7 +++
 .../state/internals/TimestampedSegment.java        |  8 ++--
 .../state/internals/TimestampedSegments.java       |  2 +-
 .../internals/TimestampedWindowStoreBuilder.java   |  7 +++
 .../WindowToTimestampedWindowByteStoreAdapter.java |  7 +++
 .../streams/state/internals/WrappedStateStore.java |  7 +++
 .../internals/GlobalProcessorContextImplTest.java  | 12 ++---
 .../internals/ProcessorContextImplTest.java        |  3 +-
 .../streams/state/KeyValueStoreTestDriver.java     |  3 +-
 .../kafka/streams/state/NoOpWindowStore.java       |  1 +
 .../state/internals/AbstractKeyValueStoreTest.java |  4 +-
 .../state/internals/CachingKeyValueStoreTest.java  | 27 ++++++++++-
 .../state/internals/CachingSessionStoreTest.java   | 28 ++++++++++-
 .../state/internals/CachingWindowStoreTest.java    | 27 ++++++++++-
 .../ChangeLoggingKeyValueBytesStoreTest.java       | 42 +++++++++++++++--
 .../ChangeLoggingSessionBytesStoreTest.java        | 21 ++++++++-
 ...geLoggingTimestampedKeyValueBytesStoreTest.java | 42 +++++++++++++++--
 ...angeLoggingTimestampedWindowBytesStoreTest.java | 21 ++++++++-
 .../ChangeLoggingWindowBytesStoreTest.java         | 21 ++++++++-
 .../internals/InMemoryKeyValueLoggedStoreTest.java |  4 +-
 .../state/internals/InMemoryKeyValueStoreTest.java |  4 +-
 .../state/internals/InMemoryLRUCacheStoreTest.java |  4 +-
 .../state/internals/KeyValueSegmentTest.java       |  2 +-
 .../state/internals/MeteredKeyValueStoreTest.java  | 38 +++++++++++++++
 .../state/internals/MeteredSessionStoreTest.java   | 38 +++++++++++++++
 .../MeteredTimestampedKeyValueStoreTest.java       | 38 +++++++++++++++
 .../MeteredTimestampedWindowStoreTest.java         | 41 ++++++++++++++++
 .../state/internals/MeteredWindowStoreTest.java    | 40 ++++++++++++++++
 .../state/internals/ReadOnlyWindowStoreStub.java   |  1 +
 .../state/internals/RocksDBKeyValueStoreTest.java  |  4 +-
 .../streams/state/internals/RocksDBStoreTest.java  | 14 +++---
 .../state/internals/TimestampedSegmentTest.java    |  2 +-
 .../kafka/test/GenericInMemoryKeyValueStore.java   |  1 +
 .../GenericInMemoryTimestampedKeyValueStore.java   |  1 +
 .../org/apache/kafka/test/MockKeyValueStore.java   |  1 +
 .../org/apache/kafka/test/NoOpReadOnlyStore.java   |  1 +
 .../kafka/test/ReadOnlySessionStoreStub.java       |  1 +
 .../streams/internals/KeyValueStoreFacade.java     |  7 +++
 .../kafka/streams/internals/WindowStoreFacade.java |  7 +++
 .../kafka/streams/MockProcessorContextTest.java    |  3 +-
 .../streams/internals/KeyValueStoreFacadeTest.java |  1 +
 .../streams/internals/WindowStoreFacadeTest.java   |  1 +
 .../wordcount/WindowedWordCountProcessorTest.java  |  4 ++
 71 files changed, 877 insertions(+), 110 deletions(-)