kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated (8e9cf0e -> 09d1498)
Date Wed, 09 Sep 2020 17:37:58 GMT
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 8e9cf0e  MINOR: mirror integration tests should not call System.exit (#9200)
     add 09d1498  KAFKA-10436: Implement KIP-478 Topology changes (#9221)

No new revisions were added by this update.

Summary of changes:
 .../examples/docs/DeveloperGuideTesting.java       |  21 ++-
 .../java/org/apache/kafka/streams/Topology.java    | 142 ++++++++++++++--
 .../apache/kafka/streams/TopologyDescription.java  |   5 +-
 .../kstream/internals/InternalStreamsBuilder.java  |   4 +-
 .../streams/kstream/internals/KStreamImpl.java     |  30 ++--
 .../streams/kstream/internals/KStreamImplJoin.java |  10 +-
 .../streams/kstream/internals/KTableImpl.java      |  20 +--
 .../internals/graph/BaseJoinProcessorNode.java     |  18 +--
 .../internals/graph/BaseRepartitionNode.java       |   8 +-
 .../internals/graph/GraphGraceSearchUtil.java      |   2 +-
 .../GroupedTableOperationRepartitionNode.java      |   2 +-
 .../internals/graph/KTableKTableJoinNode.java      |  33 ++--
 .../graph/OptimizableRepartitionNode.java          |   2 +-
 .../internals/graph/ProcessorGraphNode.java        |   8 +-
 .../internals/graph/ProcessorParameters.java       |  49 +++++-
 .../internals/graph/StatefulProcessorNode.java     |  19 ++-
 .../internals/graph/StreamStreamJoinNode.java      |  34 ++--
 .../internals/graph/StreamTableJoinNode.java       |   8 +-
 .../kstream/internals/graph/StreamToTableNode.java |   6 +-
 .../internals/graph/TableProcessorNode.java        |  11 +-
 .../kstream/internals/graph/TableSourceNode.java   |  14 +-
 .../graph/UnoptimizableRepartitionNode.java        |   2 +-
 .../streams/processor/ConnectedStoreProvider.java  |   2 +-
 .../kafka/streams/processor/ProcessorContext.java  |   3 +-
 .../streams/processor/api/ProcessorContext.java    |   3 +-
 .../internals/InternalTopologyBuilder.java         |   6 +-
 .../processor/internals/ProcessorAdapter.java      |   9 ++
 .../internals/ProcessorContextAdapter.java         |   5 +-
 .../org/apache/kafka/streams/KafkaStreamsTest.java |  30 +++-
 .../apache/kafka/streams/StreamsBuilderTest.java   |   2 +-
 .../org/apache/kafka/streams/TopologyTest.java     |  37 ++---
 .../integration/RegexSourceIntegrationTest.java    |   6 +-
 .../kstream/internals/KTableFilterTest.java        |  16 +-
 .../internals/KTableKTableInnerJoinTest.java       |  16 +-
 .../internals/KTableKTableLeftJoinTest.java        |  14 +-
 .../internals/KTableKTableOuterJoinTest.java       |  14 +-
 .../kstream/internals/KTableMapValuesTest.java     |  13 +-
 .../kstream/internals/KTableSourceTest.java        |  14 +-
 ...ghAvailabilityStreamsPartitionAssignorTest.java |   6 +-
 .../internals/InternalTopologyBuilderTest.java     |  65 ++++----
 .../processor/internals/ProcessorTopologyTest.java | 180 ++++++++++++++++-----
 .../processor/internals/StreamThreadTest.java      |  77 ++++-----
 .../internals/StreamsPartitionAssignorTest.java    |  98 +++++------
 .../StreamThreadStateStoreProviderTest.java        |   4 +-
 .../kafka/streams/TopologyTestDriverTest.java      | 118 +++++++-------
 45 files changed, 742 insertions(+), 444 deletions(-)


Mime
View raw message