Class TableSourceNode<K,​V>


  • public class TableSourceNode<K,​V>
    extends StreamSourceNode<K,​V>
    Used to represent either a KTable source or a GlobalKTable source. A boolean flag is used to indicate if this represents a GlobalKTable a GlobalKTable