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