BaseRepartitionNode (kafka 2.6.1.100-eep-810 API)

java.lang.Object
- org.apache.kafka.streams.kstream.internals.graph.StreamsGraphNode
- - org.apache.kafka.streams.kstream.internals.graph.BaseRepartitionNode<K,V>

Direct Known Subclasses:

GroupedTableOperationRepartitionNode, OptimizableRepartitionNode, UnoptimizableRepartitionNode
```
public abstract class BaseRepartitionNode<K,V>
extends StreamsGraphNode
```

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T extends BaseRepartitionNode<K,V>>

Field Summary

Fields
Modifier and Type	Field	Description
`protected InternalTopicProperties`	`internalTopicProperties`
`protected Serde<K>`	`keySerde`
`protected StreamPartitioner<K,V>`	`partitioner`
`protected ProcessorParameters<K,V>`	`processorParameters`
`protected String`	`repartitionTopic`
`protected String`	`sinkName`
`protected String`	`sourceName`
`protected Serde<V>`	`valueSerde`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

String toString()
- Methods inherited from class org.apache.kafka.streams.kstream.internals.graph.StreamsGraphNode
  addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation, writeToTopology
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

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

valueSerde
```
protected final Serde<V> valueSerde
```

sinkName
```
protected final String sinkName
```

sourceName
```
protected final String sourceName
```

repartitionTopic

protected final String repartitionTopic

processorParameters

protected final ProcessorParameters<K,V> processorParameters

partitioner

protected final StreamPartitioner<K,V> partitioner

internalTopicProperties

protected final InternalTopicProperties internalTopicProperties

Method Detail
- toString
```
public String toString()
```
  Overrides:
  
  toString in class StreamsGraphNode