Package org.apache.kafka.streams.kstream.internals

Class KTableKTableJoinMerger<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger<K,V>

All Implemented Interfaces:

KTableProcessorSupplier<K,V,V>, ConnectedStoreProvider, ProcessorSupplier<K,Change<V>>

public class KTableKTableJoinMerger<K,V>
extends Object
implements KTableProcessorSupplier<K,V,V>

Method Summary

Modifier and Type	Method	Description
void	enableSendingOldValues()
Processor<K,Change<V>>	get()	Return a new Processor instance.
String	getQueryableName()
static <K,V> KTableKTableJoinMerger<K,V>	of(KTableProcessorSupplier<K,?,V> parent1, KTableProcessorSupplier<K,?,V> parent2)
static <K,V> KTableKTableJoinMerger<K,V>	of(KTableProcessorSupplier<K,?,V> parent1, KTableProcessorSupplier<K,?,V> parent2, String queryableName)
KTableValueGetterSupplier<K,V>	view()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider

stores

Method Detail

getQueryableName

public String getQueryableName()

get

public Processor<K,Change<V>> get()

Description copied from interface: ProcessorSupplier

Return a new Processor instance.

Specified by:

get in interface ProcessorSupplier<K,V>

Returns:

a new Processor instance

view

public KTableValueGetterSupplier<K,V> view()

Specified by:

view in interface KTableProcessorSupplier<K,V,V>

enableSendingOldValues

public void enableSendingOldValues()

Specified by:

enableSendingOldValues in interface KTableProcessorSupplier<K,V,V>

of

public static <K,V> KTableKTableJoinMerger<K,V> of(KTableProcessorSupplier<K,?,V> parent1,
                                                               KTableProcessorSupplier<K,?,V> parent2)

of

public static <K,V> KTableKTableJoinMerger<K,V> of(KTableProcessorSupplier<K,?,V> parent1,
                                                               KTableProcessorSupplier<K,?,V> parent2,
                                                               String queryableName)