KAFKA-10535: Split ProcessorContext into Processor/StateStore/Record Contexts (#9361)
Migrate different components of the old ProcessorContext interface into separate interfaces that are more appropriate for their usages. See KIP-478 for the details. Reviewers: Guozhang Wang <guozhang@apache.org>, Paul Whalen <pgwhalen@gmail.com>
显示
- checkstyle/suppressions.xml 1 个添加, 1 个删除checkstyle/suppressions.xml
- streams/examples/src/test/java/org/apache/kafka/streams/examples/docs/DeveloperGuideTesting.java 12 个添加, 11 个删除...he/kafka/streams/examples/docs/DeveloperGuideTesting.java
- streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java 4 个添加, 1 个删除.../org/apache/kafka/streams/processor/ProcessorContext.java
- streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java 28 个添加, 3 个删除...n/java/org/apache/kafka/streams/processor/StateStore.java
- streams/src/main/java/org/apache/kafka/streams/processor/StateStoreContext.java 112 个添加, 0 个删除...org/apache/kafka/streams/processor/StateStoreContext.java
- streams/src/main/java/org/apache/kafka/streams/processor/api/Processor.java 3 个添加, 4 个删除...ava/org/apache/kafka/streams/processor/api/Processor.java
- streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java 92 个添加, 81 个删除.../apache/kafka/streams/processor/api/ProcessorContext.java
- streams/src/main/java/org/apache/kafka/streams/processor/api/Record.java 165 个添加, 0 个删除...n/java/org/apache/kafka/streams/processor/api/Record.java
- streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java 34 个添加, 0 个删除...rg/apache/kafka/streams/processor/api/RecordMetadata.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java 42 个添加, 30 个删除...streams/processor/internals/AbstractProcessorContext.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java 1 个添加, 1 个删除...ocessor/internals/ForwardingDisabledProcessorContext.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java 20 个添加, 7 个删除...reams/processor/internals/GlobalProcessorContextImpl.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java 2 个添加, 1 个删除...a/streams/processor/internals/GlobalStateManagerImpl.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java 8 个添加, 1 个删除...ka/streams/processor/internals/GlobalStateUpdateTask.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalApiProcessorContext.java 0 个添加, 119 个删除...eams/processor/internals/InternalApiProcessorContext.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java 4 个添加, 1 个删除...streams/processor/internals/InternalProcessorContext.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java 22 个添加, 3 个删除...e/kafka/streams/processor/internals/ProcessorAdapter.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java 0 个添加, 235 个删除.../streams/processor/internals/ProcessorContextAdapter.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java 71 个添加, 34 个删除...fka/streams/processor/internals/ProcessorContextImpl.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java 9 个添加, 6 个删除...ache/kafka/streams/processor/internals/ProcessorNode.java
加载中
想要评论请 注册 或 登录