Class AbstractStream<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.AbstractStream<K,V>
-
- Direct Known Subclasses:
CogroupedKStreamImpl
,KGroupedTableImpl
,KStreamImpl
,KTableImpl
,SessionWindowedCogroupedKStreamImpl
,SessionWindowedKStreamImpl
,TimeWindowedCogroupedKStreamImpl
,TimeWindowedKStreamImpl
public abstract class AbstractStream<K,V> extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description protected InternalStreamsBuilder
builder
protected org.apache.kafka.common.serialization.Serde<K>
keySerde
protected java.lang.String
name
protected StreamsGraphNode
streamsGraphNode
protected java.util.Set<java.lang.String>
subTopologySourceNodes
protected org.apache.kafka.common.serialization.Serde<V>
valSerde
-
Constructor Summary
Constructors Constructor Description AbstractStream(AbstractStream<K,V> stream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected InternalTopologyBuilder
internalTopologyBuilder()
org.apache.kafka.common.serialization.Serde<K>
keySerde()
org.apache.kafka.common.serialization.Serde<V>
valueSerde()
-
-
-
Field Detail
-
name
protected final java.lang.String name
-
keySerde
protected final org.apache.kafka.common.serialization.Serde<K> keySerde
-
valSerde
protected final org.apache.kafka.common.serialization.Serde<V> valSerde
-
subTopologySourceNodes
protected final java.util.Set<java.lang.String> subTopologySourceNodes
-
streamsGraphNode
protected final StreamsGraphNode streamsGraphNode
-
builder
protected final InternalStreamsBuilder builder
-
-
Constructor Detail
-
AbstractStream
public AbstractStream(AbstractStream<K,V> stream)
-
-
Method Detail
-
internalTopologyBuilder
protected InternalTopologyBuilder internalTopologyBuilder()
-
keySerde
public org.apache.kafka.common.serialization.Serde<K> keySerde()
-
valueSerde
public org.apache.kafka.common.serialization.Serde<V> valueSerde()
-
-