AbstractStream (kafka 2.6.1.100-eep-810 API)

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 Object
```

Field Summary

Fields
Modifier and Type	Field	Description
`protected InternalStreamsBuilder`	`builder`
`protected Serde<K>`	`keySerde`
`protected String`	`name`
`protected StreamsGraphNode`	`streamsGraphNode`
`protected Set<String>`	`subTopologySourceNodes`
`protected 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()`
`Serde<K>`	`keySerde()`
`Serde<V>`	`valueSerde()`

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

Field Detail

name
```
protected final String name
```

keySerde
```
protected final Serde<K> keySerde
```

valSerde
```
protected final Serde<V> valSerde
```

subTopologySourceNodes

protected final Set<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 Serde<K> keySerde()
```

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