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

Class WriteIntegerDataStoreProcessor

java.lang.Object

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

All Implemented Interfaces:

Processor

public class WriteIntegerDataStoreProcessor
extends java.lang.Object
implements Processor

Write int values into a WritableIntegerDataStore.

Since:

0.7.0

Author:

Erich Schubert

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
(package private) SharedInteger	input Shared int variable
(package private) WritableIntegerDataStore	store Store to write to

Constructor Summary

Constructors

Constructor and Description
WriteIntegerDataStoreProcessor(WritableIntegerDataStore store) Constructor.

Method Summary

Modifier and Type	Method and Description
void	cleanup(Processor.Instance inst) Invoke cleanup.
void	connectInput(SharedInteger input) Connect the input variable
WriteIntegerDataStoreProcessor.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

WritableIntegerDataStore store

Store to write to

input

SharedInteger input

Shared int variable

Constructor Detail

WriteIntegerDataStoreProcessor

public WriteIntegerDataStoreProcessor(WritableIntegerDataStore store)

Constructor.

Parameters:

store - Data store to write to

Method Detail

connectInput

public void connectInput(SharedInteger input)

Connect the input variable

Parameters:

input - Input variable

instantiate

public WriteIntegerDataStoreProcessor.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.