Package jadex.future

Class DuplicateRemovalIntermediateResultListener<E>

java.lang.Object

jadex.future.IntermediateDelegationResultListener<E>

jadex.future.DuplicateRemovalIntermediateResultListener<E>

All Implemented Interfaces:

IFutureCommandResultListener<Collection<E>>, IIntermediateResultListener<E>, IResultListener<Collection<E>>, IUndoneIntermediateResultListener<E>, IUndoneResultListener<Collection<E>>

public class DuplicateRemovalIntermediateResultListener<E>
extends IntermediateDelegationResultListener<E>

A result listener that filters duplicates.

Field Summary

Fields

Modifier and Type	Field	Description
protected jadex.collection.BloomFilter	filter	The bloom filter.
protected Function<Object,byte[]>	serializer	The serializer function.

Fields inherited from class jadex.future.IntermediateDelegationResultListener

delegate, future, undone

Constructor Summary

Constructors

Constructor	Description
DuplicateRemovalIntermediateResultListener(IIntermediateResultListener<E> delegate, boolean undone, Function<Object,byte[]> serializer)	Create a new listener.
DuplicateRemovalIntermediateResultListener(IIntermediateResultListener<E> delegate, Function<Object,byte[]> serializer)	Create a new listener.
DuplicateRemovalIntermediateResultListener(IntermediateFuture<E> future)	Create a new listener.
DuplicateRemovalIntermediateResultListener(IntermediateFuture<E> future, boolean undone)	Create a new listener.

Method Summary

Modifier and Type	Method	Description
void	customIntermediateResultAvailable(E result)	Check results before sending them further.
byte[]	objectToByteArray(Object value)	Convert a value to a byte array.
void	setBloomFilter(jadex.collection.BloomFilter filter)	Set the bloom filter used to find duplicates.

Methods inherited from class jadex.future.IntermediateDelegationResultListener

commandAvailable, customResultAvailable, exceptionOccurred, exceptionOccurredIfUndone, finished, finishedIfUndone, handleException, intermediateResultAvailable, intermediateResultAvailableIfUndone, maxResultCountAvailable, resultAvailable, resultAvailableIfUndone

Methods inherited from class java.lang.Object

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

Field Details

filter

protected jadex.collection.BloomFilter filter

The bloom filter.

serializer

protected Function<Object,byte[]> serializer

The serializer function.

Constructor Details

DuplicateRemovalIntermediateResultListener

public DuplicateRemovalIntermediateResultListener(IIntermediateResultListener<E> delegate,
 Function<Object,byte[]> serializer)

Create a new listener.

Parameters:

delegate - The delegation target.

DuplicateRemovalIntermediateResultListener

public DuplicateRemovalIntermediateResultListener(IIntermediateResultListener<E> delegate,
 boolean undone,
 Function<Object,byte[]> serializer)

Create a new listener.

Parameters:

delegate - The delegation target.

undone - use undone methods.

DuplicateRemovalIntermediateResultListener

public DuplicateRemovalIntermediateResultListener(IntermediateFuture<E> future)

Create a new listener.

Parameters:

future - The delegation target.

DuplicateRemovalIntermediateResultListener

public DuplicateRemovalIntermediateResultListener(IntermediateFuture<E> future,
 boolean undone)

Create a new listener.

Parameters:

future - The delegation target.

undone - use undone methods.

Method Details

setBloomFilter

public void setBloomFilter(jadex.collection.BloomFilter filter)

Set the bloom filter used to find duplicates.

Parameters:

filter - The filter.

customIntermediateResultAvailable

public void customIntermediateResultAvailable(E result)

Check results before sending them further.

Overrides:

customIntermediateResultAvailable in class IntermediateDelegationResultListener<E>

Parameters:

result - The result.

objectToByteArray

public byte[] objectToByteArray(Object value)

Convert a value to a byte array.

Parameters:

value - The value.

Returns:

The byte array.