Package | Description |
---|---|
org.apache.sysds.runtime.controlprogram.federated | |
org.apache.sysds.runtime.instructions.fed | |
org.apache.sysds.runtime.lineage |
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> |
FederatedLocalData.executeFederatedOperation(FederatedRequest... request) |
Future<FederatedResponse> |
FederatedData.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 MatrixBlock |
FederationUtils.aggregateResponses(List<org.apache.commons.lang3.tuple.Pair<FederatedRange,Future<FederatedResponse>>> readResponses)
Aggregate partially aggregated data from federated workers
by adding values with the same index in different federated locations.
|
static MatrixBlock |
FederationUtils.bindResponses(List<org.apache.commons.lang3.tuple.Pair<FederatedRange,Future<FederatedResponse>>> readResponses,
long[] dims)
Bind data from federated workers based on non-overlapping federated ranges.
|
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 |
ReorgFEDInstruction.Rdiag.execute(ExecutionContext ec,
Data... data) |
FederatedResponse |
ReorgFEDInstruction.DiagMatrix.execute(ExecutionContext ec,
Data... data) |
FederatedResponse |
ParameterizedBuiltinFEDInstruction.DecodeMatrix.execute(ExecutionContext ec,
Data... data) |
Modifier and Type | Method and Description |
---|---|
static FederatedResponse |
LineageCache.reuse(FederatedUDF udf,
ExecutionContext ec) |
static FederatedResponse |
LineageItemUtils.setUDFResponse(FederatedUDF udf,
MatrixObject mo) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.