Package | Description |
---|---|
org.apache.oozie.command | |
org.apache.oozie.command.bundle | |
org.apache.oozie.command.coord | |
org.apache.oozie.service | |
org.apache.oozie.sla | |
org.apache.oozie.sla.service |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
SLAAlertsXCommand.executeSlaCommand()
Execute sla command.
|
Modifier and Type | Method and Description |
---|---|
protected void |
BundleSLAChangeXCommand.executeCoordCommand(String id,
String actions,
String dates) |
protected abstract void |
BundleSLAAlertsXCommand.executeCoordCommand(String id,
String actions,
String dates) |
protected void |
BundleSLAAlertsEnableXCommand.executeCoordCommand(String id,
String actions,
String dates) |
protected void |
BundleSLAAlertsDisableXCommand.executeCoordCommand(String id,
String actions,
String dates) |
protected boolean |
BundleSLAAlertsXCommand.executeSlaCommand() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
CoordSLAChangeXCommand.executeSlaCommand() |
protected boolean |
CoordSLAAlertsEnableXCommand.executeSlaCommand() |
protected boolean |
CoordSLAAlertsDisableXCommand.executeSlaCommand() |
Modifier and Type | Method and Description |
---|---|
static Object |
ELService.findConstant(String className,
String constantName) |
static Method |
ELService.findMethod(String className,
String methodName) |
static String |
ConfigurationService.getConfigurationDirectory() |
static String |
Services.getOozieHome() |
void |
Services.init()
Initialize all services define in the
Services.CONF_SERVICE_CLASSES configuration property. |
void |
HadoopAccessorService.init(org.apache.hadoop.conf.Configuration conf) |
void |
ZKXLogStreamingService.init(Services services)
Initialize the log streaming service.
|
void |
ZKUUIDService.init(Services services) |
void |
ZKLocksService.init(Services services)
Initialize the zookeeper locks service
|
void |
ZKJobsConcurrencyService.init(Services services)
Initialize the zookeeper jobs concurrency service
|
void |
XLogStreamingService.init(Services services)
Initialize the log streaming service.
|
void |
XLogService.init(Services services)
Initialize the log service.
|
void |
WorkflowSchemaService.init(Services services)
Initialize the service.
|
void |
UUIDService.init(Services services)
Initialize the UUID service.
|
void |
UserGroupInformationService.init(Services services) |
void |
URIHandlerService.init(Services services) |
void |
StoreService.init(Services services)
Initializes the
StoreService . |
void |
SparkConfigurationService.init(Services services) |
void |
SLAStoreService.init(Services services) |
void |
ShareLibService.init(Services services) |
void |
Service.init(Services services)
Initialize the service.
|
void |
SchemaService.init(Services services)
Initialize the service.
|
void |
ProxyUserService.init(Services services)
Initializes the service.
|
void |
PartitionDependencyManagerService.init(Services services) |
void |
MetricsInstrumentationService.init(Services services)
Initialize the metrics instrumentation service.
|
void |
MemoryLocksService.init(Services services)
Initialize the memory locks service
|
void |
JvmPauseMonitorService.init(Services services) |
void |
JPAService.init(Services services)
Initializes the
JPAService . |
void |
JobsConcurrencyService.init(Services services)
Initialize the jobs concurrency service
|
void |
JMSTopicService.init(Services services) |
void |
JMSAccessorService.init(Services services) |
void |
InstrumentationService.init(Services services)
Initialize the instrumentation service.
|
void |
HCatAccessorService.init(Services services) |
void |
HadoopAccessorService.init(Services services) |
void |
EventHandlerService.init(Services services) |
void |
ELService.init(Services services)
Initialize the EL service.
|
void |
DBLiteWorkflowStoreService.init(Services services) |
void |
CoordMaterializeTriggerService.init(Services services) |
void |
ConfigurationService.init(Services services)
Initialize the log service.
|
void |
AuthorizationService.init(Services services)
Initialize the service.
|
void |
ActionService.init(Services services) |
protected void |
InstrumentationService.initLogging(Services services,
Instrumentation instr,
int interval) |
static void |
Services.setOozieHome() |
void |
Services.setService(Class<? extends Service> klass)
Set a service programmatically.
|
Constructor and Description |
---|
Services()
Create a services.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SLACalculatorMemory.addJobStatus(String jobId,
String jobStatus,
JobEvent.EventStatus jobEventStatus,
Date startTime,
Date endTime)
Triggered after receiving Job status change event, update SLA status
accordingly
|
boolean |
SLACalculator.addJobStatus(String jobId,
String jobStatus,
JobEvent.EventStatus jobEventStatus,
Date startTime,
Date endTime) |
boolean |
SLACalculatorMemory.changeDefinition(List<Pair<String,Map<String,String>>> jobIdsSLAPair) |
boolean |
SLACalculator.changeDefinition(List<Pair<String,Map<String,String>>> jobIdsSLAPair)
Change jobs Sla definitions
It takes list of pairs of jobid and key/value pairs of el evaluated sla definition.
|
boolean |
SLACalculatorMemory.disableAlert(List<String> jobIds) |
boolean |
SLACalculator.disableAlert(List<String> jobId)
Disable jobs Sla alert.
|
boolean |
SLACalculatorMemory.disableChildJobAlert(List<String> parentJobIds) |
boolean |
SLACalculator.disableChildJobAlert(List<String> parentJobIds)
Disable Sla alert for child jobs.
|
boolean |
SLACalculatorMemory.enableAlert(List<String> jobIds) |
boolean |
SLACalculator.enableAlert(List<String> jobId)
Enable jobs sla alert.
|
boolean |
SLACalculatorMemory.enableChildJobAlert(List<String> parentJobIds) |
boolean |
SLACalculator.enableChildJobAlert(List<String> parentJobIds)
Enable sla alert for child jobs.
|
void |
SLACalculatorMemory.init(org.apache.hadoop.conf.Configuration conf) |
void |
SLACalculator.init(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
boolean |
SLAService.addRegistrationEvent(SLARegistrationBean reg) |
boolean |
SLAService.addStatusEvent(String jobId,
String status,
JobEvent.EventStatus eventStatus,
Date startTime,
Date endTime) |
boolean |
SLAService.changeDefinition(List<Pair<String,Map<String,String>>> idSlaDefinitionList)
Change jobs Sla definitions
It takes list of pairs of jobid and key/value pairs of el evaluated sla definition.
|
boolean |
SLAService.disableAlert(List<String> jobIds)
Disable jobs Sla alert.
|
boolean |
SLAService.disableChildJobAlert(List<String> parentJobIds)
Disable child jobs Sla alert.
|
boolean |
SLAService.enableAlert(List<String> jobIds)
Enable jobs sla alert.
|
boolean |
SLAService.enableChildJobAlert(List<String> parentJobIds)
Enable child jobs sla alert.
|
void |
SLAService.init(Services services) |
boolean |
SLAService.updateRegistrationEvent(SLARegistrationBean reg) |
Copyright © 2015 Apache Software Foundation. All Rights Reserved.