BaseRepartitionNode¶
BaseRepartitionNode<K, V> is an extension of the GraphNode abstraction for repartition nodes.
Implementations¶
Creating Instance¶
BaseRepartitionNode takes the following to be created:
- Node Name
- Source Name
-
ProcessorParameters - Key
Serde(Apache Kafka) - Value
Serde(Apache Kafka) - Sink Name
- Repartition Topic
- StreamPartitioner
-
InternalTopicProperties
Abstract Class
BaseRepartitionNode is an abstract class and cannot be created directly. It is created indirectly for the concrete BaseRepartitionNodes.