Uses of Class
org.apache.sysds.runtime.controlprogram.federated.FederatedRequest
Packages that use FederatedRequest
-
Uses of FederatedRequest in org.apache.sysds.runtime.controlprogram.federated
Methods in org.apache.sysds.runtime.controlprogram.federated that return FederatedRequestModifier and TypeMethodDescriptionFederatedRequest.appendParam(Object obj) FederatedRequest.appendParams(Object... objs) FederationMap.broadcast(CacheableData<?> data) FederationMap.broadcast(MatrixLineagePair moLin) FederationMap.broadcast(ScalarObject scalar) FederationMap.broadcastSliced(CacheableData<?> data, boolean transposed) FederationMap.broadcastSliced(CacheableData<?> data, boolean isFrame, int[][] ix) FederationMap.broadcastSliced(CacheableData<?> data, LineageItem lineageItem, boolean isFrame, int[][] ix) FederationMap.broadcastSliced(MatrixLineagePair moLin, boolean transposed) 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 FederatedRequestFederationUtils.callInstruction(String inst, CPOperand varOldOut, long outputId, CPOperand[] varOldIn, long[] varNewIn, Types.ExecType type, boolean rmFedOutputFlag) static FederatedRequestFederationUtils.callInstruction(String inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn) static FederatedRequestFederationUtils.callInstruction(String inst, CPOperand varOldOut, CPOperand[] varOldIn, long[] varNewIn, boolean rmFedOutFlag) FederationMap.cleanup(long tid, long... id) FederatedRequest.deepClone()Methods in org.apache.sysds.runtime.controlprogram.federated with parameters of type FederatedRequestModifier and TypeMethodDescriptionFederationMap.execute(long tid, boolean wait, FederatedRange[] fedRange1, FederatedRequest elseFr, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr) FederationMap.execute(long tid, boolean wait, FederatedRange[] fedRange1, FederatedRequest elseFr, FederatedRequest frSlice1, FederatedRequest frSlice2, FederatedRequest fr) FederationMap.execute(long tid, boolean wait, FederatedRequest... fr) FederationMap.execute(long tid, boolean wait, FederatedRequest[] frSlices, FederatedRequest... fr) FederationMap.execute(long tid, boolean wait, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr) FederationMap.execute(long tid, FederatedRequest... fr) 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.FederatedData.executeFederatedOperation(FederatedRequest... request) FederatedLocalData.executeFederatedOperation(FederatedRequest... request) FederationMap.executeMultipleSlices(long tid, boolean wait, FederatedRequest[][] frSlices, FederatedRequest[] fr) FederationMap.executeRoll(long tid, boolean wait, FederatedRequest frEnd, FederatedRequest frStart, long rlen)