WriteDataStoreProcessor (ELKI: Environment for DeveLoping KDD-Applications Supported by Index-Structures)

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 a WritableDataStore.

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 source
`WriteDataStoreProcessor.Instance`	`instantiate(Executor executor)`	Create an instance.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 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 interface Processor
    
    Parameters:
    
    executor - Job executor
    
    Returns:
    
    Instance
  - cleanup
```
public void cleanup(Processor.Instance inst)
```
    Description copied from interface: Processor
    
    Invoke cleanup.
    
    Specified by:
    
    cleanup in interface Processor
    
    Parameters:
    
    inst - Instance to cleanup.