| Package | Description |
|---|---|
| com.actian.dataflow.cal.yarn.server | |
| com.pervasive.datarush.cal.monitoring | |
| com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
| Constructor and Description |
|---|
MasterServer(com.pervasive.datarush.hadoop.shims.yarn.AMRMClient amClient,
FileClient client,
Path drfsBaseDir,
JobServerInformation jobWorkerInfo,
JobSpecifier jobSpecifier,
ExecutorOptions execOptions,
List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors,
Path cacheLocation,
Path libArchiveLocation,
String applicationID,
int jobPriority,
ClusterPreferences clusterPreferences,
Map<String,ApplicationResource> appResources) |
PartitionServer(FileClient client,
Path drfsBaseDir,
String nodeID,
JobServerInformation jobWorkerInfo,
NodeAllocationProvider allocationProvider,
JobSpecifier jobSpecifier) |
| Modifier and Type | Method and Description |
|---|---|
static NodeStatisticsSnapshot |
NodeStatisticsSnapshot.captureThisJVM(String nodeID,
String host,
JobServerInformation jobWorkerInfo,
List<RuntimeStatistic<?>> additionalStats) |
| Constructor and Description |
|---|
NodeStatisticsSnapshot(String nodeID,
String host,
JobServerInformation jobWorkerInfo,
StatisticsMap statistics) |
| Modifier and Type | Method and Description |
|---|---|
JobServerInformation |
WorkerServerArguments.getJobServerInfo() |
JobServerInformation |
ClientWorkerServerArguments.getJobServerInfo() |
| Modifier and Type | Method and Description |
|---|---|
void |
WorkerServerArguments.setJobServerInfo(JobServerInformation jobServerInfo) |
| Constructor and Description |
|---|
ClientWorkerServerArguments(JobServerInformation jobServerInfo,
JobClasspathConfig classpath,
ExecutorOptions options,
PassThru<ClientPassThru> clientPassThru) |
DistributedWorkerServiceImpl(NodeAllocationProvider allocationProvider,
FileClient fileClient,
String nodeID,
JobServerInformation jobServerInfo,
JobSpecifier jobSpec,
boolean wrap) |
JobMasterServiceImpl(FileClient fileClient,
String nodeID,
JobServerInformation jobWorkerInfo,
StorageManagerSpecifier storageSpec,
ClusterSpecifier clusterSpec,
boolean wrap) |
WorkerServer(FileClient client,
Path drfsBaseDir,
String nodeID,
JobServerInformation jobWorkerInfo,
JobSpecifier jobSpecifier,
ExecutorOptions execOptions,
NodeAllocationProvider allocationProvider,
String host) |
Copyright © 2015 Actian Corporation. All Rights Reserved.