org.gridgain.grid.kernal.processors.streamer

Class GridStreamerExecutionBatch

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerExecutionBatch

All Implemented Interfaces:

Externalizable, Serializable, GridOptimizedMarshallable

public class GridStreamerExecutionBatch
extends Object
implements Externalizable, GridOptimizedMarshallable

Streamer execution batch which should be processed on one node.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.gridgain.grid.marshaller.optimized.GridOptimizedMarshallable

CLS_ID_FIELD_NAME

Constructor Summary

Constructors

Constructor and Description
GridStreamerExecutionBatch() Empty constructor required by
GridStreamerExecutionBatch(GridUuid execId, long execStartTs, GridUuid futId, Collection<UUID> execNodeIds, String stageName, Collection<Object> evts) Execution batch.

Method Summary

Methods

Modifier and Type	Method and Description
void	deployment(GridDeployment dep) Sets deployment.
Collection<Object>	events()
GridUuid	executionId()
Collection<UUID>	executionNodeIds()
long	executionStartTimeStamp()
GridUuid	futureId()
Object	ggClassId() Implementation of this method should simply return value of GG_CLASS_ID field.
void	readExternal(ObjectInput in)
String	stageName()
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

GridStreamerExecutionBatch

public GridStreamerExecutionBatch()

Empty constructor required by

GridStreamerExecutionBatch

public GridStreamerExecutionBatch(GridUuid execId,
                          long execStartTs,
                          GridUuid futId,
                          Collection<UUID> execNodeIds,
                          String stageName,
                          Collection<Object> evts)

Execution batch.

Parameters:

execId - Execution ID.

futId - Future ID.

execStartTs - Execution start timestamp.

execNodeIds - Nodes participated in this execution.

stageName - Stage name to execute.

evts - Events to process.

Method Detail

deployment

public void deployment(GridDeployment dep)

Sets deployment. Deployment is not marshalled.

Parameters:

dep - Deployment for batch.

executionId

public GridUuid executionId()

Returns:

Execution ID.

executionStartTimeStamp

public long executionStartTimeStamp()

Returns:

Execution start timestamp.

futureId

public GridUuid futureId()

Returns:

Batch future ID.

executionNodeIds

public Collection<UUID> executionNodeIds()

Returns:

Execution node IDs.

stageName

public String stageName()

Returns:

Stage name.

events

public Collection<Object> events()

Returns:

Events collection.

ggClassId

public Object ggClassId()

Implementation of this method should simply return value of GG_CLASS_ID field.

Specified by:

ggClassId in interface GridOptimizedMarshallable

Returns:

Class ID for optimized marshalling.

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

toString

public String toString()

Overrides:

toString in class Object