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

Interface AbstractSieve.NewFlowReceiver<K>

All Known Implementing Classes:

AbstractSieve.DiskNewFlow, Frontier

Enclosing class:

AbstractSieve<K,V>

public static interface AbstractSieve.NewFlowReceiver<K>

An object that can receive a new flow of hash/key pairs and that acts as a listener for the AbstractSieve. Every time the sieve is ready to produce new keys, it will call the prepareToAppend() method to warn the new flow receiver. Then it will call append(long, Object) (typically many times in a row) to add the new keys. After that, the end of the current new flow of keys is signalled by calling finishedAppending(). A call to noMoreAppend() will, instead, mean that no more keys will ever be produced by the sieve that is calling it.

Method Summary

Modifier and Type	Method	Description
void	append(long hash, K key)	A new key is appended.
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.

Method Detail

prepareToAppend

void prepareToAppend()
              throws java.io.IOException

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

Throws:

java.io.IOException

append

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

A new key is appended.

Parameters:

hash - the key hash.

key - the key itself.

Throws:

java.io.IOException

finishedAppending

void finishedAppending()
                throws java.io.IOException

The new flow of keys is over.

Throws:

java.io.IOException

noMoreAppend

void noMoreAppend()
           throws java.io.IOException

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

Throws:

java.io.IOException