Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.actian.dataflow.cal.yarn.shared | |
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.dr | |
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 |
---|---|
void |
JobHistoryService.jobFinished(JobStatistics statistics)
Called by command server upon exit to report final statistics
|
Modifier and Type | Method and Description |
---|---|
protected List<CommandHandleInfo> |
RemoteMonitoredFuture.handleFailed(CommandHandleInfo handle,
RMIException e) |
protected List<CommandHandleInfo> |
FaultTolerantFuture.handleFailed(CommandHandleInfo handle,
RMIException e) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterManagerImpl.addContainersToAppMaster(JobInformation jobInfo,
List<ContainerDescriptor> containers) |
void |
ClusterManager.addContainersToAppMaster(JobInformation jobInfo,
List<ContainerDescriptor> containers)
Add descriptors of containers that are allocated to the application master.
|
boolean |
NodeManagerImpl.anyJobsRunning() |
boolean |
NodeManager.anyJobsRunning() |
boolean |
MonitoredFutureHandle.cancel(boolean mayInterruptIfRunning) |
CancelResult |
MonitoredFutureService.cancel(GUID resultGUID,
boolean mayInterruptIfRunning) |
void |
NodeManager.cleanup(GUID jobGUID,
WorkerRole role,
CleanupLevel level)
Cleans up files created for the job
|
void |
NodeManager.clearClasspathCache()
Clears the shared classpath cache
|
void |
ClusterManagerImpl.clearClasspathCache() |
void |
ClusterManager.clearClasspathCache()
Clears the shared classpath cache
|
WorkerService |
NodeManager.createCommandExecutor(SerializationBridge<ClientWorkerServerArguments> arguments) |
boolean |
MonitoredFutureService.deleteResult(GUID guid) |
void |
ClusterManagerImpl.deregisterAppMaster(JobInformation jobInfo) |
void |
ClusterManager.deregisterAppMaster(JobInformation jobInfo)
Deregister an external application master.
|
void |
ClusterManager.ensureRegistered(NodeDescriptor node)
Adds a node to the cluster registry.
|
void |
ClusterManager.failJob(GUID jobGUID)
Manually force job fail
|
List<MasterDescriptor> |
ClusterManagerImpl.getActiveAppMasters() |
List<MasterDescriptor> |
ClusterManager.getActiveAppMasters()
Get a list of active (external) application masters.
|
NodeConfiguration |
NodeManager.getConfiguration()
Gets the current configuration settings for the node.
|
ClusterPreferences |
ClusterManagerImpl.getConfiguration() |
ClusterPreferences |
ClusterManager.getConfiguration()
Get the global cluster configuration (not for a specific node).
|
ClusterPreferences |
ClusterManager.getConfiguration(String node)
Requests the configuration for the given node.
|
List<ContainerDescriptor> |
ClusterManagerImpl.getContainers(MasterDescriptor masterDescriptor) |
List<ContainerDescriptor> |
ClusterManager.getContainers(MasterDescriptor masterDescriptor)
Get the list of containers allocated to an application master.
|
ExecutorOptions |
ClusterManager.getDefaultOptions()
Gets the default options configured for remote fragment
execution.
|
Integer |
ClusterManager.getJobStatus(GUID jobGUID)
Get the general run status of the job
-1 - job in progress
0 - job completed normally
1+ - job has errors
|
NodeDescriptor |
ClusterManager.getNodeDescriptor(String name)
Gets the node descriptor for the specified node
|
NodeMapping |
ClusterManager.getNodes(boolean refresh)
Gets node info for all nodes in the cluster
|
List<MasterDescriptor> |
ClusterManagerImpl.getPendingAppMasters() |
List<MasterDescriptor> |
ClusterManager.getPendingAppMasters()
Get a list of pending (external) application masters.
|
NodeStatistics |
WorkerService.getStatistics() |
List<NodeStatistics> |
NodeManager.getStatistics()
Fetches statistics from each of the live processes launched by this node manager
|
String |
NodeManager.getStatus()
Gets a description of the current status of the node
|
String |
ClusterManager.getStatus()
Gets a description of the current status of the node
|
void |
ClusterManager.killJob(GUID jobGUID)
Administrative job kill
|
NodeStatistics |
NodeManager.killJob(GUID jobGUID,
WorkerRole role)
Admin kill.
|
void |
NodeManager.notifyNodePreferencesChanged(ClusterPreferences nodeScopedPreferences)
Notifies the node manager that their preferences (may) have changed
|
InputStream |
ClusterManager.openClusterLogFile(LogFileOptions options)
Opens the log file for cluster manager for reading
|
InputStream |
NodeManager.openJobLogFile(GUID jobId,
WorkerRole role,
LogFileOptions options)
Opens the log file for the given job.
|
InputStream |
NodeManager.openNodeLogFile(LogFileOptions options)
Opens the log file for the node manager.
|
CommandStatus |
MonitoredFutureService.poll(GUID resultGUID,
long timeout,
TimeUnit timeunit) |
CommandStatus |
MonitoredFutureHandle.poll(long timeout,
TimeUnit timeunit) |
void |
ClusterManagerImpl.registerAppMaster(MasterDescriptor masterDescriptor) |
void |
ClusterManager.registerAppMaster(MasterDescriptor masterDescriptor)
Register an application master started outside of the context of the cluster manager.
|
void |
ClusterManagerImpl.rotateClusterLog() |
void |
ClusterManager.rotateClusterLog()
Rotates the cluster manager log
|
void |
NodeManagerImpl.rotateNodeLog() |
void |
NodeManager.rotateNodeLog()
Rotates the node manager log
|
void |
ClusterManagerImpl.rotateNodeLogs() |
void |
ClusterManager.rotateNodeLogs()
Rotates all of the node manager logs
|
void |
NodeManager.shutdown()
Terminates the node manager.
|
void |
ClusterManager.shutdown()
Requests a shutdown of the cluster.
|
void |
ClusterManagerImpl.shutdownNode(String name) |
void |
ClusterManager.shutdownNode(String node)
Shuts down the given node.
|
NodeStatistics |
DistributedWorkerService.startShutdown() |
MonitoredFutureHandle |
DistributedWorkerService.submit(DistributedCallableBatch<?> command,
List<NodeAllocationState.AssignmentState> assignments) |
MonitoredFutureHandle |
JobMasterServiceImpl.submit(JobCallable<?> jobCallable) |
MonitoredFutureHandle |
JobMasterService.submit(JobCallable<?> jobCallable) |
Copyright © 2016 Actian Corporation. All Rights Reserved.