kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbej...@apache.org
Subject [kafka] branch trunk updated (ded1fb8 -> c87fe94)
Date Thu, 03 Oct 2019 23:00:19 GMT
This is an automated email from the ASF dual-hosted git repository.

bbejeck pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from ded1fb8  KAFKA-6290: Support casting from logical types in cast transform (#7371)
     add c87fe94  KAFKA-3705 Added a foreignKeyJoin implementation for KTable. (#5527)

No new revisions were added by this update.

Summary of changes:
 build.gradle                                       |   6 +
 checkstyle/suppressions.xml                        |  12 +-
 .../java/org/apache/kafka/common/utils/Bytes.java  |  28 +-
 .../org/apache/kafka/common/utils/BytesTest.java   |  84 +++
 .../main/scala/kafka/tools/StreamsResetter.java    |   4 +-
 .../org/apache/kafka/streams/kstream/KTable.java   |  88 +++
 .../streams/kstream/internals/KTableImpl.java      | 252 +++++++-
 .../internals/KTableSourceValueGetterSupplier.java |   6 +-
 .../CombinedKey.java}                              |  44 +-
 .../foreignkeyjoin/CombinedKeySchema.java          |  96 +++
 .../ForeignJoinSubscriptionProcessorSupplier.java  | 114 ++++
 ...reignJoinSubscriptionSendProcessorSupplier.java | 116 ++++
 .../SubscriptionJoinForeignProcessorSupplier.java  | 124 ++++
 .../SubscriptionResolverJoinProcessorSupplier.java | 107 ++++
 .../SubscriptionResponseWrapper.java               |  62 ++
 .../SubscriptionResponseWrapperSerde.java          | 124 ++++
 .../SubscriptionStoreReceiveProcessorSupplier.java | 112 ++++
 .../foreignkeyjoin/SubscriptionWrapper.java        | 111 ++++
 .../foreignkeyjoin/SubscriptionWrapperSerde.java   | 119 ++++
 .../internals/graph/BaseRepartitionNode.java       |  10 +-
 .../GroupedTableOperationRepartitionNode.java      |   3 +-
 .../KTableKTableForeignKeyJoinResolutionNode.java  |  81 +++
 .../graph/OptimizableRepartitionNode.java          |  19 +-
 .../internals/graph/ProcessorGraphNode.java        |   7 +
 .../internals/graph/StatefulProcessorNode.java     |  18 +-
 .../kstream/internals/graph/StreamSinkNode.java    |   4 +
 .../internals/InternalProcessorContext.java        |  13 +
 .../internals/InternalTopologyBuilder.java         |  45 +-
 .../state/internals/RocksDBPrefixIterator.java     |  54 ++
 .../streams/integration/ForeignKeyJoinSuite.java   |  47 ++
 ...bleForeignKeyInnerJoinMultiIntegrationTest.java | 254 ++++++++
 .../KTableKTableForeignKeyJoinIntegrationTest.java | 699 +++++++++++++++++++++
 .../foreignkeyjoin/CombinedKeySchemaTest.java      |  73 +++
 .../SubscriptionResponseWrapperSerdeTest.java      |  91 +++
 .../SubscriptionWrapperSerdeTest.java              |  86 +++
 .../state/internals/RocksDBKeyValueStoreTest.java  |   3 +-
 .../streams/state/internals/RocksDBStoreTest.java  |   2 +-
 .../streams/scala/FunctionsCompatConversions.scala |   6 +
 .../kafka/streams/scala/kstream/KTable.scala       |  38 +-
 39 files changed, 3109 insertions(+), 53 deletions(-)
 create mode 100644 clients/src/test/java/org/apache/kafka/common/utils/BytesTest.java
 copy streams/src/main/java/org/apache/kafka/streams/kstream/internals/{Change.java =>
foreignkeyjoin/CombinedKey.java} (50%)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchema.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplier.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionSendProcessorSupplier.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinForeignProcessorSupplier.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolverJoinProcessorSupplier.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableForeignKeyJoinResolutionNode.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBPrefixIterator.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/ForeignKeyJoinSuite.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchemaTest.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java


Mime
View raw message