Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

We try to avoid many overloads by not implementing all the overloaded combinations in DSLof related methods.

 

KStream

 

Code Block
languagejava
public <VT, VR> KStream<K, VR> join(final KTable<K, VT> other,
                                    final ValueJoiner<? super V, ? super VT, ? extends VR> joiner,
                                    final Joined<K, V, VT> joined,
									final RepartitionHint hintThisStream)
public <VT, VR> KStream<K, VR> leftJoin(final KTable<K, VT> other,
                                        final ValueJoiner<? super V, ? super VT, ? extends VR> joiner,
                                        final Joined<K, V, VT> joined, 
										final RepartitionHint hintThisStream)




public <VO, VR> KStream<K, VR> join(final KStream<K, VO> otherStream,
                                    final ValueJoiner<? super V, ? super VO, ? extends VR> joiner,
                                    final JoinWindows windows,
                                    final Joined<K, V, VO> joined, 
									final RepartitionHint hintThisStream,
									final RepartitionHint hintOtherStream)
 
public <V1, R> KStream<K, R> join(final KStream<K, V1> other,
                                  final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                  final JoinWindows windows,
                                  final Serde<K> keySerde,
                                  final Serde<V> thisValueSerde,
                                  final Serde<V1> otherValueSerde, 
								  final RepartitionHint hintThisStream,
								  final RepartitionHint hintOtherStream)

public <VO, VR> KStream<K, VR> outerJoin(final KStream<K, VO> other,
                                         final ValueJoiner<? super V, ? super VO, ? extends VR> joiner,
                                         final JoinWindows windows,
                                         final Joined<K, V, VO> joined,
										 final RepartitionHint hintThisStream,
									     final RepartitionHint hintOtherStream)
 
public <V1, R> KStream<K, R> leftJoin(final KStream<K, V1> other,
                                      final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                      final JoinWindows windows,
                                      final Serde<K> keySerde,
                                      final Serde<V> thisValSerde,
                                      final Serde<V1> otherValueSerde, 
									  final RepartitionHint hintThisStream,
									  final RepartitionHint hintOtherStream)


public <VO, VR> KStream<K, VR> leftJoin(final KStream<K, VO> other,
                                        final ValueJoiner<? super V, ? super VO, ? extends VR> joiner,
                                        final JoinWindows windows,
                                        final Joined<K, V, VO> joined, 
										final RepartitionHint hintThisStream,
										final RepartitionHint hintOtherStream)

...