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
FieldsModifier and TypeFieldDescriptionprotected jadex.collection.BloomFilter
The bloom filter.The serializer function.Fields inherited from class jadex.future.IntermediateDelegationResultListener
delegate, future, undone
-
Constructor Summary
ConstructorsConstructorDescriptionDuplicateRemovalIntermediateResultListener
(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.Create a new listener.DuplicateRemovalIntermediateResultListener
(IntermediateFuture<E> future, boolean undone) Create a new listener. -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
-
Field Details
-
filter
protected jadex.collection.BloomFilter filterThe bloom filter. -
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
Create a new listener.- Parameters:
future
- The delegation target.
-
DuplicateRemovalIntermediateResultListener
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
Check results before sending them further.- Overrides:
customIntermediateResultAvailable
in classIntermediateDelegationResultListener<E>
- Parameters:
result
- The result.
-
objectToByteArray
Convert a value to a byte array.- Parameters:
value
- The value.- Returns:
- The byte array.
-