Uses of Class
com.pervasive.datarush.util.RMIException

Packages that use RMIException

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.

Uses of RMIException in com.actian.dataflow.cal.yarn.server

Methods in com.actian.dataflow.cal.yarn.server that throw RMIException

Modifier and Type	Method and Description
List<NodeStatistics>	ContainerStatsServiceImpl.getContainerStats()

Uses of RMIException in com.actian.dataflow.cal.yarn.shared

Methods in com.actian.dataflow.cal.yarn.shared that throw RMIException

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.

Uses of RMIException in com.pervasive.datarush.cal

Methods in com.pervasive.datarush.cal that throw RMIException

Modifier and Type	Method and Description
void	JobHistoryService.jobFinished(JobStatistics statistics) Called by command server upon exit to report final statistics

Uses of RMIException in com.pervasive.datarush.cal.dr

Methods in com.pervasive.datarush.cal.dr with parameters of type RMIException

Modifier and Type	Method and Description
protected List<CommandHandleInfo>	RemoteMonitoredFuture.handleFailed(CommandHandleInfo handle, RMIException e)
protected List<CommandHandleInfo>	FaultTolerantFuture.handleFailed(CommandHandleInfo handle, RMIException e)

Uses of RMIException in com.pervasive.datarush.cluster

Methods in com.pervasive.datarush.cluster that throw RMIException

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)