Package | Description |
---|---|
com.asakusafw.yaess.basic |
Basic modules for YAESS.
|
com.asakusafw.yaess.core |
Core models/interfaces for YAESS.
|
com.asakusafw.yaess.flowlog |
Generate logs for individual jobflow executions.
|
com.asakusafw.yaess.jobqueue |
YAESS Hadoop Script Handlers for Job Queue.
|
com.asakusafw.yaess.jsch |
YAESS Script Handlers via JSch.
|
com.asakusafw.yaess.multidispatch |
YAESS Script Handler Dispatcher.
|
com.asakusafw.yaess.paralleljob |
Simple Parallel Job Scheduler Plug-in for YAESS.
|
Modifier and Type | Method and Description |
---|---|
protected void |
BasicHadoopScriptHandler.configureExtension(ServiceProfile<?> profile) |
protected abstract void |
ProcessHadoopScriptHandler.configureExtension(ServiceProfile<?> profile)
Configures this handler internally (extension point).
|
protected abstract void |
ProcessCommandScriptHandler.configureExtension(ServiceProfile<?> profile)
Configures this handler internally (extension point).
|
protected void |
BasicCommandScriptHandler.configureExtension(ServiceProfile<?> profile) |
void |
BasicLockProvider.doConfigure(ServiceProfile<?> profile) |
protected void |
BasicMonitorProvider.doConfigure(ServiceProfile<?> profile) |
protected void |
BasicJobScheduler.doConfigure(ServiceProfile<?> profile) |
protected void |
ProcessHadoopScriptHandler.doConfigure(ServiceProfile<?> profile,
Map<String,String> desiredProperties,
Map<String,String> desiredEnvironmentVariables) |
protected void |
ProcessCommandScriptHandler.doConfigure(ServiceProfile<?> profile,
Map<String,String> desiredProperties,
Map<String,String> desiredEnvironmentVariables) |
Modifier and Type | Method and Description |
---|---|
ServiceProfile<CoreProfile> |
YaessProfile.getCore()
Returns a core profile.
|
ServiceProfile<HadoopScriptHandler> |
YaessProfile.getHadoopHandler()
Returns a Hadoop script handler.
|
ServiceProfile<ExecutionLockProvider> |
YaessProfile.getLocks()
Returns a lock provider.
|
ServiceProfile<ExecutionMonitorProvider> |
YaessProfile.getMonitors()
Returns a monitor provider.
|
ServiceProfile<JobScheduler> |
YaessProfile.getScheduler()
Returns a job scheduler.
|
static <T extends Service> |
ServiceProfile.load(Properties properties,
String prefix,
Class<T> serviceBaseClass,
ClassLoader classLoader)
Deprecated.
use
load(Properties, String, Class, ProfileContext) instead |
static <T extends Service> |
ServiceProfile.load(Properties properties,
String prefix,
Class<T> serviceBaseClass,
ProfileContext context)
Loads a service profile with the specified key prefix.
|
Modifier and Type | Method and Description |
---|---|
Map<String,ServiceProfile<CommandScriptHandler>> |
YaessProfile.getCommandHandlers()
Returns command script handlers for each target profile name.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionScriptHandlerBase.configure(ServiceProfile<?> profile) |
void |
CoreProfile.configure(ServiceProfile<?> profile) |
void |
ExecutionLockProvider.configure(ServiceProfile<?> profile) |
void |
ExecutionMonitorProvider.configure(ServiceProfile<?> profile) |
void |
JobScheduler.configure(ServiceProfile<?> profile) |
void |
Service.configure(ServiceProfile<?> profile)
Configures this service.
|
protected void |
CoreProfile.doConfigure(ServiceProfile<?> profile)
Configures this service internally (extention point).
|
protected abstract void |
ExecutionLockProvider.doConfigure(ServiceProfile<?> profile)
Configures this provider internally (extention point).
|
protected void |
ExecutionMonitorProvider.doConfigure(ServiceProfile<?> profile)
Configures this service internally (extention point).
|
protected void |
JobScheduler.doConfigure(ServiceProfile<?> profile)
Configures this service internally (extention point).
|
protected abstract void |
ExecutionScriptHandlerBase.doConfigure(ServiceProfile<?> profile,
Map<String,String> desiredProperties,
Map<String,String> desiredEnvironmentVariables)
Configures this handler internally (extention point).
|
Constructor and Description |
---|
YaessProfile(ServiceProfile<CoreProfile> core,
ServiceProfile<ExecutionMonitorProvider> monitors,
ServiceProfile<ExecutionLockProvider> locks,
ServiceProfile<JobScheduler> scheduler,
ServiceProfile<HadoopScriptHandler> hadoopHandler,
Collection<ServiceProfile<CommandScriptHandler>> commandHandlers)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
static FlowLoggerProfile |
FlowLoggerProfile.convert(ServiceProfile<?> profile)
Converts the generic profile into the structured profile about
FlowLogger . |
protected void |
FlowLoggerProvider.doConfigure(ServiceProfile<?> profile) |
Modifier and Type | Method and Description |
---|---|
static JobClientProfile |
JobClientProfile.convert(ServiceProfile<?> profile)
Converts general profile into the corresponded this profile.
|
protected void |
QueueHadoopScriptHandler.doConfigure(ServiceProfile<?> profile,
Map<String,String> desiredProperties,
Map<String,String> desiredEnvironmentVariables) |
Modifier and Type | Method and Description |
---|---|
protected void |
SshHadoopScriptHandler.configureExtension(ServiceProfile<?> profile) |
protected void |
SshCommandScriptHandler.configureExtension(ServiceProfile<?> profile) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionScriptHandlerDispatcher.configure(ServiceProfile<?> profile) |
Modifier and Type | Method and Description |
---|---|
protected void |
ParallelJobScheduler.doConfigure(ServiceProfile<?> profile) |
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.