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	Description
FederatedRequest	FederatedRequest.appendParam(Object obj)
FederatedRequest	FederatedRequest.appendParams(Object... objs)
FederatedRequest	FederationMap.broadcast(CacheableData<?> data)
FederatedRequest	FederationMap.broadcast(MatrixLineagePair moLin)
FederatedRequest	FederationMap.broadcast(ScalarObject scalar)
FederatedRequest[]	FederationMap.broadcastSliced(CacheableData<?> data, boolean transposed)
FederatedRequest[]	FederationMap.broadcastSliced(CacheableData<?> data, boolean isFrame, int[][] ix)
FederatedRequest[]	FederationMap.broadcastSliced(CacheableData<?> data, LineageItem lineageItem, boolean isFrame, int[][] ix)
FederatedRequest[]	FederationMap.broadcastSliced(MatrixLineagePair moLin, boolean transposed)
FederatedRequest[]	FederationMap.broadcastSliced(MatrixLineagePair moLin, boolean isFrame, int[][] ix)
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, long outputId, CPOperand[] varOldIn, long[] varNewIn, Types.ExecType type, boolean rmFedOutputFlag)
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)
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	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 frSlice1, FederatedRequest frSlice2, 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[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, FederatedRequest... fr)
Future<FederatedResponse>[]	FederationMap.execute(long tid, FederatedRequest[] frSlices, FederatedRequest... fr)
static Future<FederatedResponse>	FederatedData.executeFederatedOperation(InetSocketAddress address, int retry, FederatedRequest... request)	Executes an federated operation on a federated worker.
static Future<FederatedResponse>	FederatedData.executeFederatedOperation(InetSocketAddress address, FederatedRequest... request)	Executes an federated operation on a federated worker.
Future<FederatedResponse>	FederatedData.executeFederatedOperation(FederatedRequest... request)
Future<FederatedResponse>	FederatedLocalData.executeFederatedOperation(FederatedRequest... request)
Future<FederatedResponse>[]	FederationMap.executeMultipleSlices(long tid, boolean wait, FederatedRequest[][] frSlices, FederatedRequest[] fr)