Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.actian.dataflow.cal.yarn.shared | |
com.pervasive.datarush.cal.dr | |
com.pervasive.datarush.cal.monitoring | |
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
Modifier and Type | Method and Description |
---|---|
List<NodeStatistics> |
ContainerStatsServiceImpl.getContainerStats() |
Modifier and Type | Method and Description |
---|---|
List<NodeStatistics> |
ContainerStatsService.getContainerStats()
Return a list of node statistics from each active container being managed by
an external application master.
|
Modifier and Type | Method and Description |
---|---|
NodeStatistics |
AbstractDRClusterExecutor.getNonParallelStatistics()
Returns the non-parallel stats ( these are treated as the stats for the master )
|
Modifier and Type | Method and Description |
---|---|
List<NodeStatistics> |
AbstractDRClusterExecutor.startShutdown() |
Modifier and Type | Class and Description |
---|---|
class |
NodeStatisticsSnapshot |
Modifier and Type | Method and Description |
---|---|
NodeStatistics |
NodeStatisticsSnapshot.finalSnapshot() |
NodeStatistics |
NodeStatistics.finalSnapshot() |
Modifier and Type | Method and Description |
---|---|
List<NodeStatistics> |
JobStatistics.getNodeStatistics() |
Modifier and Type | Method and Description |
---|---|
static JobStatistics |
JobStatistics.forNodeStatistics(JobStatus status,
JobInformation jobInfo,
List<NodeStatistics> nodeStatistics) |
static JobStatistics |
JobStatistics.forNodeStatistics(String jobID,
JobStatus status,
JobInformation jobInfo,
List<NodeStatistics> nodeStatistics) |
static List<JobStatistics> |
JobStatistics.multiJobStatistics(JobStatus status,
List<NodeStatistics> nodeStatistics,
List<JobInformation> allocatedJobs) |
Modifier and Type | Method and Description |
---|---|
NodeStatistics |
WorkerService.getStatistics() |
NodeStatistics |
JobMasterServiceImpl.getStatistics() |
NodeStatistics |
DistributedWorkerServiceImpl.getStatistics() |
NodeStatistics |
NodeManagerImpl.killJob(GUID guid,
WorkerRole role) |
NodeStatistics |
NodeManager.killJob(GUID jobGUID,
WorkerRole role)
Admin kill.
|
NodeStatistics |
DistributedWorkerServiceImpl.startShutdown() |
NodeStatistics |
DistributedWorkerService.startShutdown() |
Modifier and Type | Method and Description |
---|---|
List<NodeStatistics> |
NodeManagerImpl.getStatistics() |
List<NodeStatistics> |
NodeManager.getStatistics()
Fetches statistics from each of the live processes launched by this node manager
|
Copyright © 2015 Actian Corporation. All Rights Reserved.