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 184b8918717 KAFKA-16524; Metrics for KIP-853 (#18304)
add 0d1e7e04b2a KAFKA-18644: improve generic type names for KStreamImpl
and KTableImpl (#18722)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/kstream/KStream.java | 8 +-
.../org/apache/kafka/streams/kstream/KTable.java | 74 ++++----
.../streams/kstream/internals/AbstractStream.java | 8 +-
.../kstream/internals/ForeachProcessor.java | 4 +-
.../kstream/internals/KGroupedTableImpl.java | 11 +-
.../streams/kstream/internals/KStreamFilter.java | 4 +-
.../streams/kstream/internals/KStreamImpl.java | 103 ++++++-----
.../kstream/internals/KStreamKTableJoin.java | 4 +-
.../kstream/internals/KStreamMapValues.java | 4 +-
.../streams/kstream/internals/KStreamPeek.java | 4 +-
.../streams/kstream/internals/KTableFilter.java | 2 +-
.../streams/kstream/internals/KTableImpl.java | 206 +++++++++++++--------
.../kstream/internals/KTableRepartitionMap.java | 20 +-
.../foreignkeyjoin/ForeignKeyExtractor.java | 4 +-
.../ResponseJoinProcessorSupplier.java | 8 +-
.../SubscriptionSendProcessorSupplier.java | 6 +-
.../internals/graph/BaseRepartitionNode.java | 33 ++--
.../GroupedTableOperationRepartitionNode.java | 7 +-
.../graph/OptimizableRepartitionNode.java | 6 +-
.../internals/graph/StreamTableJoinNode.java | 6 +-
.../graph/UnoptimizableRepartitionNode.java | 3 +-
21 files changed, 291 insertions(+), 234 deletions(-)
