public final class MasterServer extends Object
Constructor and Description |
---|
MasterServer(com.pervasive.datarush.hadoop.shims.yarn.AMRMClient amClient,
FileClient client,
Path drfsBaseDir,
JobServerInformation jobWorkerInfo,
JobSpecifier jobSpecifier,
com.pervasive.datarush.cluster.ExecutorOptions execOptions,
List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors,
Path cacheLocation,
Path libArchiveLocation,
String applicationID,
int jobPriority,
com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences,
Map<String,ApplicationResource> appResources) |
Modifier and Type | Method and Description |
---|---|
void |
awaitShutdown() |
InetSocketAddress |
ensureService() |
com.pervasive.datarush.cluster.PathInfo |
getDRFSBaseInfo() |
static void |
main(String[] argv) |
void |
shutdown() |
public MasterServer(com.pervasive.datarush.hadoop.shims.yarn.AMRMClient amClient, FileClient client, Path drfsBaseDir, JobServerInformation jobWorkerInfo, JobSpecifier jobSpecifier, com.pervasive.datarush.cluster.ExecutorOptions execOptions, List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors, Path cacheLocation, Path libArchiveLocation, String applicationID, int jobPriority, com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences, Map<String,ApplicationResource> appResources)
public InetSocketAddress ensureService()
public void shutdown()
public com.pervasive.datarush.cluster.PathInfo getDRFSBaseInfo()
public void awaitShutdown() throws InterruptedException
InterruptedException
Copyright © 2021 Actian Corporation. All rights reserved.