Package org.apache.kafka.streams.kstream.internals.graph
-
Class Summary 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, 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 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 GlobalKTableTableProcessorNode<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>