Package | Description |
---|---|
org.apache.sysds.runtime.controlprogram.federated | |
org.apache.sysds.runtime.instructions.fed |
Modifier and Type | Method and Description |
---|---|
FederatedResponse |
FederatedWorkerHandler.createResponse(Object msg) |
abstract FederatedResponse |
FederatedUDF.execute(ExecutionContext ec,
Data... data)
Execute the user-defined function on a set of data objects
(e.g., matrix objects, frame objects, or scalars), which are
looked up by specified input IDs and passed in the same order.
|
Modifier and Type | Method and Description |
---|---|
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> |
FederatedData.initFederatedData(long id) |
List<org.apache.commons.lang3.tuple.Pair<FederatedRange,Future<FederatedResponse>>> |
FederationMap.requestFederatedData() |
Modifier and Type | Method and Description |
---|---|
static void |
FederationUtils.waitFor(List<Future<FederatedResponse>> responses) |
Modifier and Type | Method and Description |
---|---|
FederatedResponse |
MultiReturnParameterizedBuiltinFEDInstruction.CreateFrameEncoder.execute(ExecutionContext ec,
Data... data) |
FederatedResponse |
MultiReturnParameterizedBuiltinFEDInstruction.ExecuteFrameEncoder.execute(ExecutionContext ec,
Data... data) |
FederatedResponse |
ParameterizedBuiltinFEDInstruction.DecodeMatrix.execute(ExecutionContext ec,
Data... data) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.