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