public class DistributedAssignMessage extends BaseVoidMessage implements DistributedMessage
clipboard, messageType, originatorId, retransmitCount, role, shardIndex, storage, targetId, taskId, trainer, transport, voidConfiguration
Modifier | Constructor and Description |
---|---|
protected |
DistributedAssignMessage() |
|
DistributedAssignMessage(java.lang.Integer key,
INDArray payload) |
|
DistributedAssignMessage(java.lang.Integer key,
int index,
double value) |
Modifier and Type | Method and Description |
---|---|
void |
processMessage()
This method assigns specific value to either specific row, or whole array.
|
asBytes, asUnsafeBuffer, attachContext, extractContext, getMessageType, incrementRetransmitCount, isBlockingMessage, isJoinSupported, joinMessage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
asBytes, asUnsafeBuffer, attachContext, extractContext, fromBytes, getMessageType, getOriginatorId, getRetransmitCount, getTargetId, getTaskId, incrementRetransmitCount, isBlockingMessage, isJoinSupported, joinMessage, setOriginatorId, setTargetId
protected DistributedAssignMessage()
public DistributedAssignMessage(@NonNull java.lang.Integer key, int index, double value)
public DistributedAssignMessage(@NonNull java.lang.Integer key, INDArray payload)
public void processMessage()
processMessage
in interface VoidMessage