Class | Description |
---|---|
BaseRepartitionNode<K,V> | |
GlobalStoreNode | |
GraphGraceSearchUtil | |
GroupedTableOperationRepartitionNode<K,V> | |
GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> | |
KTableKTableJoinNode<K,V1,V2,VR> |
Too much specific information to generalize so the KTable-KTable join requires a specific node.
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> | |
OptimizableRepartitionNode<K,V> | |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> | |
ProcessorGraphNode<K,V> |
Used to represent any type of stateless operation:
map, mapValues, flatMap, flatMapValues, filter, filterNot, branch
|
ProcessorParameters<K,V> |
Class used to represent a
ProcessorSupplier and the name
used to register it with the InternalTopologyBuilder
Used by the Join nodes as there are several parameters, this abstraction helps
keep the number of arguments more reasonable. |
StatefulProcessorNode<K,V> | |
StateStoreNode | |
StreamsGraphNode | |
StreamSinkNode<K,V> | |
StreamSourceNode<K,V> | |
StreamStreamJoinNode<K,V1,V2,VR> |
Too much information to generalize, so Stream-Stream joins are represented by a specific node.
|
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> | |
StreamTableJoinNode<K,V> |
Represents a join between a KStream and a KTable or GlobalKTable
|
TableProcessorNode<K,V,S extends StateStore> | |
TableSourceNode<K,V,S extends StateStore> |
Used to represent either a KTable source or a GlobalKTable source.
|
TableSourceNode.TableSourceNodeBuilder<K,V,S extends StateStore> |