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
XCallable s 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 |
SchemaCheckerService |
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> |
SchemaCheckerService.getInterface() |
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 © 2018 Apache Software Foundation. All rights reserved.