| Package | Description |
|---|---|
| com.actian.dataflow.cal.yarn.server | |
| com.pervasive.datarush.cal.monitoring |
| 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) |
PartitionServer(FileClient client,
Path drfsBaseDir,
String nodeID,
JobServerInformation jobWorkerInfo,
com.pervasive.datarush.cal.dr.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) |
Copyright © 2020 Actian Corporation. All rights reserved.