You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/10/12 14:36:29 UTC

[kafka] branch trunk updated (a73bf59 -> 1f8ac6e)

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 a73bf59  KAFKA-10584:IndexSearchType should use sealed trait instead of Enumeration (#9399)
     add 1f8ac6e  KAFKA-10598: Improve IQ name and type checks (#9408)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     |  21 +++-
 .../org/apache/kafka/streams/StreamsBuilder.java   |   8 +-
 .../kafka/streams/kstream/KGroupedStream.java      |  12 +-
 .../kafka/streams/kstream/KGroupedTable.java       |  10 +-
 .../kstream/SessionWindowedCogroupedKStream.java   |   4 +-
 .../streams/kstream/SessionWindowedKStream.java    |   8 +-
 .../apache/kafka/streams/kstream/Suppressed.java   |   2 +-
 .../kstream/TimeWindowedCogroupedKStream.java      |   4 +-
 .../kafka/streams/kstream/TimeWindowedKStream.java |   8 +-
 .../kstream/internals/MaterializedInternal.java    |   8 +-
 .../processor/internals/ProcessorTopology.java     |  15 ++-
 .../internals/StreamThreadStateStoreProvider.java  |  61 +++++-----
 .../org/apache/kafka/streams/TopologyTest.java     |   4 +-
 .../integration/JoinStoreIntegrationTest.java      |  23 +++-
 ...reignKeyJoinMaterializationIntegrationTest.java |  16 +--
 .../integration/QueryableStateIntegrationTest.java | 128 ++++++++++++++++++---
 .../integration/utils/IntegrationTestUtils.java    |  30 ++++-
 .../internals/InternalTopologyBuilderTest.java     |   8 ++
 .../StreamThreadStateStoreProviderTest.java        |  43 ++++---
 19 files changed, 295 insertions(+), 118 deletions(-)