StreamJoinedInternal (kafka 2.6.1.100-eep-810 API)

java.lang.Object
- org.apache.kafka.streams.kstream.StreamJoined<K,V1,V2>
- - org.apache.kafka.streams.kstream.internals.StreamJoinedInternal<K,V1,V2>

public class StreamJoinedInternal<K,V1,V2>
extends StreamJoined<K,V1,V2>

Field Summary
- Fields inherited from class org.apache.kafka.streams.kstream.StreamJoined
  keySerde, name, otherStoreSupplier, otherValueSerde, storeName, thisStoreSupplier, valueSerde

Constructor Summary

Constructors
Constructor Description

StreamJoinedInternal(StreamJoined<K,V1,V2> streamJoined)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Serde<K>`	`keySerde()`
`String`	`name()`
`WindowBytesStoreSupplier`	`otherStoreSupplier()`
`Serde<V2>`	`otherValueSerde()`
`String`	`storeName()`
`WindowBytesStoreSupplier`	`thisStoreSupplier()`
`Serde<V1>`	`valueSerde()`

Methods inherited from class org.apache.kafka.streams.kstream.StreamJoined
as, toString, with, with, withKeySerde, withName, withOtherStoreSupplier, withOtherValueSerde, withStoreName, withThisStoreSupplier, withValueSerde

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamJoinedInternal

public StreamJoinedInternal(StreamJoined<K,V1,V2> streamJoined)

Method Detail

keySerde
```
public Serde<K> keySerde()
```

valueSerde
```
public Serde<V1> valueSerde()
```

otherValueSerde
```
public Serde<V2> otherValueSerde()
```

name
```
public String name()
```

storeName
```
public String storeName()
```

thisStoreSupplier

public WindowBytesStoreSupplier thisStoreSupplier()

otherStoreSupplier

public WindowBytesStoreSupplier otherStoreSupplier()