public class FederatedData extends Object
| Constructor and Description | 
|---|
| FederatedData(FederatedData other,
             long varID)Make a copy of the  FederatedDatametadata, but use another varID (refer to another object on worker) | 
| FederatedData(Types.DataType dataType,
             InetSocketAddress address,
             String filepath) | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | clearFederatedWorkers() | 
| Future<FederatedResponse> | executeFederatedOperation(FederatedRequest... request) | 
| static Future<FederatedResponse> | executeFederatedOperation(InetSocketAddress address,
                         FederatedRequest... request)Executes an federated operation on a federated worker. | 
| InetSocketAddress | getAddress() | 
| String | getFilepath() | 
| long | getVarID() | 
| Future<FederatedResponse> | initFederatedData(long id) | 
| boolean | isInitialized() | 
| static void | resetFederatedSites() | 
| void | setVarID(long varID) | 
public FederatedData(Types.DataType dataType, InetSocketAddress address, String filepath)
public FederatedData(FederatedData other, long varID)
FederatedData metadata, but use another varID (refer to another object on worker)other - the FederatedData of which we want to copy the worker information fromvarID - the varID of the variable we refer topublic InetSocketAddress getAddress()
public void setVarID(long varID)
public long getVarID()
public String getFilepath()
public boolean isInitialized()
public Future<FederatedResponse> initFederatedData(long id)
public Future<FederatedResponse> executeFederatedOperation(FederatedRequest... request)
public static Future<FederatedResponse> executeFederatedOperation(InetSocketAddress address, FederatedRequest... request)
address - socket address (incl host and port)request - the requested operationpublic static void clearFederatedWorkers()
public static void resetFederatedSites()
Copyright © 2020 The Apache Software Foundation. All rights reserved.