public abstract class AbstractStream<K,V>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected InternalStreamsBuilder |
builder |
protected org.apache.kafka.common.serialization.Serde<K> |
keySerde |
protected java.lang.String |
name |
protected java.util.Set<java.lang.String> |
sourceNodes |
protected StreamsGraphNode |
streamsGraphNode |
protected org.apache.kafka.common.serialization.Serde<V> |
valSerde |
Constructor and Description |
---|
AbstractStream(AbstractStream<K,V> stream) |
Modifier and Type | Method and Description |
---|---|
protected InternalTopologyBuilder |
internalTopologyBuilder() |
org.apache.kafka.common.serialization.Serde<K> |
keySerde() |
org.apache.kafka.common.serialization.Serde<V> |
valueSerde() |
protected final java.lang.String name
protected final org.apache.kafka.common.serialization.Serde<K> keySerde
protected final org.apache.kafka.common.serialization.Serde<V> valSerde
protected final java.util.Set<java.lang.String> sourceNodes
protected final StreamsGraphNode streamsGraphNode
protected final InternalStreamsBuilder builder
public AbstractStream(AbstractStream<K,V> stream)
protected InternalTopologyBuilder internalTopologyBuilder()
public org.apache.kafka.common.serialization.Serde<K> keySerde()
public org.apache.kafka.common.serialization.Serde<V> valueSerde()