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/10/02 23:51:14 UTC
[kafka] branch trunk updated (b5aa269 -> 69790a1)
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 b5aa269 MINOR: Fix MirrorConnectorsIntegrationTest (#9341)
add 69790a1 KAFKA-10535: Split ProcessorContext into Processor/StateStore/Record Contexts (#9361)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../examples/docs/DeveloperGuideTesting.java | 23 +-
.../kafka/streams/processor/ProcessorContext.java | 5 +-
.../apache/kafka/streams/processor/StateStore.java | 31 ++-
.../kafka/streams/processor/StateStoreContext.java | 112 ++++++++++
.../kafka/streams/processor/api/Processor.java | 7 +-
.../streams/processor/api/ProcessorContext.java | 173 +++++++-------
.../apache/kafka/streams/processor/api/Record.java | 165 ++++++++++++++
.../streams/processor/api/RecordMetadata.java | 26 +--
.../internals/AbstractProcessorContext.java | 72 +++---
.../ForwardingDisabledProcessorContext.java | 2 +-
.../internals/GlobalProcessorContextImpl.java | 27 ++-
.../internals/GlobalStateManagerImpl.java | 3 +-
.../processor/internals/GlobalStateUpdateTask.java | 9 +-
.../internals/InternalApiProcessorContext.java | 119 ----------
.../internals/InternalProcessorContext.java | 5 +-
.../processor/internals/ProcessorAdapter.java | 25 ++-
.../internals/ProcessorContextAdapter.java | 235 -------------------
.../processor/internals/ProcessorContextImpl.java | 105 ++++++---
.../internals/ProcessorContextReverseAdapter.java | 248 ---------------------
.../streams/processor/internals/ProcessorNode.java | 15 +-
.../internals/ProcessorRecordContext.java | 3 +-
.../processor/internals/ProcessorStateManager.java | 3 +-
.../streams/processor/internals/SinkNode.java | 26 ++-
.../streams/processor/internals/SourceNode.java | 5 +-
...xt.java => StoreToProcessorContextAdapter.java} | 70 +++---
.../streams/processor/internals/StreamTask.java | 37 ++-
.../streams/processor/internals/ToInternal.java | 4 +
.../org/apache/kafka/streams/KafkaStreamsTest.java | 13 +-
.../apache/kafka/streams/StreamsBuilderTest.java | 5 +-
.../org/apache/kafka/streams/TopologyTest.java | 8 +-
...KStreamSessionWindowAggregateProcessorTest.java | 5 +-
.../kstream/internals/KStreamTransformTest.java | 5 +-
.../KTableSuppressProcessorMetricsTest.java | 3 +-
.../suppress/KTableSuppressProcessorTest.java | 3 +-
.../internals/AbstractProcessorContextTest.java | 46 ++--
.../internals/GlobalProcessorContextImplTest.java | 19 +-
.../processor/internals/GlobalStateTaskTest.java | 9 +-
.../internals/GlobalStreamThreadTest.java | 4 +-
.../internals/ProcessorContextImplTest.java | 2 +-
.../processor/internals/ProcessorNodeTest.java | 8 +-
.../internals/ProcessorStateManagerTest.java | 5 +-
.../processor/internals/ProcessorTopologyTest.java | 36 +--
.../streams/processor/internals/SinkNodeTest.java | 3 +-
.../processor/internals/StreamTaskTest.java | 14 +-
.../processor/internals/StreamThreadTest.java | 4 +-
.../testutil/ConsumerRecordUtil.java} | 46 ++--
.../AbstractRocksDBSegmentedBytesStoreTest.java | 13 +-
.../internals/AbstractSessionBytesStoreTest.java | 9 +-
.../internals/AbstractWindowBytesStoreTest.java | 13 +-
.../state/internals/CachingKeyValueStoreTest.java | 5 +-
.../state/internals/CachingSessionStoreTest.java | 5 +-
.../state/internals/CachingWindowStoreTest.java | 5 +-
.../ChangeLoggingKeyValueBytesStoreTest.java | 3 +-
.../ChangeLoggingSessionBytesStoreTest.java | 6 +-
...geLoggingTimestampedKeyValueBytesStoreTest.java | 3 +-
...angeLoggingTimestampedWindowBytesStoreTest.java | 6 +-
.../ChangeLoggingWindowBytesStoreTest.java | 6 +-
.../CompositeReadOnlyKeyValueStoreTest.java | 3 +-
.../internals/GlobalStateStoreProviderTest.java | 3 +-
.../state/internals/MeteredKeyValueStoreTest.java | 5 +-
.../state/internals/MeteredSessionStoreTest.java | 5 +-
.../MeteredTimestampedKeyValueStoreTest.java | 9 +-
.../MeteredTimestampedWindowStoreTest.java | 11 +-
.../state/internals/MeteredWindowStoreTest.java | 25 ++-
.../streams/state/internals/RocksDBStoreTest.java | 39 ++--
.../internals/RocksDBTimestampedStoreTest.java | 15 +-
.../state/internals/RocksDBWindowStoreTest.java | 7 +-
.../state/internals/SegmentIteratorTest.java | 5 +-
.../internals/TimeOrderedKeyValueBufferTest.java | 37 +--
.../kafka/test/InternalMockProcessorContext.java | 31 ++-
.../org/apache/kafka/test/MockApiProcessor.java | 21 +-
.../kafka/test/MockInternalProcessorContext.java | 19 ++
.../java/org/apache/kafka/test/MockProcessor.java | 8 +-
.../org/apache/kafka/test/MockProcessorNode.java | 5 +-
.../java/org/apache/kafka/test/MockSourceNode.java | 11 +-
.../apache/kafka/test/NoOpProcessorContext.java | 15 +-
.../apache/kafka/streams/TopologyTestDriver.java | 18 +-
.../streams/processor/MockProcessorContext.java | 5 +-
.../kafka/streams/TopologyTestDriverTest.java | 126 ++++++-----
80 files changed, 1102 insertions(+), 1190 deletions(-)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/StateStoreContext.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/api/Record.java
copy connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ToleranceType.java => streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java (69%)
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalApiProcessorContext.java
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java
copy streams/src/main/java/org/apache/kafka/streams/processor/internals/{ForwardingDisabledProcessorContext.java => StoreToProcessorContextAdapter.java} (60%)
copy streams/src/test/java/org/apache/kafka/streams/processor/{TimestampExtractorTest.java => internals/testutil/ConsumerRecordUtil.java} (50%)