| Package | Description | 
|---|---|
| org.apache.oozie.service | |
| org.apache.oozie.sla.service | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbandonedCoordCheckerService
The Abandoned Coord Checker Service check finds out the abandoned coord jobs in system and kills it. 
 | 
class  | 
ActionCheckerService
The Action Checker Service queue ActionCheckCommands to check the status of
 running actions and CoordActionCheckCommands to check the status of
 coordinator actions. 
 | 
class  | 
ActionService  | 
class  | 
AuthorizationService
The authorization service provides all authorization checks. 
 | 
class  | 
BundleEngineService
Service that return a bundle engine for a user. 
 | 
class  | 
CallableQueueService
The callable queue service queues  
XCallables for asynchronous execution. | 
class  | 
CallbackService
Service that generates and parses callback URLs. 
 | 
class  | 
ConfigurationService
Built in service that initializes the services configuration. 
 | 
class  | 
CoordinatorEngineService
Service that return a coordinator engine for a user. 
 | 
class  | 
CoordMaterializeTriggerService
The coordinator Materialization Lookup trigger service schedule lookup trigger command for every interval (default is
 5 minutes ). 
 | 
class  | 
DagEngineService
Service that return a dag engine for a user. 
 | 
class  | 
DagXLogInfoService
Set Dag specific log info parameters. 
 | 
class  | 
DBLiteWorkflowStoreService  | 
class  | 
ELService
The ELService creates  
ELEvaluator instances preconfigured with constants and functions defined in the
 configuration. | 
class  | 
EventHandlerService
Service class that handles the events system - creating events queue,
 managing configured properties and managing and invoking various event
 listeners via worker threads 
 | 
class  | 
GroupsService
The GroupsService class delegates to the Hadoop's  
org.apache.hadoop.security.Groups
 to retrieve the groups a user belongs to. | 
class  | 
HadoopAccessorService
The HadoopAccessorService returns HadoopAccessor instances configured to work on behalf of a user-group. 
 | 
class  | 
HCatAccessorService  | 
class  | 
InstrumentationService
This service provides an  
Instrumentation instance configured to support samplers. | 
class  | 
JMSAccessorService
This class will 
  Create/Manage JMS connections using user configured JNDI properties. 
 | 
class  | 
JMSTopicService
JMS Topic service to retrieve topic names from events or job id 
 | 
class  | 
JobsConcurrencyService
This Service helps coordinate other Services to prevent duplicate processing of Jobs if there are multiple Oozie Servers. 
 | 
class  | 
JPAService
Service that manages JPA and executes  
JPAExecutor. | 
class  | 
JvmPauseMonitorService
This class sets up a simple thread that sleeps for a short period of time. 
 | 
class  | 
LiteWorkflowAppService
Service that provides workflow application definition reading, parsing and creating proto configuration. 
 | 
class  | 
LiteWorkflowStoreService  | 
class  | 
MemoryLocksService
Service that provides in-memory locks. 
 | 
class  | 
MetricsInstrumentationService
This service provides an  
Instrumentation instance mostly compatible with the original Instrumentation, but backed by
 Codahale Metrics. | 
class  | 
PartitionDependencyManagerService
Module that functions like a caching service to maintain partition dependency mappings 
 | 
class  | 
PauseTransitService
PauseTransitService is the runnable which is scheduled to run at the configured interval, it checks all bundles to
 see if they should be paused, un-paused or started. 
 | 
class  | 
ProxyUserService
The ProxyUserService checks if a user of a request has proxyuser privileges. 
 | 
class  | 
PurgeService
The PurgeService schedules purging of completed jobs and associated action older than a specified age for workflow, coordinator and bundle. 
 | 
class  | 
RecoveryService
The Recovery Service checks for pending actions and premater coordinator jobs older than a configured age and then
 queues them for execution. 
 | 
class  | 
SchedulerService
This service executes scheduled Runnables and Callables at regular intervals. 
 | 
class  | 
SchemaService
Service that loads Oozie workflow definition schema and registered extension
 schemas. 
 | 
class  | 
ShareLibService  | 
class  | 
SLAStoreService  | 
class  | 
SparkConfigurationService  | 
class  | 
StatusTransitService
StateTransitService is scheduled to run at the configured interval. 
 | 
class  | 
StoreService
Base service for persistency of jobs and actions. 
 | 
class  | 
URIHandlerService  | 
class  | 
UserGroupInformationService  | 
class  | 
UUIDService
The UUID service generates unique IDs. 
 | 
class  | 
WorkflowAppService
Service that provides application workflow definition reading from the path and creation of the proto configuration. 
 | 
class  | 
WorkflowSchemaService
Service that loads Oozie workflow definition schema and registered extension schemas. 
 | 
class  | 
WorkflowStoreService
Base service for persistency of jobs and actions. 
 | 
class  | 
XLogService
Built-in service that initializes and manages Logging via Log4j. 
 | 
class  | 
XLogStreamingService
Service that performs streaming of log files over Web Services if enabled in XLogService 
 | 
class  | 
ZKJobsConcurrencyService
This Service helps coordinate other Services to prevent duplicate processing of Jobs if there are multiple Oozie Servers. 
 | 
class  | 
ZKLocksService
Service that provides distributed locks via ZooKeeper. 
 | 
class  | 
ZKUUIDService
Service that provides distributed job id sequence via ZooKeeper. 
 | 
class  | 
ZKXLogStreamingService
Service that performs streaming of log files over Web Services if enabled in XLogService and collates logs from other Oozie
 servers. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T extends Service>  | 
Services.get(Class<T> serviceKlass)
Return a service by its public interface. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Class<? extends Service> | 
XLogStreamingService.getInterface()
Return the public interface for log streaming service. 
 | 
Class<? extends Service> | 
XLogService.getInterface()
Return the public interface for log service. 
 | 
Class<? extends Service> | 
WorkflowStoreService.getInterface()
Return the public interface of the service. 
 | 
Class<? extends Service> | 
WorkflowSchemaService.getInterface()
Return the public interface of the service. 
 | 
Class<? extends Service> | 
WorkflowAppService.getInterface()
Return the public interface for workflow application service. 
 | 
Class<? extends Service> | 
UUIDService.getInterface()
Return the public interface for UUID service. 
 | 
Class<? extends Service> | 
UserGroupInformationService.getInterface()  | 
Class<? extends Service> | 
URIHandlerService.getInterface()  | 
Class<? extends Service> | 
StoreService.getInterface()
Return the public interface of the service. 
 | 
Class<? extends Service> | 
StatusTransitService.getInterface()
Return the public interface for the purge jobs service. 
 | 
Class<? extends Service> | 
SparkConfigurationService.getInterface()  | 
Class<? extends Service> | 
SLAStoreService.getInterface()  | 
Class<? extends Service> | 
ShareLibService.getInterface()  | 
Class<? extends Service> | 
Service.getInterface()
Return the public interface of the service. 
 | 
Class<? extends Service> | 
SchemaService.getInterface()
Return the public interface of the service. 
 | 
Class<? extends Service> | 
SchedulerService.getInterface()
Return the public interface for scheduler service. 
 | 
Class<? extends Service> | 
RecoveryService.getInterface()
Return the public interface for the Recovery Service. 
 | 
Class<? extends Service> | 
PurgeService.getInterface()
Return the public interface for the purge jobs service. 
 | 
Class<? extends Service> | 
ProxyUserService.getInterface()
Returns the service interface. 
 | 
Class<? extends Service> | 
PauseTransitService.getInterface()
Return the public interface for the purge jobs service. 
 | 
Class<? extends Service> | 
PartitionDependencyManagerService.getInterface()  | 
Class<? extends Service> | 
MemoryLocksService.getInterface()
Return the public interface for the memory locks services 
 | 
Class<? extends Service> | 
JvmPauseMonitorService.getInterface()  | 
Class<? extends Service> | 
JPAService.getInterface()
Return the public interface of the service. 
 | 
Class<? extends Service> | 
JobsConcurrencyService.getInterface()
Return the public interface for the jobs concurrency services 
 | 
Class<? extends Service> | 
JMSTopicService.getInterface()  | 
Class<? extends Service> | 
JMSAccessorService.getInterface()  | 
Class<? extends Service> | 
InstrumentationService.getInterface()
Return the public interface for instrumentation service. 
 | 
Class<? extends Service> | 
HCatAccessorService.getInterface()  | 
Class<? extends Service> | 
HadoopAccessorService.getInterface()  | 
Class<? extends Service> | 
GroupsService.getInterface()
Returns the service interface. 
 | 
Class<? extends Service> | 
EventHandlerService.getInterface()  | 
Class<? extends Service> | 
ELService.getInterface()
Return the public interface for EL service. 
 | 
Class<? extends Service> | 
DagXLogInfoService.getInterface()
Return the public interface of the service. 
 | 
Class<? extends Service> | 
DagEngineService.getInterface()
Return the public interface of the Dag engine service. 
 | 
Class<? extends Service> | 
CoordMaterializeTriggerService.getInterface()  | 
Class<? extends Service> | 
CoordinatorEngineService.getInterface()
Return the public interface of the Coordinator engine service. 
 | 
Class<? extends Service> | 
ConfigurationService.getInterface()
Return the public interface for configuration service. 
 | 
Class<? extends Service> | 
CallbackService.getInterface()
Return the public interface of the Dag engine service. 
 | 
Class<? extends Service> | 
CallableQueueService.getInterface()
Return the public interface for command queue service. 
 | 
Class<? extends Service> | 
BundleEngineService.getInterface()
Return the public interface of the Bundle engine service. 
 | 
Class<? extends Service> | 
AuthorizationService.getInterface()
Return the public interface of the service. 
 | 
Class<? extends Service> | 
ActionService.getInterface()  | 
Class<? extends Service> | 
ActionCheckerService.getInterface()
Return the public interface for the action checker service. 
 | 
Class<? extends Service> | 
AbandonedCoordCheckerService.getInterface()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Services.setService(Class<? extends Service> klass)
Set a service programmatically. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SLAService  | 
| Modifier and Type | Method and Description | 
|---|---|
Class<? extends Service> | 
SLAService.getInterface()  | 
Copyright © 2016 Apache Software Foundation. All rights reserved.