Class StatefulProcessorNode<K,​V>

    • Constructor Detail

      • StatefulProcessorNode

        public StatefulProcessorNode​(java.lang.String nodeName,
                                     ProcessorParameters<K,​V> processorParameters,
                                     java.lang.String[] storeNames,
                                     boolean repartitionRequired)
        Create a node representing a stateful processor, where the named store has already been registered.
      • StatefulProcessorNode

        public StatefulProcessorNode​(java.lang.String nodeName,
                                     ProcessorParameters<K,​V> processorParameters,
                                     StoreBuilder<? extends StateStore> materializedKTableStoreBuilder,
                                     boolean repartitionRequired)
        Create a node representing a stateful processor, where the store needs to be built and registered as part of building this node.