| Modifier and Type | Method and Description |
|---|---|
BatchStepAdapter |
BatchJobAdapter.getStepById(String stepId)
Returns the step of the given id
|
| Modifier and Type | Method and Description |
|---|---|
BatchQueueDelegate |
BatchQueueManager.streamingAggregatorInputQueue(BatchJobInstanceAdapter jobInstance,
BatchStepAdapter step)
Returns a
BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator |
BatchQueueDelegate |
BatchQueueManager.streamingAggregatorOutputQueue(BatchJobInstanceAdapter jobInstance,
BatchStepAdapter step)
Returns a
BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator |
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultBatchStep
Default implementation of
BatchStep |
| Modifier and Type | Method and Description |
|---|---|
BatchStepAdapter |
DefaultBatchJob.getStepById(String stepId)
Returns the step of the given id
|
| Modifier and Type | Method and Description |
|---|---|
List<BatchStepAdapter> |
BatchRecordProcessors.getSteps() |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultBatchStepAggregator.setStep(BatchStepAdapter step) |
| Modifier and Type | Method and Description |
|---|---|
void |
BatchRecordProcessors.setSteps(List<BatchStepAdapter> steps) |
| Modifier and Type | Field and Description |
|---|---|
protected BatchStepAdapter |
AbstractStreamingAggregatorQueueBuffer.step |
protected BatchStepAdapter |
AggregatorRecordBuffer.step |
| Constructor and Description |
|---|
AbstractStreamingAggregatorQueueBuffer(String name,
BatchEngine batchEngine,
BatchStepAdapter step) |
AggregatorRecordBuffer(String name,
int size,
BatchEngine batchEngine,
BatchStepAdapter step,
org.mule.runtime.core.api.processor.Processor chain,
org.mule.runtime.api.component.location.ComponentLocation location,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher,
org.mule.runtime.core.api.MuleContext muleContext) |
FixedAggregatorRecordBuffer(int blockSize,
boolean preserveMimeTypes,
BatchEngine batchEngine,
BatchStepAdapter step,
org.mule.runtime.core.api.processor.Processor chain,
org.mule.runtime.api.component.location.ComponentLocation location,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher,
org.mule.runtime.core.api.MuleContext muleContext) |
FixedAggregatorTransactionRecordBuffer(int blockSize,
boolean preserveMimeTypes,
BatchEngine batchEngine,
BatchStepAdapter step,
org.mule.runtime.core.api.processor.Processor chain,
org.mule.runtime.api.component.location.ComponentLocation location,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher,
org.mule.runtime.core.api.MuleContext muleContext) |
StreamingAggregatorBuffer(BatchEngine batchEngine,
BatchStepAdapter step,
org.mule.runtime.core.api.processor.Processor chain,
org.mule.runtime.api.notification.NotificationDispatcher notificationDispatcher,
org.mule.runtime.core.api.MuleContext muleContext) |
StreamingAggregatorInputQueueBuffer(BatchEngine batchEngine,
BatchStepAdapter step) |
StreamingAggregatorOutputQueueBuffer(BatchEngine batchEngine,
BatchStepAdapter step) |
| Modifier and Type | Field and Description |
|---|---|
protected BatchStepAdapter |
AbstractStreamingAggregatorQueueDelegate.step |
| Modifier and Type | Method and Description |
|---|---|
BatchQueueDelegate |
DefaultBatchQueueManager.streamingAggregatorInputQueue(BatchJobInstanceAdapter jobInstance,
BatchStepAdapter step)
Returns a
BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator |
BatchQueueDelegate |
DefaultBatchQueueManager.streamingAggregatorOutputQueue(BatchJobInstanceAdapter jobInstance,
BatchStepAdapter step)
Returns a
BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator |
| Constructor and Description |
|---|
AbstractStreamingAggregatorQueueDelegate(BatchJobInstanceAdapter jobInstance,
org.mule.runtime.core.api.util.queue.QueueManager queueManager,
long queueTimeout,
BatchStepAdapter step,
org.mule.runtime.api.serialization.ObjectSerializer serializer,
org.mule.runtime.core.api.MuleContext muleContext) |
StreamingAggregatorInputQueueDelegate(BatchJobInstanceAdapter jobInstance,
org.mule.runtime.core.api.util.queue.QueueManager queueManager,
long queueTimeout,
BatchStepAdapter step,
org.mule.runtime.api.serialization.ObjectSerializer serializer,
org.mule.runtime.core.api.MuleContext muleContext) |
StreamingAggregatorOutputQueueDelegate(BatchJobInstanceAdapter jobInstance,
org.mule.runtime.core.api.util.queue.QueueManager queueManager,
long queueTimeout,
BatchStepAdapter step,
org.mule.runtime.api.serialization.ObjectSerializer serializer,
org.mule.runtime.core.api.MuleContext muleContext) |
Copyright © 2006–2022 MuleSoft, Inc.. All rights reserved.