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, joinMessage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
asBytes, asUnsafeBuffer, extractContext, fromBytes, getMessageType, getOriginatorId, getRetransmitCount, getTargetId, getTaskId, incrementRetransmitCount, isBlockingMessage, joinMessage, setOriginatorId, setTargetId
protected 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)
VoidMessage
attachContext
in interface VoidMessage
attachContext
in class BaseVoidMessage
public void processMessage()
VoidMessage
processMessage
in interface VoidMessage
public byte getCounter()
getCounter
in interface TrainingMessage
public long getFrameId()
getFrameId
in interface TrainingMessage
public void setFrameId(long frameId)
setFrameId
in interface TrainingMessage
public boolean isJoinSupported()
isJoinSupported
in interface VoidMessage
isJoinSupported
in class BaseVoidMessage
Copyright © 2020. All rights reserved.