You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2021/03/10 22:28:07 UTC
[kafka] branch trunk updated (8c9bc9c -> 029f5a1)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 8c9bc9c MINOR: Add entityType for metadata record definitions (#10116)
add 029f5a1 KAFKA-10062: Add a methods to retrieve the current timestamps as known by the Streams app (#9744)
No new revisions were added by this update.
Summary of changes:
.../kafka/streams/processor/ProcessorContext.java | 30 +++++
.../internals/AbstractProcessorContext.java | 7 +-
.../ForwardingDisabledProcessorContext.java | 10 ++
.../internals/GlobalProcessorContextImpl.java | 16 ++-
.../processor/internals/GlobalStreamThread.java | 3 +-
.../internals/InternalProcessorContext.java | 5 -
.../processor/internals/ProcessorContextImpl.java | 5 +
.../processor/internals/ProcessorContextUtils.java | 6 +-
.../internals/StoreToProcessorContextAdapter.java | 10 ++
.../AbstractRocksDBSegmentedBytesStore.java | 2 +-
.../state/internals/InMemoryWindowStore.java | 2 +-
...KStreamSessionWindowAggregateProcessorTest.java | 7 +-
.../internals/AbstractProcessorContextTest.java | 6 +-
.../internals/GlobalProcessorContextImplTest.java | 9 +-
.../internals/ProcessorContextImplTest.java | 10 +-
.../StoreToProcessorContextAdapterTest.java | 123 +++++++++++++++++++++
.../MeteredTimestampedWindowStoreTest.java | 4 +-
.../state/internals/MeteredWindowStoreTest.java | 4 +-
.../kafka/test/InternalMockProcessorContext.java | 37 +++++--
.../apache/kafka/test/NoOpProcessorContext.java | 10 ++
.../apache/kafka/streams/TopologyTestDriver.java | 2 +-
.../streams/processor/MockProcessorContext.java | 51 ++++++++-
.../kafka/streams/MockProcessorContextTest.java | 6 +-
.../kafka/streams/TopologyTestDriverTest.java | 3 +-
24 files changed, 326 insertions(+), 42 deletions(-)
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreToProcessorContextAdapterTest.java