Package org.apache.kafka.streams.kstream.internals.foreignkeyjoin
-
Class Summary Class Description CombinedKey<KF,KP> CombinedKeySchema<KO,K> Factory for creating CombinedKey serializers / deserializers.ForeignJoinSubscriptionProcessorSupplier<K,KO,VO> ForeignJoinSubscriptionSendProcessorSupplier<K,KO,V> SubscriptionJoinForeignProcessorSupplier<K,KO,VO> ReceivesSubscriptionWrapper<K>
events and processes them according to their Instruction.SubscriptionResolverJoinProcessorSupplier<K,V,VO,VR> ReceivesSubscriptionResponseWrapper<VO>
events and filters out events which do not match the current hash of the primary key.SubscriptionResponseWrapper<FV> SubscriptionResponseWrapperSerde<V> SubscriptionStoreReceiveProcessorSupplier<K,KO> SubscriptionWrapper<K> SubscriptionWrapperSerde<K> -
Enum Summary Enum Description SubscriptionWrapper.Instruction