public class DataRushCluster extends Object
Modifier and Type | Method and Description |
---|---|
String |
allocateMaster(NodeAllocationRequest request) |
NodeAllocationPlan |
allocateWorkers(GUID jobGUID) |
static DataRushCluster |
cluster(ClusterSpecifier clusterSpec,
NetworkConfiguration networkConfiguration) |
static DataRushCluster |
cluster(InetSocketAddress addr,
NetworkConfiguration networkConfiguration) |
static DataRushCluster |
cluster(String host,
int port,
NetworkConfiguration networkConfiguration)
Defines a reference to a cluster at a specified host and port.
|
static DataRushCluster |
embedded(File workingDir,
int nodeCount,
int availableProcessorsPerNode) |
static DataRushCluster |
embedded(File workingDir,
int nodeCount,
int availableProcessorsPerNode,
ResourceAllocation nodeCapacity) |
static DataRushCluster |
embedded(File workingDir,
int nodeCount,
int availableProcessorsPerNode,
ResourceAllocation nodeCapacity,
Map<String,String> otherSettings) |
ClusterManager |
getClusterManager() |
List<String> |
getClusterNodes(boolean refresh)
Enumerates the names of currently registered nodes in the cluster.
|
ExecutorOptions |
getDefaultFragmentOptions()
Gets the global default settings for graph fragment execution.
|
String |
getHost()
Gets the hostname of the machine where the cluster manager
is located.
|
ClusterPreferences |
getNodeConfiguration(String nodeID) |
NodeMapping |
getNodeInfo(boolean refresh)
Enumerates registered information for nodes in the cluster.
|
int |
getPort()
Gets the port number where the cluster manager is listening.
|
ClusterSpecifier |
getSpecifier() |
ClusterManager |
pingClusterManager() |
String |
toString() |
public String getHost()
public int getPort()
public ClusterManager pingClusterManager()
public ClusterManager getClusterManager()
public ClusterPreferences getNodeConfiguration(String nodeID)
public String allocateMaster(NodeAllocationRequest request)
public NodeAllocationPlan allocateWorkers(GUID jobGUID)
public ExecutorOptions getDefaultFragmentOptions()
public List<String> getClusterNodes(boolean refresh)
refresh
- whether to refresh so as to return only nodes that are livepublic NodeMapping getNodeInfo(boolean refresh)
refresh
- whether to refresh so as to return only nodes that are livepublic ClusterSpecifier getSpecifier()
public static DataRushCluster cluster(String host, int port, NetworkConfiguration networkConfiguration)
host
- the hostname of the cluster managerport
- the port at which the cluster manager is listeningpublic static DataRushCluster cluster(InetSocketAddress addr, NetworkConfiguration networkConfiguration)
public static DataRushCluster cluster(ClusterSpecifier clusterSpec, NetworkConfiguration networkConfiguration)
public static DataRushCluster embedded(File workingDir, int nodeCount, int availableProcessorsPerNode)
public static DataRushCluster embedded(File workingDir, int nodeCount, int availableProcessorsPerNode, ResourceAllocation nodeCapacity)
public static DataRushCluster embedded(File workingDir, int nodeCount, int availableProcessorsPerNode, ResourceAllocation nodeCapacity, Map<String,String> otherSettings)
Copyright © 2015 Actian Corporation. All Rights Reserved.