This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 8839514 MINOR: Small cleanups in `AlterIsr` handling logic (#9663)
add dc55be2 KAFKA-6687: restrict DSL to allow only Streams from the same
source topics (#9609)
No new revisions were added by this update.
Summary of changes:
.../streams/kstream/internals/AbstractStream.java | 10 +--
.../kstream/internals/CogroupedKStreamImpl.java | 12 +--
.../internals/CogroupedStreamAggregateBuilder.java | 20 ++---
.../internals/GroupedStreamAggregateBuilder.java | 12 +--
.../kstream/internals/InternalStreamsBuilder.java | 98 +++++++++++-----------
.../kstream/internals/KGroupedStreamImpl.java | 16 ++--
.../kstream/internals/KGroupedTableImpl.java | 10 +--
.../streams/kstream/internals/KStreamImpl.java | 60 ++++++-------
.../streams/kstream/internals/KStreamImplJoin.java | 14 ++--
.../streams/kstream/internals/KTableImpl.java | 32 +++----
.../SessionWindowedCogroupedKStreamImpl.java | 6 +-
.../internals/SessionWindowedKStreamImpl.java | 6 +-
.../SlidingWindowedCogroupedKStreamImpl.java | 6 +-
.../internals/SlidingWindowedKStreamImpl.java | 6 +-
.../TimeWindowedCogroupedKStreamImpl.java | 6 +-
.../kstream/internals/TimeWindowedKStreamImpl.java | 6 +-
.../internals/graph/BaseJoinProcessorNode.java | 2 +-
.../internals/graph/BaseRepartitionNode.java | 2 +-
.../internals/graph/GraphGraceSearchUtil.java | 18 ++--
.../{StreamsGraphNode.java => GraphNode.java} | 22 ++---
.../internals/graph/ProcessorGraphNode.java | 2 +-
.../kstream/internals/graph/SourceGraphNode.java | 74 ++++++++++++++++
.../kstream/internals/graph/StateStoreNode.java | 2 +-
.../kstream/internals/graph/StreamSinkNode.java | 2 +-
.../kstream/internals/graph/StreamSourceNode.java | 72 +++++-----------
.../internals/graph/StreamTableJoinNode.java | 2 +-
.../kstream/internals/graph/StreamToTableNode.java | 2 +-
.../internals/graph/TableProcessorNode.java | 2 +-
.../kstream/internals/graph/TableSourceNode.java | 2 +-
.../apache/kafka/streams/StreamsBuilderTest.java | 28 +++----
.../kstream/internals/AbstractStreamTest.java | 2 +-
31 files changed, 297 insertions(+), 257 deletions(-)
rename
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/{StreamsGraphNode.java
=> GraphNode.java} (85%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/SourceGraphNode.java
