org.apache.ignite.internal.processors.dataload

Class GridDataLoadRequest

java.lang.Object

org.apache.ignite.plugin.extensions.communication.MessageAdapter

org.apache.ignite.internal.processors.dataload.GridDataLoadRequest

All Implemented Interfaces:

Serializable

public class GridDataLoadRequest
extends MessageAdapter

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.plugin.extensions.communication.MessageAdapter

MessageAdapter.Type

Field Summary

Fields inherited from class org.apache.ignite.plugin.extensions.communication.MessageAdapter

reader, readState

Constructor Summary

Constructors

Constructor and Description
GridDataLoadRequest() Externalizable support.
GridDataLoadRequest(long reqId, byte[] resTopicBytes, String cacheName, byte[] updaterBytes, byte[] colBytes, boolean ignoreDepOwnership, boolean skipStore, DeploymentMode depMode, String sampleClsName, String userVer, Map<UUID,IgniteUuid> ldrParticipants, IgniteUuid clsLdrId, boolean forceLocDep)

Method Summary

Methods

Modifier and Type	Method and Description
String	cacheName()
IgniteUuid	classLoaderId()
byte[]	collectionBytes()
DeploymentMode	deploymentMode()
byte	directType() Gets message type.
boolean	forceLocalDeployment()
boolean	ignoreDeploymentOwnership()
Map<UUID,IgniteUuid>	participants()
boolean	readFrom(ByteBuffer buf) Reads this message from provided byte buffer.
long	requestId()
byte[]	responseTopicBytes()
String	sampleClassName()
boolean	skipStore()
String	toString()
byte[]	updaterBytes()
String	userVersion()
boolean	writeTo(ByteBuffer buf, MessageWriter writer) Writes this message to provided byte buffer.

Methods inherited from class org.apache.ignite.plugin.extensions.communication.MessageAdapter

setReader, skipRecovery

Methods inherited from class java.lang.Object

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

Constructor Detail

GridDataLoadRequest

public GridDataLoadRequest()

Externalizable support.

GridDataLoadRequest

public GridDataLoadRequest(long reqId,
                   byte[] resTopicBytes,
                   @Nullable
                   String cacheName,
                   byte[] updaterBytes,
                   byte[] colBytes,
                   boolean ignoreDepOwnership,
                   boolean skipStore,
                   DeploymentMode depMode,
                   String sampleClsName,
                   String userVer,
                   Map<UUID,IgniteUuid> ldrParticipants,
                   IgniteUuid clsLdrId,
                   boolean forceLocDep)

Parameters:

reqId - Request ID.

resTopicBytes - Response topic.

cacheName - Cache name.

updaterBytes - Cache updater.

colBytes - Collection bytes.

ignoreDepOwnership - Ignore ownership.

skipStore - Skip store flag.

depMode - Deployment mode.

sampleClsName - Sample class name.

userVer - User version.

ldrParticipants - Loader participants.

clsLdrId - Class loader ID.

forceLocDep - Force local deployment.

Method Detail

requestId

public long requestId()

Returns:

Request ID.

responseTopicBytes

public byte[] responseTopicBytes()

Returns:

Response topic.

cacheName

public String cacheName()

Returns:

Cache name.

updaterBytes

public byte[] updaterBytes()

Returns:

Updater.

collectionBytes

public byte[] collectionBytes()

Returns:

Collection bytes.

ignoreDeploymentOwnership

public boolean ignoreDeploymentOwnership()

Returns:

True to ignore ownership.

skipStore

public boolean skipStore()

Returns:

Skip store flag.

deploymentMode

public DeploymentMode deploymentMode()

Returns:

Deployment mode.

sampleClassName

public String sampleClassName()

Returns:

Sample class name.

userVersion

public String userVersion()

Returns:

User version.

participants

public Map<UUID,IgniteUuid> participants()

Returns:

Participants.

classLoaderId

public IgniteUuid classLoaderId()

Returns:

Class loader ID.

forceLocalDeployment

public boolean forceLocalDeployment()

Returns:

True to force local deployment.

toString

public String toString()

Overrides:

toString in class Object

writeTo

public boolean writeTo(ByteBuffer buf,
              MessageWriter writer)

Writes this message to provided byte buffer.

Specified by:

writeTo in class MessageAdapter

Parameters:

buf - Byte buffer.

writer - Writer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf)

Reads this message from provided byte buffer.

Specified by:

readFrom in class MessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

directType

public byte directType()

Gets message type.

Specified by:

directType in class MessageAdapter

Returns:

Message type.