kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated (b5aa269 -> 69790a1)
Date Fri, 02 Oct 2020 23:51:14 GMT
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%)


Mime
View raw message