KAFKA-10562: Properly invoke new StateStoreContext init (#9388)
* all wrapping stores should pass StateStoreContext init through to the same method on the wrapped store and not translate it to ProcessorContext init * base-level stores should handle StateStoreContext init so that callers passing a non-InternalProcessorContext implementation will be able to initialize the store * extra tests are added to verify the desired behavior Reviewers: Guozhang Wang <guozhang@apache.org>
显示
- streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorTest.java 1 个添加, 0 个删除...ka/streams/examples/wordcount/WordCountProcessorTest.java
- streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerTest.java 1 个添加, 0 个删除.../streams/examples/wordcount/WordCountTransformerTest.java
- streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java 4 个添加, 0 个删除...n/java/org/apache/kafka/streams/processor/StateStore.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java 8 个添加, 0 个删除...treams/processor/internals/AbstractReadOnlyDecorator.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java 10 个添加, 1 个删除...reams/processor/internals/AbstractReadWriteDecorator.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java 34 个添加, 0 个删除...ka/streams/processor/internals/ProcessorContextUtils.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java 1 个添加, 0 个删除...s/state/internals/AbstractRocksDBSegmentedBytesStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java 17 个添加, 4 个删除...e/kafka/streams/state/internals/CachingKeyValueStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java 10 个添加, 1 个删除...he/kafka/streams/state/internals/CachingSessionStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java 10 个添加, 6 个删除...che/kafka/streams/state/internals/CachingWindowStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java 16 个添加, 1 个删除...eams/state/internals/ChangeLoggingKeyValueBytesStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java 11 个添加, 1 个删除...reams/state/internals/ChangeLoggingSessionBytesStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java 12 个添加, 6 个删除...treams/state/internals/ChangeLoggingWindowBytesStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java 1 个添加, 0 个删除.../kafka/streams/state/internals/InMemoryKeyValueStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java 1 个添加, 0 个删除...e/kafka/streams/state/internals/InMemorySessionStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java 15 个添加, 2 个删除...ms/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java 1 个添加, 0 个删除...he/kafka/streams/state/internals/InMemoryWindowStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java 4 个添加, 4 个删除...apache/kafka/streams/state/internals/KeyValueSegment.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java 1 个添加, 1 个删除...pache/kafka/streams/state/internals/KeyValueSegments.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueByteStoreAdapter.java 7 个添加, 0 个删除...ernals/KeyValueToTimestampedKeyValueByteStoreAdapter.java
加载中
想要评论请 注册 或 登录