Package org.apache.sysds.runtime.controlprogram.paramserv

Class LocalParamServer

java.lang.Object

org.apache.sysds.runtime.controlprogram.paramserv.ParamServer

org.apache.sysds.runtime.controlprogram.paramserv.LocalParamServer

Direct Known Subclasses:

HEParamServer

public class LocalParamServer
extends ParamServer

Constructor Summary

Constructors

Constructor	Description
LocalParamServer()

Method Summary

Modifier and Type	Method	Description
static LocalParamServer	create(ListObject model, String aggFunc, Statement.PSUpdateType updateType, Statement.PSFrequency freq, ExecutionContext ec, int workerNum, String valFunc, int numBatchesPerEpoch, MatrixObject valFeatures, MatrixObject valLabels, int nbatches, boolean modelAvg, int numBackupWorkers)
ListObject	pull(int workerID)
void	push(int workerID, ListObject gradients)

Methods inherited from class org.apache.sysds.runtime.controlprogram.paramserv.ParamServer

getAggInst, getNumWorkers, getResult

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LocalParamServer

public LocalParamServer()

Method Details

create

public static LocalParamServer create(ListObject model,
 String aggFunc,
 Statement.PSUpdateType updateType,
 Statement.PSFrequency freq,
 ExecutionContext ec,
 int workerNum,
 String valFunc,
 int numBatchesPerEpoch,
 MatrixObject valFeatures,
 MatrixObject valLabels,
 int nbatches,
 boolean modelAvg,
 int numBackupWorkers)

push

public void push(int workerID,
 ListObject gradients)

Specified by:

push in class ParamServer

pull

public ListObject pull(int workerID)

Specified by:

pull in class ParamServer