de.lmu.ifi.dbs.elki.parallel.processor

Class WriteDataStoreProcessor<T>

java.lang.Object

de.lmu.ifi.dbs.elki.parallel.processor.WriteDataStoreProcessor<T>

Type Parameters:

T - data type

All Implemented Interfaces:

Processor

public class WriteDataStoreProcessor<T>
extends Object
implements Processor

Output channel to store data in a WritableDataStore.

Author:

Erich Schubert

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	WriteDataStoreProcessor.Instance Instance for a sub-channel.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) SharedObject<T>	input Input variable
(package private) WritableDataStore<T>	store Store to write to

Constructor Summary

Constructors

Constructor and Description
WriteDataStoreProcessor(WritableDataStore<T> store) Constructor.

Method Summary

Methods

Modifier and Type	Method and 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.