com.bigdata.bop.engine

Interface IHaltOpMessage

All Superinterfaces:

IOpLifeCycleMessage, IOpMessage, Serializable

All Known Implementing Classes:

HaltOpMessage

public interface IHaltOpMessage
extends IOpLifeCycleMessage

A message sent to the IQueryClient when an operator is done executing for some chunk of inputs.

Version:

$Id$

Author:

Bryan Thompson

Method Summary

Methods

Modifier and Type	Method and Description
int	getAltSinkMessagesOut() The number of the IChunkMessages that were output for the alternative sink.
Throwable	getCause() The cause and null if the operator halted normally.
int	getSinkMessagesOut() The number of the IChunkMessages that were output for the primary sink.
BOpStats	getStats() The statistics for the execution of the bop against the partition on the service.

Methods inherited from interface com.bigdata.bop.engine.IOpLifeCycleMessage

getServiceId

Methods inherited from interface com.bigdata.bop.engine.IOpMessage

getBOpId, getPartitionId, getQueryId

Method Detail

getCause

Throwable getCause()

The cause and null if the operator halted normally.

getSinkMessagesOut

int getSinkMessagesOut()

The number of the IChunkMessages that were output for the primary sink. (This information is used for the atomic termination decision.)

For a given downstream operator this is ONE (1) for scale-up. For scale-out, this is one per index partition over which the intermediate results were mapped.

getAltSinkMessagesOut

int getAltSinkMessagesOut()

The number of the IChunkMessages that were output for the alternative sink. (This information is used for the atomic termination decision.)

For a given downstream operator this is ONE (1) for scale-up. For scale-out, this is one per index partition over which the intermediate results were mapped. It is zero if there was no alternative sink for the operator.

getStats

BOpStats getStats()

The statistics for the execution of the bop against the partition on the service.