| Package | Description |
|---|---|
| org.apache.sysds.runtime.controlprogram.federated | |
| org.apache.sysds.runtime.instructions.fed | |
| org.apache.sysds.runtime.io |
| Modifier and Type | Method and Description |
|---|---|
FederatedRange[] |
FederationMap.getFederatedRanges() |
FederatedRange |
FederatedRange.shift(long rshift,
long cshift) |
FederatedRange |
FederatedRange.transpose() |
| Modifier and Type | Method and Description |
|---|---|
List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> |
FederationMap.getMap() |
List<org.apache.commons.lang3.tuple.Pair<FederatedRange,Future<FederatedResponse>>> |
FederationMap.requestFederatedData() |
| Modifier and Type | Method and Description |
|---|---|
int |
FederatedRange.compareTo(FederatedRange o) |
Future<FederatedResponse>[] |
FederationMap.execute(long tid,
boolean wait,
FederatedRange[] fedRange1,
FederatedRequest elseFr,
FederatedRequest[] frSlices1,
FederatedRequest[] frSlices2,
FederatedRequest... fr) |
| 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.
|
void |
FederationMap.forEachParallel(BiFunction<FederatedRange,FederatedData,Void> forEachFunction)
Execute a function for each
FederatedRange + FederatedData pair. |
FederationMap |
FederationMap.mapParallel(long newVarID,
BiFunction<FederatedRange,FederatedData,Void> mappingFunction)
Execute a function for each
FederatedRange + FederatedData pair mapping the pairs to
their new form by directly changing both FederatedRange and FederatedData. |
| Constructor and Description |
|---|
FederatedRange(FederatedRange other)
Does a deep copy of another
FederatedRange object. |
FederatedRange(FederatedRange other,
long clen) |
| Constructor and Description |
|---|
FederationMap(List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> fedMap) |
FederationMap(long ID,
List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> fedMap) |
FederationMap(long ID,
List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> fedMap,
FederationMap.FType type) |
| Modifier and Type | Method and Description |
|---|---|
static void |
InitFEDInstruction.federateFrame(FrameObject output,
List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> workers) |
static void |
InitFEDInstruction.federateMatrix(CacheableData<?> output,
List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> workers) |
| Modifier and Type | Method and Description |
|---|---|
static List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> |
ReaderWriterFederated.read(String file,
DataCharacteristics mc)
Read a federated map from disk, It is not initialized before it is used in:
org.apache.sysds.runtime.instructions.fed.InitFEDInstruction
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.