public class FederationUtils extends Object
| Constructor and Description | 
|---|
| FederationUtils() | 
| Modifier and Type | Method and Description | 
|---|---|
| static MatrixBlock | aggAdd(Future<FederatedResponse>[] ffr) | 
| static MatrixBlock | aggMatrix(AggregateUnaryOperator aop,
         Future<FederatedResponse>[] ffr,
         FederationMap map) | 
| static MatrixBlock | aggMean(Future<FederatedResponse>[] ffr,
       FederationMap map) | 
| static DoubleObject | aggMinMax(Future<FederatedResponse>[] ffr,
         boolean isMin,
         boolean isScalar) | 
| static ScalarObject | aggScalar(AggregateUnaryOperator aop,
         Future<FederatedResponse>[] ffr) | 
| static FederatedRequest | callInstruction(String inst,
               CPOperand varOldOut,
               CPOperand[] varOldIn,
               long[] varNewIn) | 
| static long | getNextFedDataID() | 
| static MatrixBlock[] | getResults(Future<FederatedResponse>[] ffr) | 
| static MatrixBlock | rbind(Future<FederatedResponse>[] ffr) | 
| static void | resetFedDataID() | 
| static void | waitFor(List<Future<FederatedResponse>> responses) | 
public static void resetFedDataID()
public static long getNextFedDataID()
public static FederatedRequest callInstruction(String inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn)
public static MatrixBlock aggAdd(Future<FederatedResponse>[] ffr)
public static MatrixBlock aggMean(Future<FederatedResponse>[] ffr, FederationMap map)
public static DoubleObject aggMinMax(Future<FederatedResponse>[] ffr, boolean isMin, boolean isScalar)
public static MatrixBlock[] getResults(Future<FederatedResponse>[] ffr)
public static MatrixBlock rbind(Future<FederatedResponse>[] ffr)
public static ScalarObject aggScalar(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr)
public static MatrixBlock aggMatrix(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, FederationMap map)
public static void waitFor(List<Future<FederatedResponse>> responses)
Copyright © 2020 The Apache Software Foundation. All rights reserved.