| Package | Description | 
|---|---|
| org.apache.sysds.runtime.controlprogram.federated | |
| org.apache.sysds.runtime.instructions.fed | |
| org.apache.sysds.runtime.io | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
FederatedLocalData  | 
| Modifier and Type | Method and Description | 
|---|---|
FederatedData | 
FederatedData.copyWithNewID(long varID)
Make a copy of the  
FederatedData metadata, but use another varID (refer to another object on worker) | 
FederatedData | 
FederatedLocalData.copyWithNewID(long varID)  | 
FederatedData[] | 
FederationMap.getFederatedData()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> | 
FederationMap.getMap()  | 
| Modifier and Type | Method and Description | 
|---|---|
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 | 
|---|
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.