Class HEParamServer
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.paramserv.ParamServer
- 
- org.apache.sysds.runtime.controlprogram.paramserv.LocalParamServer
- 
- org.apache.sysds.runtime.controlprogram.paramserv.HEParamServer
 
 
 
- 
 public class HEParamServer extends LocalParamServer This class implements Homomorphic Encryption (HE) for LocalParamServer. It only supports modelAvg=true.
- 
- 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description PublicKeyaggregatePartialPublicKeys(PublicKey[] partial_public_keys)static HEParamServercreate(ListObject model, String aggFunc, Statement.PSUpdateType updateType, Statement.PSFrequency freq, ExecutionContext ec, int workerNum, String valFunc, int numBatchesPerEpoch, MatrixObject valFeatures, MatrixObject valLabels, int nbatches)byte[]generateA()voidpush(int workerID, ListObject encrypted_model)voidregisterThread(int thread_id, FederatedPSControlThread thread)- 
Methods inherited from class org.apache.sysds.runtime.controlprogram.paramserv.LocalParamServercreate, pull
 - 
Methods inherited from class org.apache.sysds.runtime.controlprogram.paramserv.ParamServergetAggInst, getNumWorkers, getResult
 
- 
 
- 
- 
- 
Method Detail- 
createpublic static HEParamServer 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) 
 - 
registerThreadpublic void registerThread(int thread_id, FederatedPSControlThread thread)
 - 
generateApublic byte[] generateA() 
 - 
aggregatePartialPublicKeyspublic PublicKey aggregatePartialPublicKeys(PublicKey[] partial_public_keys) 
 - 
pushpublic void push(int workerID, ListObject encrypted_model)- Overrides:
- pushin class- LocalParamServer
 
 
- 
 
-