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

Class KNNProcessor<O>

java.lang.Object

de.lmu.ifi.dbs.elki.parallel.processor.KNNProcessor<O>

Type Parameters:

O - Object type

All Implemented Interfaces:

Processor

public class KNNProcessor<O>
extends Object
implements Processor

Processor to compute the kNN of each object.

Author:

Erich Schubert

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KNNProcessor.Instance<O> Instance for precomputing the kNN.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	k K parameter
(package private) KNNQuery<O>	knnq KNN query object
(package private) SharedObject<KNNList>	out Output channel to write to

Constructor Summary

Constructors

Constructor and Description
KNNProcessor(int k, KNNQuery<O> knnq) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(Processor.Instance inst) Invoke cleanup.
void	connectKNNOutput(SharedObject<KNNList> output) Connect the output channel.
KNNProcessor.Instance<O>	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

k

int k

K parameter

knnq

KNNQuery<O> knnq

KNN query object

out

SharedObject<KNNList> out

Output channel to write to

Constructor Detail

KNNProcessor

public KNNProcessor(int k,
            KNNQuery<O> knnq)

Constructor.

Parameters:

k - K parameter

knnq - Distance query to use

Method Detail

connectKNNOutput

public void connectKNNOutput(SharedObject<KNNList> output)

Connect the output channel.

Parameters:

output - Output channel

instantiate

public KNNProcessor.Instance<O> 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.