Class FederatedData
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.federated.FederatedData
 
- 
- Direct Known Subclasses:
- FederatedLocalData
 
 public class FederatedData extends Object 
- 
- 
Nested Class SummaryNested Classes Modifier and Type Class Description static classFederatedData.FederatedRequestEncoder
 - 
Constructor SummaryConstructors Constructor Description FederatedData(Types.DataType dataType, InetSocketAddress address, String filepath)FederatedData(Types.DataType dataType, InetSocketAddress address, String filepath, long varID)
 - 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static voidclearFederatedWorkers()static voidclearWorkGroup()FederatedDatacopyWithNewID(long varID)Make a copy of theFederatedDatametadata, but use another varID (refer to another object on worker)static voidcreateWorkGroup()static Future<FederatedResponse>executeFederatedOperation(InetSocketAddress address, FederatedRequest... request)Executes an federated operation on a federated worker.Future<FederatedResponse>executeFederatedOperation(FederatedRequest... request)InetSocketAddressgetAddress()Types.DataTypegetDataType()StringgetFilepath()longgetVarID()Future<FederatedResponse>initFederatedData(long id)Future<FederatedResponse>initFederatedData(long id, MetaData mtd)Future<FederatedResponse>initFederatedDataFromLocal(long id, CacheBlock block)booleanisInitialized()static voidresetFederatedSites()voidsetVarID(long varID)StringtoString()
 
- 
- 
- 
Constructor Detail- 
FederatedDatapublic FederatedData(Types.DataType dataType, InetSocketAddress address, String filepath) 
 - 
FederatedDatapublic FederatedData(Types.DataType dataType, InetSocketAddress address, String filepath, long varID) 
 
- 
 - 
Method Detail- 
getAddresspublic InetSocketAddress getAddress() 
 - 
setVarIDpublic void setVarID(long varID) 
 - 
getVarIDpublic long getVarID() 
 - 
getFilepathpublic String getFilepath() 
 - 
getDataTypepublic Types.DataType getDataType() 
 - 
isInitializedpublic boolean isInitialized() 
 - 
copyWithNewIDpublic FederatedData copyWithNewID(long varID) Make a copy of theFederatedDatametadata, but use another varID (refer to another object on worker)- Parameters:
- varID- the varID of the variable we refer to
- Returns:
- new FederatedDatawith different varID set
 
 - 
initFederatedDatapublic Future<FederatedResponse> initFederatedData(long id) 
 - 
initFederatedDatapublic Future<FederatedResponse> initFederatedData(long id, MetaData mtd) 
 - 
initFederatedDataFromLocalpublic Future<FederatedResponse> initFederatedDataFromLocal(long id, CacheBlock block) 
 - 
executeFederatedOperationpublic Future<FederatedResponse> executeFederatedOperation(FederatedRequest... request) 
 - 
executeFederatedOperationpublic static Future<FederatedResponse> executeFederatedOperation(InetSocketAddress address, FederatedRequest... request) Executes an federated operation on a federated worker.- Parameters:
- address- socket address (incl host and port)
- request- the requested operation
- Returns:
- the response
 
 - 
clearFederatedWorkerspublic static void clearFederatedWorkers() 
 - 
resetFederatedSitespublic static void resetFederatedSites() 
 - 
clearWorkGrouppublic static void clearWorkGroup() 
 - 
createWorkGrouppublic static void createWorkGroup() 
 
- 
 
-