org.gridgain.grid.kernal.processors.streamer

Class GridStreamerExecutionRequest

java.lang.Object

org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

org.gridgain.grid.kernal.processors.streamer.GridStreamerExecutionRequest

All Implemented Interfaces:

Serializable, Cloneable

public class GridStreamerExecutionRequest
extends GridTcpCommunicationMessageAdapter

See Also:

Serialized Form

Field Summary

Fields inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

BIT_SET_NOT_READ, BOOLEAN_ARR_NOT_READ, BYTE_ARR_LIST_NOT_READ, BYTE_ARR_NOT_READ, CACHE_VER_NOT_READ, CHAR_ARR_NOT_READ, CLOCK_DELTA_VER_NOT_READ, commState, DHT_PART_EXCHANGE_ID_NOT_READ, DOUBLE_ARR_NOT_READ, DR_INT_REQ_ENTRY_NOT_READ, ENUM_NOT_READ, FLOAT_ARR_NOT_READ, GRID_UUID_NOT_READ, INT_ARR_NOT_READ, LONG_ARR_NOT_READ, LONG_LIST_NOT_READ, MSG_NOT_READ, NULL, SHORT_ARR_NOT_READ, STR_NOT_READ, UUID_NOT_READ, VAL_BYTES_NOT_READ

Constructor Summary

Constructors

Constructor and Description
GridStreamerExecutionRequest()
GridStreamerExecutionRequest(boolean forceLocDep, byte[] batchBytes, GridDeploymentMode depMode, String sampleClsName, String userVer, Map<UUID,GridUuid> ldrParticipants, GridUuid clsLdrId)

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	batchBytes()
GridUuid	classLoaderId()
GridTcpCommunicationMessageAdapter	clone()
protected void	clone0(GridTcpCommunicationMessageAdapter _msg) Clones all fields of the provided message to this.
GridDeploymentMode	deploymentMode()
byte	directType()
boolean	forceLocalDeployment()
Map<UUID,GridUuid>	loaderParticipants()
boolean	readFrom(ByteBuffer buf)
String	sampleClassName()
String	toString()
String	userVersion()
boolean	writeTo(ByteBuffer buf)

Methods inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

arrayIterator, messageReader, messageWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerExecutionRequest

public GridStreamerExecutionRequest()

GridStreamerExecutionRequest

public GridStreamerExecutionRequest(boolean forceLocDep,
                            byte[] batchBytes,
                            @Nullable
                            GridDeploymentMode depMode,
                            @Nullable
                            String sampleClsName,
                            @Nullable
                            String userVer,
                            @Nullable
                            Map<UUID,GridUuid> ldrParticipants,
                            @Nullable
                            GridUuid clsLdrId)

Parameters:

forceLocDep - Force local deployment flag.

batchBytes - Batch serialized bytes.

depMode - Deployment mode.

sampleClsName - Sample class name.

userVer - User version.

ldrParticipants - Loader participants.

clsLdrId - Class loader ID.

Method Detail

forceLocalDeployment

public boolean forceLocalDeployment()

Returns:

Force local deployment flag.

deploymentMode

public GridDeploymentMode deploymentMode()

Returns:

Deployment mode.

sampleClassName

public String sampleClassName()

Returns:

Deployment sample class name.

userVersion

public String userVersion()

Returns:

Deployment user version.

loaderParticipants

public Map<UUID,GridUuid> loaderParticipants()

Returns:

Node class loader participants.

classLoaderId

public GridUuid classLoaderId()

Returns:

Class loader ID.

batchBytes

public byte[] batchBytes()

Returns:

Serialized batch in case if P2P class loading is enabled.

toString

public String toString()

Overrides:

toString in class Object

clone

public GridTcpCommunicationMessageAdapter clone()

Specified by:

clone in class GridTcpCommunicationMessageAdapter

clone0

protected void clone0(GridTcpCommunicationMessageAdapter _msg)

Clones all fields of the provided message to this.

Specified by:

clone0 in class GridTcpCommunicationMessageAdapter

Parameters:

_msg - Message to clone from.

writeTo

public boolean writeTo(ByteBuffer buf)

Specified by:

writeTo in class GridTcpCommunicationMessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf)

Specified by:

readFrom in class GridTcpCommunicationMessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

directType

public byte directType()

Specified by:

directType in class GridTcpCommunicationMessageAdapter

Returns:

Message type.