Class DuplicateRemovalIntermediateResultListener<E>

    • Field Detail

      • filter

        protected BloomFilter filter
        The bloom filter.
    • Constructor Detail

      • DuplicateRemovalIntermediateResultListener

        public DuplicateRemovalIntermediateResultListener​(IIntermediateResultListener<E> delegate)
        Create a new listener.
        Parameters:
        delegate - The delegation target.
      • DuplicateRemovalIntermediateResultListener

        public DuplicateRemovalIntermediateResultListener​(IIntermediateResultListener<E> delegate,
                                                          boolean undone)
        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 Detail

      • setBloomFilter

        public void setBloomFilter​(BloomFilter filter)
        Set the bloom filter used to find duplicates.
        Parameters:
        filter - The filter.
      • objectToByteArray

        public byte[] objectToByteArray​(java.lang.Object value)
        Convert a value to a byte array.
        Parameters:
        value - The value.
        Returns:
        The byte array.