Class StatefulProcessorNode<K,​V>

    • Constructor Detail

      • StatefulProcessorNode

        public StatefulProcessorNode​(ProcessorParameters<K,​V> processorParameters,
                                     java.util.Set<StoreBuilder<?>> preRegisteredStores,
                                     java.util.Set<KTableValueGetterSupplier<?,​?>> valueGetterSuppliers)
        Create a node representing a stateful processor, where the named stores have already been registered.
      • StatefulProcessorNode

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

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