public class SparkPSProxy extends ParamServer
| Constructor and Description |
|---|
SparkPSProxy(org.apache.spark.network.client.TransportClient client,
long rpcTimeout,
org.apache.spark.util.LongAccumulator aRPC) |
| Modifier and Type | Method and Description |
|---|---|
ListObject |
pull(int workerID) |
void |
push(int workerID,
ListObject value) |
getAggInst, getResultpublic SparkPSProxy(org.apache.spark.network.client.TransportClient client,
long rpcTimeout,
org.apache.spark.util.LongAccumulator aRPC)
public void push(int workerID,
ListObject value)
push in class ParamServerpublic ListObject pull(int workerID)
pull in class ParamServerCopyright © 2021 The Apache Software Foundation. All rights reserved.