Class FederationUtils
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.federated.FederationUtils
 
- 
 public class FederationUtils extends Object 
- 
- 
Constructor SummaryConstructors Constructor Description FederationUtils()
 - 
Method Summary
 
- 
- 
- 
Method Detail- 
resetFedDataIDpublic static void resetFedDataID() 
 - 
getNextFedDataIDpublic static long getNextFedDataID() 
 - 
checkFedMapTypepublic static void checkFedMapType(MatrixObject mo) 
 - 
callInstructionpublic static FederatedRequest callInstruction(String inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn, boolean rmFedOutFlag) 
 - 
callInstructionpublic static FederatedRequest callInstruction(String inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn) 
 - 
callInstructionpublic static FederatedRequest[] callInstruction(String[] inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn) 
 - 
callInstructionpublic static FederatedRequest[] callInstruction(String[] inst, CPOperand varOldOut, long outputId, CPOperand[] varOldIn, long[] varNewIn, Types.ExecType type) 
 - 
callInstructionpublic static FederatedRequest callInstruction(String inst, CPOperand varOldOut, long outputId, CPOperand[] varOldIn, long[] varNewIn, Types.ExecType type, boolean rmFedOutputFlag) 
 - 
aggAddpublic static MatrixBlock aggAdd(Future<FederatedResponse>[] ffr) 
 - 
aggMeanpublic static MatrixBlock aggMean(Future<FederatedResponse>[] ffr, FederationMap map) 
 - 
getResultspublic static MatrixBlock[] getResults(Future<FederatedResponse>[] ffr) 
 - 
bindpublic static MatrixBlock bind(Future<FederatedResponse>[] ffr, boolean cbind) 
 - 
aggMinMaxpublic static MatrixBlock aggMinMax(Future<FederatedResponse>[] ffr, boolean isMin, boolean isScalar, Optional<FTypes.FType> fedType) 
 - 
aggProdpublic static MatrixBlock aggProd(Future<FederatedResponse>[] ffr, FederationMap fedMap, AggregateUnaryOperator aop) 
 - 
aggMinMaxIndexpublic static MatrixBlock aggMinMaxIndex(Future<FederatedResponse>[] ffr, boolean isMin, FederationMap map) 
 - 
aggVarpublic static MatrixBlock aggVar(Future<FederatedResponse>[] ffr, Future<FederatedResponse>[] meanFfr, FederationMap map, boolean isRowAggregate, boolean isScalar) 
 - 
aggScalarpublic static ScalarObject aggScalar(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, Future<FederatedResponse>[] meanFfr, FederationMap map) 
 - 
aggMatrixpublic static MatrixBlock aggMatrix(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, Future<FederatedResponse>[] meanFfr, FederationMap map) 
 - 
waitForpublic static void waitFor(List<Future<FederatedResponse>> responses) 
 - 
aggScalarpublic static ScalarObject aggScalar(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr) 
 - 
aggScalarpublic static ScalarObject aggScalar(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, FederationMap map) 
 - 
aggMatrixpublic static MatrixBlock aggMatrix(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, FederationMap map) 
 - 
federateLocalDatapublic static FederationMap federateLocalData(CacheableData<?> data) 
 - 
bindResponsespublic static MatrixBlock bindResponses(List<org.apache.commons.lang3.tuple.Pair<FederatedRange,Future<FederatedResponse>>> readResponses, long[] dims) throws Exception Bind data from federated workers based on non-overlapping federated ranges.- Parameters:
- readResponses- responses from federated workers containing the federated ranges and data
- dims- dimensions of output MatrixBlock
- Returns:
- MatrixBlock of consolidated data
- Throws:
- Exception- in case of problems with getting data from responses
 
 - 
aggregateResponsespublic static MatrixBlock aggregateResponses(List<org.apache.commons.lang3.tuple.Pair<FederatedRange,Future<FederatedResponse>>> readResponses) Aggregate partially aggregated data from federated workers by adding values with the same index in different federated locations.- Parameters:
- readResponses- responses from federated workers containing the federated data
- Returns:
- MatrixBlock of consolidated, aggregated data
 
 - 
decoderpublic static io.netty.handler.codec.serialization.ObjectDecoder decoder() 
 
- 
 
-