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

Class AbstractSieve.DiskNewFlow<T>

java.lang.Object

it.unimi.di.law.bubing.sieve.AbstractSieve.DiskNewFlow<T>

All Implemented Interfaces:

AbstractSieve.NewFlowReceiver<T>

Enclosing class:

AbstractSieve<K,V>

public static final class AbstractSieve.DiskNewFlow<T>
extends java.lang.Object
implements AbstractSieve.NewFlowReceiver<T>

A basic, on-disk AbstractSieve.NewFlowReceiver.

Constructor Summary

Constructors

Constructor	Description
DiskNewFlow(ByteSerializerDeserializer<T> serializer)

Method Summary

Modifier and Type	Method	Description
void	append(long hash, T key)	A new key is appended.
MutableString	dequeueKey()	Returns the next key in the flow of new pairs remained after the check, and discards the corresponding value.
void	finishedAppending()	The new flow of keys is over.
void	noMoreAppend()	There will be no more new flows (because the sieve that is calling this method was closed).
void	prepareToAppend()	A new flow of keys is ready and will start being appended.
long	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

DiskNewFlow

public DiskNewFlow(ByteSerializerDeserializer<T> serializer)
            throws java.io.IOException

Throws:

java.io.IOException

Method Detail

size

public long size()

prepareToAppend

public void prepareToAppend()
                     throws java.io.IOException

Description copied from interface: AbstractSieve.NewFlowReceiver

A new flow of keys is ready and will start being appended.

Specified by:

prepareToAppend in interface AbstractSieve.NewFlowReceiver<T>

Throws:

java.io.IOException

append

public void append(long hash,
                   T key)
            throws java.io.IOException

Description copied from interface: AbstractSieve.NewFlowReceiver

A new key is appended.

Specified by:

append in interface AbstractSieve.NewFlowReceiver<T>

Parameters:

hash - the key hash.

key - the key itself.

Throws:

java.io.IOException

finishedAppending

public void finishedAppending()
                       throws java.io.IOException

Description copied from interface: AbstractSieve.NewFlowReceiver

The new flow of keys is over.

Specified by:

finishedAppending in interface AbstractSieve.NewFlowReceiver<T>

Throws:

java.io.IOException

noMoreAppend

public void noMoreAppend()
                  throws java.io.IOException

Description copied from interface: AbstractSieve.NewFlowReceiver

There will be no more new flows (because the sieve that is calling this method was closed).

Specified by:

noMoreAppend in interface AbstractSieve.NewFlowReceiver<T>

Throws:

java.io.IOException

dequeueKey

public MutableString dequeueKey()
                         throws java.util.NoSuchElementException,
                                java.io.IOException,
                                java.lang.InterruptedException

Returns the next key in the flow of new pairs remained after the check, and discards the corresponding value. Note that calling this method is blocking (it may take a long time to produce the next pair because check+update is performed in batch); in particular, if no thread calls AbstractSieve.enqueue(Object, Object) for a sufficient number of times or AbstractSieve.flush(), a call to this method may never return.

Returns:

the next key (the value is discarded).

Throws:

java.util.NoSuchElementException - if there is no more pair to be returned; this may only happen if this new flow has been closed.

java.io.IOException

java.lang.InterruptedException