Package it.unimi.di.law.bubing.sieve

Class IdentitySieve<K,V>

java.lang.Object

it.unimi.di.law.bubing.sieve.AbstractSieve<K,V>

it.unimi.di.law.bubing.sieve.IdentitySieve<K,V>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public final class IdentitySieve<K,V>
extends AbstractSieve<K,V>

A sieve that simply (and immediately) copies enqueued keys to the new flow receiver.

Note that instances of this class call AbstractSieve.NewFlowReceiver.prepareToAppend() in the constructor only, and AbstractSieve.NewFlowReceiver.noMoreAppend() in the method close() only.

Nested Class Summary

Nested classes/interfaces inherited from class it.unimi.di.law.bubing.sieve.AbstractSieve

AbstractSieve.DefaultUpdateStrategy<K,V>, AbstractSieve.DiskNewFlow<T>, AbstractSieve.NewFlowReceiver<K>, AbstractSieve.SieveEntry<K,V>, AbstractSieve.UpdateStrategy<K,V>

Field Summary

Fields inherited from class it.unimi.di.law.bubing.sieve.AbstractSieve

CHAR_SEQUENCE_HASHING_STRATEGY, hashingStrategy, keySerDeser, newFlowReceiver, updateStrategy, valueSerDeser

Constructor Summary

Constructors

Constructor	Description
IdentitySieve(AbstractSieve.NewFlowReceiver<K> newFlowReceiver, ByteSerializerDeserializer<K> keySerDeser, ByteSerializerDeserializer<V> valueSerDeser, it.unimi.dsi.sux4j.mph.AbstractHashFunction<K> hashingStrategy, AbstractSieve.UpdateStrategy<K,V> updateStrategy)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes (forever) this sieve.
boolean	enqueue(K key, V value)	Add the given (key,value) pair to the store.
void	flush()	Forces the check+update of all pairs that have been enqueued.

Methods inherited from class it.unimi.di.law.bubing.sieve.AbstractSieve

setNewFlowRecevier

Methods inherited from class java.lang.Object

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

Constructor Detail

IdentitySieve

public IdentitySieve(AbstractSieve.NewFlowReceiver<K> newFlowReceiver,
                     ByteSerializerDeserializer<K> keySerDeser,
                     ByteSerializerDeserializer<V> valueSerDeser,
                     it.unimi.dsi.sux4j.mph.AbstractHashFunction<K> hashingStrategy,
                     AbstractSieve.UpdateStrategy<K,V> updateStrategy)
              throws java.io.IOException

Throws:

java.io.IOException

Method Detail

enqueue

public boolean enqueue(K key,
                       V value)
                throws java.io.IOException

Description copied from class: AbstractSieve

Add the given (key,value) pair to the store.

Specified by:

enqueue in class AbstractSieve<K,V>

Returns:

true if the operation caused a flush.

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Description copied from class: AbstractSieve

Closes (forever) this sieve.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in class AbstractSieve<K,V>

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException,
                  java.lang.InterruptedException

Description copied from class: AbstractSieve

Forces the check+update of all pairs that have been enqueued.

Specified by:

flush in class AbstractSieve<K,V>

Throws:

java.io.IOException

java.lang.InterruptedException