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.