public class SilentUpdatesMessage extends BaseVoidMessage implements TrainingMessage, RequestMessage
| Modifier and Type | Field and Description |
|---|---|
protected long |
frameId |
protected long |
updateId |
protected INDArray |
updates |
clipboard, messageType, originatorId, retransmitCount, role, shardIndex, storage, targetId, taskId, trainer, transport, voidConfiguration| Modifier | Constructor and Description |
|---|---|
protected |
SilentUpdatesMessage() |
|
SilentUpdatesMessage(INDArray encodedUpdates,
long updateId) |
| Modifier and Type | Method and Description |
|---|---|
void |
attachContext(VoidConfiguration voidConfiguration,
TrainingDriver<? extends TrainingMessage> trainer,
Clipboard clipboard,
Transport transport,
Storage storage,
NodeRole role,
short shardIndex)
This method initializes message for further processing
|
byte |
getCounter() |
long |
getFrameId() |
boolean |
isJoinSupported() |
void |
processMessage()
This method will be started in context of executor, either Shard, Client or Backup node
|
void |
setFrameId(long frameId) |
asBytes, asUnsafeBuffer, extractContext, getMessageType, incrementRetransmitCount, isBlockingMessage, joinMessageclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitasBytes, asUnsafeBuffer, extractContext, fromBytes, getMessageType, getOriginatorId, getRetransmitCount, getTargetId, getTaskId, incrementRetransmitCount, isBlockingMessage, joinMessage, setOriginatorId, setTargetIdprotected long updateId
protected INDArray updates
protected long frameId
protected SilentUpdatesMessage()
public SilentUpdatesMessage(INDArray encodedUpdates, long updateId)
public void attachContext(VoidConfiguration voidConfiguration, TrainingDriver<? extends TrainingMessage> trainer, Clipboard clipboard, Transport transport, Storage storage, NodeRole role, short shardIndex)
VoidMessageattachContext in interface VoidMessageattachContext in class BaseVoidMessagepublic void processMessage()
VoidMessageprocessMessage in interface VoidMessagepublic byte getCounter()
getCounter in interface TrainingMessagepublic long getFrameId()
getFrameId in interface TrainingMessagepublic void setFrameId(long frameId)
setFrameId in interface TrainingMessagepublic boolean isJoinSupported()
isJoinSupported in interface VoidMessageisJoinSupported in class BaseVoidMessageCopyright © 2020. All rights reserved.