|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
JobExecution as ABANDONED.
AsyncItemProcessor.setDelegate(ItemProcessor)).
AsynchronousFailureException based on a message and
another exception.
AsynchronousFailureException based on a message.
ItemProcessor that delegates to a nested processor and in the
background.Menu implementations.StepLocator implementation that just looks in its enclosing bean
factory for components of type Step.ChunkHandler based on a ChunkProcessor.StepContribution.JobService.listJobExecutions(int, int).
job instances in the repository
for a given job name.
JobService.listJobs(int, int).
Step, delegating execution to it,
but serving all other operations locally.ItemReader with hard-coded input data.ItemWriter which only logs data it receives.FileService.File to a JobLaunchRequest with a job parameter
input.file equal to the path of the file.File to a Spring Resource so it can be consumed by a
generic consumer.[domain]:type=JobExecution,name=[jobName].
[domain]:type=JobExecution,name=[jobName],step=[stepName].
JobExecution by id.
JobExecutions for a specific job name in
reverse order of creation (so normally of execution).
JobExecutions in reverse order of creation
(so normally of execution).
job instance by id.
JobParameters used to execute a job successfully.
SimpleJobService from the configuration provided.
ChunkHandler from the ChunkProcessor extracted from the step provided.
Step instances.
SimpleJobServiceFactoryBean.getObject().
RequestMethod.
Step.
StepExecution from its id and that of its parent
JobExecution.
step executions for a given job execution
(by id).
Step.
StepExecutionRequest objects to the request channel of the MessagingOperations, and then
receives the result back as a list of StepExecution on a reply channel.
JobParametersIncrementer.
JobExecution instances.JobConfigurationRequest to a Spring Resource so it
can be handled by a generic consumer.Resource and create an
ApplicationContext, registering any Job instances defined in
a JobRegistry.JobExecutionMetrics.JobLauncher that synchronizes jobs globally so that
only one execution of a given Job can be active at once.Job and its JobParameters forming a request for a job to be launched.JobLaunchRequest and returning a JobExecution.JobLocator.
JobLaunchRequest for restarting the last failed
execution of the Job.JobParameters
for rendering.JobLaunchRequest so that it picks up the job parameters from
the last execution if possible.job executions in descending order of
creation (usually close to execution order).
job executions for a job in descending
order of creation (usually close to execution order).
job instances in descending order of
creation (usually close to order of execution).
step executions for a step in descending
order of creation (usually close to execution order).
FileService that deals with files only in the
local file system.Menu contributions.PartitionHandler that uses MessageChannel instances to send instructions to remote workers and
receive their responses.ChannelInterceptor that turns a pollable channel into a "pass-thru channel": if a client calls
receive() on the channel it will delegate to a MessageSource to pull the message directly from
an external source.MessageSource and send immediately to the input channel, so that the call that we are
intercepting always a message to receive.
StepExecutionDao interface to add additional search
features.MessageSourcePollerInterceptor.preReceive(MessageChannel)).
ChunkProcessor.
DataSource.
ItemProcessor to use to delegate processing to in a
background thread.
StepExecutionSplitter in the MessageChannelPartitionHandler.handle(StepExecutionSplitter, StepExecution) method,
instructing it how many StepExecution instances are required, ideally.
StepExecutionMetrics.
JobExplorer to use to inspect existing executions.
StepExecution
completion.
JobRepository needed for updates to execution data.
FileService.
StepContribution instances coming back from remote workers.
JobExecutionMetrics.
Step to execute for each request.
Step that will be used to execute the partitioned StepExecution.
TaskExecutor to be used to execute the
tasks submitted.
TaskExecutor to use to allow the item processing to proceed
in the background.
JobService that delegates most of its work to other
off-the-shelf components.JobService that makes the configuration of its
various ingredients as convenient as possible.StepContribution instances that can be aggregated and used to update an ongoing
StepExecution.ChannelInterceptor that adds the current StepExecution (if
there is one) as a header to the message.StepExecutionMetrics.MessageEndpoint that can handle a StepExecutionRequest and
return a StepExecution as the result.Step instances given a StepLocator.JobLaunchRequest consisting of a reference to a
Job and some JobParameters.Poller implementation that uses a TaskScheduler to poll in
a background thread.TaskExecutor with a throttle limit which works by delegating to an
existing task executor and limiting the number of tasks submitted.ThrottledTaskExecutor with infinite
(Integer.MAX_VALUE) throttle limit.
ThrottledTaskExecutor with infinite
(Integer.MAX_VALUE) throttle limit.
ThrottledTaskExecutor with finite throttle
limit.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||