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
