Package org.apache.kafka.streams.kstream.internals.graph
-
Class Summary Class Description BaseRepartitionNode<K,V> BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T extends BaseRepartitionNode<K,V>> GlobalStoreNode<K,V,S extends StateStore> 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, branchProcessorParameters<K,V> Class used to represent aProcessorSupplier
and the name used to register it with theInternalTopologyBuilder
Used by the Join nodes as there are several parameters, this abstraction helps keep the number of arguments more reasonable.StatefulProcessorNode<K,V> StateStoreNode<S extends StateStore> 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 GlobalKTableStreamToTableNode<K,V> Represents a KTable convert From KStreamTableProcessorNode<K,V> TableSourceNode<K,V> Used to represent either a KTable source or a GlobalKTable source.TableSourceNode.TableSourceNodeBuilder<K,V> UnoptimizableRepartitionNode<K,V> Repartition node that is not subject of optimization algorithmUnoptimizableRepartitionNode.UnoptimizableRepartitionNodeBuilder<K,V>