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

Class DoubleMinMaxProcessor

java.lang.Object

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

All Implemented Interfaces:

Processor

public class DoubleMinMaxProcessor
extends Object
implements Processor

Sink collecting minimum and maximum values.

Author:

Erich Schubert

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	DoubleMinMaxProcessor.Instance Instance for a particular sub-channel / part of the data set.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) SharedDouble	input Input channel
(package private) DoubleMinMax	minmax The central data store.

Constructor Summary

Constructors

Constructor and Description
DoubleMinMaxProcessor() Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(Processor.Instance inst) Invoke cleanup.
void	connectInput(SharedDouble input) Connect an input channel.
DoubleMinMax	getMinMax() Get the minmax object.
DoubleMinMaxProcessor.Instance	instantiate(Executor executor) Create an instance.
protected void	merge(DoubleMinMax minmax) Merge the result of an instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

minmax

DoubleMinMax minmax

The central data store.

input

SharedDouble input

Input channel

Constructor Detail

DoubleMinMaxProcessor

public DoubleMinMaxProcessor()

Constructor.

Method Detail

connectInput

public void connectInput(SharedDouble input)

Connect an input channel.

Parameters:

input - Input channel

instantiate

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

merge

protected void merge(DoubleMinMax minmax)

Merge the result of an instance.

Parameters:

minmax - Minmax value

getMinMax

public DoubleMinMax getMinMax()

Get the minmax object.

Returns:

Minmax object