Page History

public class StreamJoined<K, V1, V2> implements NamedOperation<StreamJoined<K, V1, V2>> {

public static <K, V1, V2> StreamJoined<K, V1, V2> with(final WindowBytesStoreSupplier storeSupplier,
                                                       final WindowBytesStoreSupplier otherSupplier){}

public static <K, V1, V2> StreamJoined<K, V1, V2> as(final String storeName) {}

public static <K, V1, V2> StreamJoined<K, V1, V2> with(final Serde<K> keySerde,
                                                       final Serde<V1> valueSerde,
                                                       final Serde<V2> otherValueSerde) {}
 // The withName method will name the process and provide the base name 
 // for any repartition topics if required

 public StreamJoined<K, V1, V2> withName(final String name) {}

 // The withStoreName is used as the base name for stores provided by Kafka Streams
 // If users provide state store suppliers, then the name in the store supplier is used
 public StreamJoined<K, V1, V2> withStoreName(final String storeName) {}

 public StreamJoined<K, V1, V2> withKeySerde(final Serde<K> keySerde) {}

 public StreamJoined<K, V1, V2> withValueSerde(final Serde<V1> valueSerde) {}

 public StreamJoined<K, V1, V2> withOtherValueSerde(final Serde<V2> otherValueSerde) {}

 public StreamJoined<K, V1, V2> withStoreSupplierwithThisStoreSupplier(final WindowBytesStoreSupplier storeSupplier) {}

 public StreamJoined<K, V1, V2> withOtherStoreSupplier(final WindowBytesStoreSupplier otherStoreSupplier) {}