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

Class MaterializingIntermediateResultElementSink

java.lang.Object

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

All Implemented Interfaces:

IntermediateResultElementSink

public class MaterializingIntermediateResultElementSink
extends Object
implements IntermediateResultElementSink

An implementation of IntermediateResultElementSink that materializes all solution mappings that are sent to it directly into an IntermediateResultBlock. This block can then be obtained by calling getMaterializedResultBlock(). If more solution mappings are sent to this sink after the block has been requested, a new block will be started, which can then be obtained by calling getMaterializedResultBlock() again. Attention, this implementation is not thread safe.

Field Summary

Fields

Modifier and Type	Field	Description
protected final IntermediateResultBlockBuilder	blockBuilder

Constructor Summary

Constructors

Constructor	Description
MaterializingIntermediateResultElementSink()

Method Summary

Modifier and Type	Method	Description
IntermediateResultBlock	getMaterializedResultBlock()	Returns an IntermediateResultBlock that contains all solution mappings that have been sent to this sink since the last time getMaterializedResultBlock() was called or, if this function has not been called so far, since this sink was created.
int	getSizeOfCurrentResultBlock()	Returns the number of solution mappings that have currently been accumulated to be placed in the IntermediateResultBlock to be returned by getMaterializedResultBlock().
void	send(SolutionMapping element)

Methods inherited from class java.lang.Object

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

Field Details

blockBuilder

protected final IntermediateResultBlockBuilder blockBuilder

Constructor Details

MaterializingIntermediateResultElementSink

public MaterializingIntermediateResultElementSink()

Method Details

send

public void send(SolutionMapping element)

Specified by:

send in interface IntermediateResultElementSink

getSizeOfCurrentResultBlock

public int getSizeOfCurrentResultBlock()

Returns the number of solution mappings that have currently been accumulated to be placed in the IntermediateResultBlock to be returned by getMaterializedResultBlock().

getMaterializedResultBlock

public IntermediateResultBlock getMaterializedResultBlock()

Returns an IntermediateResultBlock that contains all solution mappings that have been sent to this sink since the last time getMaterializedResultBlock() was called or, if this function has not been called so far, since this sink was created.