| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
BatchManager.getJobInstance(String jobName,
String jobInstanceId)
Finds a
BatchJobInstance and returns it |
| Modifier and Type | Method and Description |
|---|---|
Iterator<BatchJobInstance> |
BatchManager.getExecutingInstances()
Returns the instance of
BatchJobInstance that are in an executing state |
Iterator<BatchJobInstance> |
BatchManager.getJobInstances(String jobName)
Returns all the
BatchJobInstance available for the given jobName |
| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
BatchNotification.getJobInstance() |
| Constructor and Description |
|---|
BatchNotification(BatchJobInstance jobInstance,
BatchStep step,
Exception e,
int action) |
BatchNotification(BatchJobInstance jobInstance,
BatchStep step,
int action) |
BatchNotification(BatchJobInstance jobInstance,
BatchStep step,
Record record,
Exception e,
int action) |
BatchNotification(BatchJobInstance jobInstance,
BatchStep step,
Record record,
int action) |
BatchNotification(BatchJobInstance jobInstance,
Exception exception,
int action) |
BatchNotification(BatchJobInstance jobInstance,
int action) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
BatchJobInstanceAdapter
Adapter interface to access
BatchJobInstance related functionality that we don't want exposed as part of the API |
| Modifier and Type | Method and Description |
|---|---|
<T extends BatchJobInstance> |
BatchJobInstanceStore.getExecutingInstances()
Retrieves all the
BatchJobInstance that are currently elegible for
execution. |
<T extends BatchJobInstance> |
BatchJobInstanceStore.getJobInstances(String jobName)
Returns all the
BatchJobInstance for the given job name |
| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
BatchJobAdapter.execute(org.mule.runtime.core.api.event.CoreEvent muleEvent)
Executes the batch and generates a
BatchJobInstance in loading state |
| Modifier and Type | Method and Description |
|---|---|
int |
BatchEngine.getBlockSize(BatchJobInstance jobInstance)
|
BatchJobAdapter |
BatchEngine.getJobFor(BatchJobInstance jobInstance)
Returns the owning
BatchJobAdapter for the given
BatchJobInstance |
boolean |
BatchJobInstanceStore.remove(BatchJobInstance jobInstance)
removes the given
BatchJobInstance |
| Modifier and Type | Method and Description |
|---|---|
boolean |
HistoryExpirationPolicy.shouldExpire(BatchJobInstance jobInstance)
Determines if the
jobInstance should be expired from the historic records. |
boolean |
HistoryExpirationCriteria.shouldExpire(BatchJobInstance jobInstance)
Determines if
jobInstance should be expired from the historic records based on the relationship between
getCreationTime() and HistoryExpirationCriteria.maxAge/HistoryExpirationCriteria.ageUnit |
| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
BatchException.getJobInstance() |
| Constructor and Description |
|---|
BatchException(org.mule.runtime.api.i18n.I18nMessage message,
BatchJobInstance jobInstance) |
BatchException(org.mule.runtime.api.i18n.I18nMessage message,
Throwable cause,
BatchJobInstance jobInstance) |
BatchException(Throwable cause,
BatchJobInstance jobInstance) |
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultBatchJobInstance |
class |
ImmutableBatchJobInstance
Immutable view of a
BatchJobInstance |
| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
DefaultBatchJob.execute(org.mule.runtime.core.api.event.CoreEvent event) |
BatchJobInstance |
DefaultBatchManager.getJobInstance(String jobName,
String jobInstanceId)
Finds a
BatchJobInstance and returns it |
| Modifier and Type | Method and Description |
|---|---|
Iterator<BatchJobInstance> |
DefaultBatchManager.getExecutingInstances()
Returns the instance of
BatchJobInstance that are in an executing state |
Iterator<BatchJobInstance> |
DefaultBatchManager.getJobInstances(String jobName)
Returns all the
BatchJobInstance available for the given jobName |
| Modifier and Type | Method and Description |
|---|---|
protected List<BatchProcessingListener> |
BaseBatchProcessingListenerOwner.getListeners(BatchJobInstance jobInstance) |
| Constructor and Description |
|---|
ImmutableBatchJobInstance(BatchJobInstance jobInstance) |
| Modifier and Type | Method and Description |
|---|---|
<T extends BatchJobInstance> |
DefaultBatchJobInstanceStore.getJobInstances(String jobName)
Returns all the
BatchJobInstance for the given job name |
| Modifier and Type | Method and Description |
|---|---|
int |
DefaultBatchEngine.getBlockSize(BatchJobInstance jobInstance)
|
BatchJobAdapter |
DefaultBatchEngine.getJobFor(BatchJobInstance jobInstance)
Returns the owning
BatchJobAdapter for the given
BatchJobInstance |
boolean |
DefaultBatchJobInstanceStore.remove(BatchJobInstance jobInstance)
removes the given
BatchJobInstance |
| Modifier and Type | Method and Description |
|---|---|
long |
StreamingAggregatorInputQueueBuffer.getFlushedRecordCount(BatchJobInstance jobInstance) |
| Modifier and Type | Method and Description |
|---|---|
void |
BatchWorkManager.executable(BatchJobInstance jobInstance)
Tracks the given
jobInstance as an executable one. |
void |
DefaultBatchWorkManager.executable(BatchJobInstance jobInstance)
Tracks the given
jobInstance as an executable one. |
| Constructor and Description |
|---|
BatchFailureHandlingException(Throwable cause,
Throwable derivate,
BatchJobInstance jobInstance)
Builds this exception
|
| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
RoundRobinBatchJobSchedulingStrategy.next(List<BatchJobInstance> executableInstances) |
BatchJobInstance |
CreationTimeSequentialSchedulingStrategy.next(List<BatchJobInstance> executableInstances) |
| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
RoundRobinBatchJobSchedulingStrategy.next(List<BatchJobInstance> executableInstances) |
BatchJobInstance |
CreationTimeSequentialSchedulingStrategy.next(List<BatchJobInstance> executableInstances) |
| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
BatchJobInstanceSchedulingStrategy.next(List<BatchJobInstance> executableInstances) |
| Modifier and Type | Method and Description |
|---|---|
BatchJobInstance |
BatchJobInstanceSchedulingStrategy.next(List<BatchJobInstance> executableInstances) |
| Modifier and Type | Method and Description |
|---|---|
static String |
BatchUtils.buildExceptionLogMessage(BatchJobInstance jobInstance,
BatchStep step,
Exception exception) |
Copyright © 2006–2019 MuleSoft, Inc.. All rights reserved.