Class WriteDataStoreProcessor<T>

  • Type Parameters:
    T - data type
    All Implemented Interfaces:
    Processor

    public class WriteDataStoreProcessor<T>
    extends java.lang.Object
    implements Processor
    Output channel to store data in a WritableDataStore.
    Since:
    0.7.0
    Author:
    Erich Schubert
    • Constructor Detail

      • WriteDataStoreProcessor

        public WriteDataStoreProcessor​(WritableDataStore<T> store)
        Constructor.
        Parameters:
        store - Data store to write to
    • Method Detail

      • connectInput

        public void connectInput​(SharedObject<T> input)
        Connect the data source
        Parameters:
        input - Input