Package elki.parallel.processor
Class WriteDataStoreProcessor<T>
- java.lang.Object
-
- elki.parallel.processor.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 aWritableDataStore
.- Since:
- 0.7.0
- Author:
- Erich Schubert
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
WriteDataStoreProcessor.Instance
Instance for a sub-channel.
-
Field Summary
Fields Modifier and Type Field Description (package private) SharedObject<T>
input
Input variable(package private) WritableDataStore<T>
store
Store to write to
-
Constructor Summary
Constructors Constructor Description WriteDataStoreProcessor(WritableDataStore<T> store)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cleanup(Processor.Instance inst)
Invoke cleanup.void
connectInput(SharedObject<T> input)
Connect the data sourceWriteDataStoreProcessor.Instance
instantiate(Executor executor)
Create an instance.
-
-
-
Field Detail
-
store
WritableDataStore<T> store
Store to write to
-
input
SharedObject<T> input
Input variable
-
-
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
-
instantiate
public WriteDataStoreProcessor.Instance instantiate(Executor executor)
Description copied from interface:Processor
Create an instance. May be called multiple times, for example for multiple threads.- Specified by:
instantiate
in interfaceProcessor
- Parameters:
executor
- Job executor- Returns:
- Instance
-
cleanup
public void cleanup(Processor.Instance inst)
Description copied from interface:Processor
Invoke cleanup.
-
-