com.bigdata.bop.fed

Class EmptyChunkMessage<E>

java.lang.Object

com.bigdata.bop.fed.EmptyChunkMessage<E>

All Implemented Interfaces:

IChunkMessage<E>, IOpMessage, Serializable

public class EmptyChunkMessage<E>
extends Object
implements IChunkMessage<E>, Serializable

An empty IChunkMessage. This is used to kick off the optional last evaluation phase for an operator.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EmptyChunkMessage(IQueryClient queryController, UUID queryId, int bopId, int partitionId, boolean lastInvocation)

Method Summary

Methods

Modifier and Type	Method and Description
int	getBOpId() Return the operator identifier.
int	getBytesAvailable()
IChunkAccessor<E>	getChunkAccessor() Return an interface which may be used to access the chunk's data.
int	getPartitionId() Return the index partition identifier.
IQueryClient	getQueryController() The proxy for the query controller.
UUID	getQueryControllerId() The UUID of the query controller (the IQueryClient to which the query was submitted).
UUID	getQueryId() Return the query identifier.
int	getSolutionCount() Return the #of solutions which are available from this message.
boolean	isLastInvocation() Return true iff the IChunkMessage is for the last evaluation pass of an operator.
boolean	isMaterialized() Return true if the chunk is materialized on the receiver.
void	materialize(FederatedRunningQuery runningQuery) Materialize the chunk on the receiver.
void	release() Release all resources associated with this chunk.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

EmptyChunkMessage

public EmptyChunkMessage(IQueryClient queryController,
                 UUID queryId,
                 int bopId,
                 int partitionId,
                 boolean lastInvocation)

Parameters:

queryController -

queryId -

bopId -

partitionId -

Method Detail

getQueryController

public IQueryClient getQueryController()

Description copied from interface: IChunkMessage

The proxy for the query controller.

Specified by:

getQueryController in interface IChunkMessage<E>

See Also:

Optimize serialization for query messages on cluster, The query controller should be discoverable

getQueryControllerId

public UUID getQueryControllerId()

Description copied from interface: IChunkMessage

The UUID of the query controller (the IQueryClient to which the query was submitted).

Specified by:

getQueryControllerId in interface IChunkMessage<E>

See Also:

https://sourceforge.net/apps/trac/bigdata/ticket/475

getQueryId

public UUID getQueryId()

Description copied from interface: IOpMessage

Return the query identifier.

Specified by:

getQueryId in interface IOpMessage

getBOpId

public int getBOpId()

Description copied from interface: IOpMessage

Return the operator identifier.

Specified by:

getBOpId in interface IOpMessage

getPartitionId

public int getPartitionId()

Description copied from interface: IOpMessage

Return the index partition identifier.

Specified by:

getPartitionId in interface IOpMessage

isLastInvocation

public boolean isLastInvocation()

Description copied from interface: IChunkMessage

Return true iff the IChunkMessage is for the last evaluation pass of an operator. The last evaluation pass for an operator must be requested using an annotation. When it is requested, the operator will be invoked one more time for each node or shard on which it was run (depending on the BOpEvaluationContext). When so invoked, the IChunkMessage will be associated with an empty source and this flag will be set.

Specified by:

isLastInvocation in interface IChunkMessage<E>

See Also:

PipelineOp.Annotations#LAST_PASS

isMaterialized

public boolean isMaterialized()

Description copied from interface: IChunkMessage

Return true if the chunk is materialized on the receiver.

Specified by:

isMaterialized in interface IChunkMessage<E>

getSolutionCount

public int getSolutionCount()

Description copied from interface: IChunkMessage

Return the #of solutions which are available from this message.

Specified by:

getSolutionCount in interface IChunkMessage<E>

getBytesAvailable

public int getBytesAvailable()

toString

public String toString()

Overrides:

toString in class Object

materialize

public void materialize(FederatedRunningQuery runningQuery)

Description copied from interface: IChunkMessage

Materialize the chunk on the receiver.

Specified by:

materialize in interface IChunkMessage<E>

Parameters:

runningQuery - The running query.

release

public void release()

Description copied from interface: IChunkMessage

Release all resources associated with this chunk. If the source has been opened, then ensure that it is closed. If the data has been materialized, then discard the materialized data.

Specified by:

release in interface IChunkMessage<E>

getChunkAccessor

public IChunkAccessor<E> getChunkAccessor()

Description copied from interface: IChunkMessage

Return an interface which may be used to access the chunk's data.

Specified by:

getChunkAccessor in interface IChunkMessage<E>