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 2020/05/27 17:57:50 UTC
[kafka] branch trunk updated (99115cb -> 075bbcf)
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 99115cb KAFKA-9561: Update task input partitions after rebalance (#8221)
add 075bbcf KAFKA-7523: Add ConnectedStoreProvider to Processor API (#6824)
No new revisions were added by this update.
Summary of changes:
docs/streams/developer-guide/dsl-api.html | 15 +-
docs/streams/developer-guide/processor-api.html | 54 +-
docs/streams/upgrade-guide.html | 7 +
.../examples/wordcount/WordCountProcessorDemo.java | 2 -
...ssorDemo.java => WordCountTransformerDemo.java} | 62 +-
.../examples/wordcount/WordCountProcessorTest.java | 3 +-
...ssorTest.java => WordCountTransformerTest.java} | 38 +-
.../java/org/apache/kafka/streams/Topology.java | 10 +
.../org/apache/kafka/streams/kstream/KStream.java | 1137 ++++++++++++++------
.../kafka/streams/kstream/TransformerSupplier.java | 4 +-
.../streams/kstream/ValueTransformerSupplier.java | 4 +-
.../kstream/ValueTransformerWithKeySupplier.java | 4 +-
.../streams/kstream/internals/AbstractStream.java | 45 +-
.../kstream/internals/KStreamFlatTransform.java | 8 +
.../internals/KStreamFlatTransformValues.java | 8 +
.../streams/kstream/internals/KStreamImpl.java | 2 +-
.../kstream/internals/KStreamTransformValues.java | 8 +
.../internals/TransformerSupplierAdapter.java | 7 +
.../internals/graph/StatefulProcessorNode.java | 6 +
.../streams/processor/ConnectedStoreProvider.java | 117 ++
.../kafka/streams/processor/ProcessorSupplier.java | 2 +-
.../internals/InternalTopologyBuilder.java | 5 +-
.../processor/internals/ProcessorContextImpl.java | 3 +-
.../org/apache/kafka/streams/TopologyTest.java | 36 +-
.../KStreamTransformIntegrationTest.java | 456 +++++---
.../internals/TransformerSupplierAdapterTest.java | 15 +
.../internals/InternalTopologyBuilderTest.java | 21 +-
.../processor/internals/ProcessorTopologyTest.java | 77 ++
28 files changed, 1575 insertions(+), 581 deletions(-)
copy streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/{WordCountProcessorDemo.java => WordCountTransformerDemo.java} (73%)
copy streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/{WordCountProcessorTest.java => WordCountTransformerTest.java} (63%)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/ConnectedStoreProvider.java