Uses of Class
org.apache.sysds.runtime.controlprogram.federated.FederatedRequest

Packages that use FederatedRequest

Package	Description
org.apache.sysds.runtime.controlprogram.federated

Uses of FederatedRequest in org.apache.sysds.runtime.controlprogram.federated

Methods in org.apache.sysds.runtime.controlprogram.federated that return FederatedRequest

Modifier and Type	Method and Description
FederatedRequest	FederatedRequest.appendParam(Object obj)
FederatedRequest	FederatedRequest.appendParams(Object... objs)
FederatedRequest	FederationMap.broadcast(CacheableData<?> data)
FederatedRequest	FederationMap.broadcast(ScalarObject scalar)
FederatedRequest[]	FederationMap.broadcastSliced(CacheableData<?> data, boolean transposed) Creates separate slices of an input data object according to the index ranges of federated data.
FederatedRequest[]	FederationMap.broadcastSliced(CacheableData<?> data, boolean isFrame, int[][] ix)
static FederatedRequest[]	FederationUtils.callInstruction(String[] inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn)
static FederatedRequest[]	FederationUtils.callInstruction(String[] inst, CPOperand varOldOut, long outputId, CPOperand[] varOldIn, long[] varNewIn, Types.ExecType type)
static FederatedRequest	FederationUtils.callInstruction(String inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn)
static FederatedRequest	FederationUtils.callInstruction(String inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn, boolean rmFedOutFlag)
static FederatedRequest	FederationUtils.callInstruction(String inst, CPOperand varOldOut, long outputId, CPOperand[] varOldIn, long[] varNewIn, Types.ExecType type, boolean rmFedOutputFlag)
FederatedRequest	FederationMap.cleanup(long tid, long... id)
FederatedRequest	FederatedRequest.deepClone()

Methods in org.apache.sysds.runtime.controlprogram.federated with parameters of type FederatedRequest

Modifier and Type	Method and Description
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRange[] fedRange1, FederatedRequest elseFr, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRange[] fedRange1, FederatedRequest elseFr, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRange[] fedRange1, FederatedRequest elseFr, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRange[] fedRange1, FederatedRequest elseFr, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRequest[] frSlices, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRequest[] frSlices, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, boolean wait, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, FederatedRequest[] frSlices, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, FederatedRequest[] frSlices, FederatedRequest... fr)
Future<FederatedResponse>	FederatedData.executeFederatedOperation(FederatedRequest... request)
Future<FederatedResponse>	FederatedLocalData.executeFederatedOperation(FederatedRequest... request)
static Future<FederatedResponse>	FederatedData.executeFederatedOperation(InetSocketAddress address, FederatedRequest... request) Executes an federated operation on a federated worker.
Future<FederatedResponse>[]	FederationMap.executeMultipleSlices(long tid, boolean wait, FederatedRequest[][] frSlices, FederatedRequest[] fr)
Future<FederatedResponse>[]	FederationMap.executeMultipleSlices(long tid, boolean wait, FederatedRequest[][] frSlices, FederatedRequest[] fr)