com.bigdata.bop.engine

Class StartOpMessage

java.lang.Object

com.bigdata.bop.engine.StartOpMessage

All Implemented Interfaces:

IOpLifeCycleMessage, IOpMessage, IStartOpMessage, Externalizable, Serializable

public class StartOpMessage
extends Object
implements Externalizable, IStartOpMessage

A message sent to the IQueryClient when an operator begins executing for some chunk of inputs (an operator on a node against a shard for some binding set chunks generated by downstream operator(s)).

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StartOpMessage() De-serialization constructor.
StartOpMessage(UUID queryId, int opId, int partitionId, UUID serviceId, int nmessages)

Method Summary

Methods

Modifier and Type	Method and Description
int	getBOpId() Return the operator identifier.
int	getChunkMessageCount() The #of IChunkMessage accepted as the input for the operator.
int	getPartitionId() Return the index partition identifier.
UUID	getQueryId() Return the query identifier.
UUID	getServiceId() Return the identifier of the service on which the operator will/did execute.
void	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

StartOpMessage

public StartOpMessage()

De-serialization constructor.

StartOpMessage

public StartOpMessage(UUID queryId,
              int opId,
              int partitionId,
              UUID serviceId,
              int nmessages)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

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

getServiceId

public UUID getServiceId()

Description copied from interface: IOpLifeCycleMessage

Return the identifier of the service on which the operator will/did execute.

Specified by:

getServiceId in interface IOpLifeCycleMessage

getChunkMessageCount

public int getChunkMessageCount()

Description copied from interface: IStartOpMessage

The #of IChunkMessage accepted as the input for the operator.

Note: This should be ONE (1) unless IChunkMessage are being combined for the operator.

Specified by:

getChunkMessageCount in interface IStartOpMessage

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException