Class SynchronizedIntermediateResultElementSink

java.lang.Object

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

All Implemented Interfaces:

ClosableIntermediateResultElementSink, IntermediateResultElementSink

public class SynchronizedIntermediateResultElementSink
extends Object
implements ClosableIntermediateResultElementSink

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed
protected SolutionMapping	currentElement

Constructor Summary

Constructors

Constructor	Description
SynchronizedIntermediateResultElementSink()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this sink.
SolutionMapping	getNextElement()
boolean	isClosed()	Returns true if this sink has been closed.
void	send(SolutionMapping element)

Methods inherited from class java.lang.Object

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

Methods inherited from interface se.liu.ida.hefquin.engine.queryplan.executable.IntermediateResultElementSink

send, send

Field Details

currentElement

protected SolutionMapping currentElement

closed

protected boolean closed

Constructor Details

SynchronizedIntermediateResultElementSink

public SynchronizedIntermediateResultElementSink()

Method Details

send

public void send(SolutionMapping element)

Specified by:

send in interface IntermediateResultElementSink

close

public void close()

Description copied from interface: ClosableIntermediateResultElementSink

Closes this sink. Further calls of

invalid reference

#send(Object)

will be ignored. If this sink has been closed before, calling this method again has no effect.

Specified by:

close in interface ClosableIntermediateResultElementSink

isClosed

public boolean isClosed()

Description copied from interface: ClosableIntermediateResultElementSink

Returns true if this sink has been closed.

Specified by:

isClosed in interface ClosableIntermediateResultElementSink

getNextElement

public SolutionMapping getNextElement()