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) | 
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 © 2020 The Apache Software Foundation. All rights reserved.