Package se.liu.ida.hefquin.engine.queryplan.executable.impl

Class CollectingIntermediateResultElementSink

java.lang.Object

se.liu.ida.hefquin.engine.queryplan.executable.impl.CollectingIntermediateResultElementSink

All Implemented Interfaces:

IntermediateResultElementSink

Direct Known Subclasses:

CollectingIntermediateResultElementSinkWithTranslation

public class CollectingIntermediateResultElementSink
extends Object
implements IntermediateResultElementSink

A (thread-safe) implementation of IntermediateResultElementSink that collects all solution mappings that are sent to it. The collected solution mappings can then be accessed by calling getCollectedSolutionMappings().

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<SolutionMapping>	l

Constructor Summary

Constructors

Constructor	Description
CollectingIntermediateResultElementSink()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears this sink by removing all solution mappings that have so far been collected in this sink.
Iterable<SolutionMapping>	getCollectedSolutionMappings()	Returns an iterable over the solution mappings that have been collected in this sink since the last time it was cleared (by calling clear()) or, if it has not been cleared so far, since it was created.
void	send(SolutionMapping element)

Methods inherited from class java.lang.Object

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

Field Details

l

protected final List<SolutionMapping> l

Constructor Details

CollectingIntermediateResultElementSink

public CollectingIntermediateResultElementSink()

Method Details

send

public void send(SolutionMapping element)

Specified by:

send in interface IntermediateResultElementSink

getCollectedSolutionMappings

public Iterable<SolutionMapping> getCollectedSolutionMappings()

Returns an iterable over the solution mappings that have been collected in this sink since the last time it was cleared (by calling clear()) or, if it has not been cleared so far, since it was created.

clear

public void clear()

Clears this sink by removing all solution mappings that have so far been collected in this sink.