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 588ea44 KAFKA-12782: Fix Javadocs generation by upgrading JDK (#10780)
add f207bac KAFKA-8410: KTableProcessor migration groundwork (#10744)
No new revisions were added by this update.
Summary of changes:
.../streams/kstream/internals/KTableFilter.java | 76 ++++++++++++----------
.../streams/kstream/internals/KTableImpl.java | 30 ++++++++-
...pplier.java => KTableNewProcessorSupplier.java} | 8 +--
.../internals/SessionCacheFlushListener.java | 29 +++++++--
.../internals/TimestampedCacheFlushListener.java | 43 +++++++++---
.../internals/TimestampedTupleForwarder.java | 32 +++++++--
.../ForeignJoinSubscriptionProcessorSupplier.java | 2 +-
.../SubscriptionStoreReceiveProcessorSupplier.java | 2 +-
.../org/apache/kafka/streams/processor/To.java | 7 ++
.../internals/AbstractProcessorContext.java | 2 +-
.../internals/GlobalProcessorContextImpl.java | 2 +-
.../processor/internals/GlobalStateUpdateTask.java | 5 +-
.../internals/InternalProcessorContext.java | 4 +-
.../internals/InternalTopologyBuilder.java | 51 ++++++++-------
.../processor/internals/ProcessorContextImpl.java | 2 +-
.../streams/processor/internals/ProcessorNode.java | 6 +-
.../processor/internals/ProcessorTopology.java | 32 ++++-----
.../processor/internals/RecordDeserializer.java | 6 +-
.../streams/processor/internals/RecordQueue.java | 6 +-
.../streams/processor/internals/SinkNode.java | 8 +--
.../streams/processor/internals/SourceNode.java | 6 +-
.../streams/processor/internals/StreamTask.java | 11 +++-
.../state/internals/CacheFlushListener.java | 8 +++
.../state/internals/MeteredKeyValueStore.java | 30 +++++++--
.../state/internals/MeteredSessionStore.java | 30 +++++++--
.../state/internals/MeteredWindowStore.java | 30 +++++++--
.../streams/kstream/internals/KStreamImplTest.java | 8 +--
...KStreamSessionWindowAggregateProcessorTest.java | 2 +-
.../kstream/internals/KTableReduceTest.java | 2 +-
.../internals/SessionCacheFlushListenerTest.java | 2 +-
.../TimestampedCacheFlushListenerTest.java | 9 +--
.../internals/TimestampedTupleForwarderTest.java | 27 ++++++--
.../internals/AbstractProcessorContextTest.java | 2 +-
.../processor/internals/GlobalStateTaskTest.java | 6 +-
.../processor/internals/ProcessorNodeTest.java | 8 +--
.../internals/ProcessorTopologyFactories.java | 2 +-
.../internals/RecordDeserializerTest.java | 2 +-
.../processor/internals/RecordQueueTest.java | 6 +-
.../streams/processor/internals/SinkNodeTest.java | 8 +--
.../processor/internals/SourceNodeTest.java | 8 +--
.../processor/internals/StreamTaskTest.java | 22 ++++---
.../streams/state/KeyValueStoreTestDriver.java | 1 +
.../state/internals/AbstractKeyValueStoreTest.java | 2 +
.../AbstractRocksDBSegmentedBytesStoreTest.java | 2 +-
.../internals/AbstractSessionBytesStoreTest.java | 3 +-
.../internals/AbstractWindowBytesStoreTest.java | 2 +-
.../state/internals/CacheFlushListenerStub.java | 12 ++++
.../CachingInMemoryKeyValueStoreTest.java | 4 +-
.../internals/CachingInMemorySessionStoreTest.java | 18 ++++-
.../CachingPersistentSessionStoreTest.java | 18 ++++-
.../CachingPersistentWindowStoreTest.java | 4 +-
.../ChangeLoggingKeyValueBytesStoreTest.java | 3 +-
...geLoggingTimestampedKeyValueBytesStoreTest.java | 3 +-
.../CompositeReadOnlyKeyValueStoreTest.java | 11 +++-
.../state/internals/InMemoryKeyValueStoreTest.java | 1 +
.../state/internals/InMemoryLRUCacheStoreTest.java | 1 +
.../state/internals/InMemoryWindowStoreTest.java | 1 +
.../state/internals/KeyValueSegmentsTest.java | 2 +-
.../MeteredTimestampedWindowStoreTest.java | 2 +-
.../state/internals/MeteredWindowStoreTest.java | 2 +-
.../streams/state/internals/RocksDBStoreTest.java | 3 +-
.../RocksDBTimeOrderedWindowStoreTest.java | 2 +-
.../state/internals/RocksDBWindowStoreTest.java | 1 +
.../state/internals/SegmentIteratorTest.java | 3 +-
.../state/internals/TimestampedSegmentsTest.java | 2 +-
.../kafka/test/InternalMockProcessorContext.java | 8 +--
.../kafka/test/MockInternalProcessorContext.java | 2 +-
.../org/apache/kafka/test/MockProcessorNode.java | 2 +-
.../java/org/apache/kafka/test/MockSourceNode.java | 4 +-
.../apache/kafka/test/NoOpProcessorContext.java | 2 +-
70 files changed, 478 insertions(+), 225 deletions(-)
copy
streams/src/main/java/org/apache/kafka/streams/kstream/internals/{KTableProcessorSupplier.java
=> KTableNewProcessorSupplier.java} (83%)
