public class LocalParamServer extends ParamServer
Constructor and Description |
---|
LocalParamServer() |
Modifier and Type | Method and Description |
---|---|
static LocalParamServer |
create(ListObject model,
String aggFunc,
Statement.PSUpdateType updateType,
ExecutionContext ec,
int workerNum) |
ListObject |
pull(int workerID) |
void |
push(int workerID,
ListObject gradients) |
getResult
public static LocalParamServer create(ListObject model, String aggFunc, Statement.PSUpdateType updateType, ExecutionContext ec, int workerNum)
public void push(int workerID, ListObject gradients)
push
in class ParamServer
public ListObject pull(int workerID)
pull
in class ParamServer
Copyright © 2020 The Apache Software Foundation. All rights reserved.