Uses of Class
com.mulesoft.mule.runtime.module.batch.api.record.Record

Packages that use Record

Package	Description
com.mulesoft.mule.runtime.module.batch
com.mulesoft.mule.runtime.module.batch.api.notification
com.mulesoft.mule.runtime.module.batch.api.record
com.mulesoft.mule.runtime.module.batch.engine
com.mulesoft.mule.runtime.module.batch.engine.buffer
com.mulesoft.mule.runtime.module.batch.engine.queue
com.mulesoft.mule.runtime.module.batch.internal
com.mulesoft.mule.runtime.module.batch.internal.commit
com.mulesoft.mule.runtime.module.batch.internal.engine
com.mulesoft.mule.runtime.module.batch.internal.engine.buffer
com.mulesoft.mule.runtime.module.batch.internal.engine.queue
com.mulesoft.mule.runtime.module.batch.internal.engine.threading
com.mulesoft.mule.runtime.module.batch.internal.record
com.mulesoft.mule.runtime.module.batch.util

Uses of Record in com.mulesoft.mule.runtime.module.batch

Methods in com.mulesoft.mule.runtime.module.batch with parameters of type Record

Modifier and Type	Method and Description
int	BatchStepAggregator.add(Record record, BatchTransactionContext ctx) Adds a new record

Method parameters in com.mulesoft.mule.runtime.module.batch with type arguments of type Record

Modifier and Type	Method and Description
void	BatchProcessingListener.onSteppingQueueDispatch(BatchJobInstanceAdapter jobInstance, Collection<Record> records) Notifies that the given Records were queued into the stepping queue of the given BatchJobInstanceAdapter

Uses of Record in com.mulesoft.mule.runtime.module.batch.api.notification

Methods in com.mulesoft.mule.runtime.module.batch.api.notification that return Record

Modifier and Type	Method and Description
Record	BatchNotification.getRecord()

Constructors in com.mulesoft.mule.runtime.module.batch.api.notification with parameters of type Record

Constructor and Description
BatchNotification(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance, BatchStep step, Record record, Exception e, int action)
BatchNotification(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance, BatchStep step, Record record, int action)

Uses of Record in com.mulesoft.mule.runtime.module.batch.api.record

Methods in com.mulesoft.mule.runtime.module.batch.api.record that return Record

Modifier and Type	Method and Description
Record	Record.markAsFailedInStep(BatchStep step, Exception e) Registers that this record found an exception on the given BatchStep The given exception will be recoverable through the getStepExceptions() , getExceptionForStep(String) # methods
Record	Record.markAsProcessedByStep(BatchStep step) Registers that the given BatchStep has finished processing this record.

Constructors in com.mulesoft.mule.runtime.module.batch.api.record with parameters of type Record

Constructor and Description
RecordELAdapter(Record record)

Uses of Record in com.mulesoft.mule.runtime.module.batch.engine

Methods in com.mulesoft.mule.runtime.module.batch.engine that return Record

Modifier and Type	Method and Description
Record	BatchStepAdapter.onRecord(Record record, BatchTransactionContext ctx) Process the given Record for the given BatchJobInstanceAdapter

Methods in com.mulesoft.mule.runtime.module.batch.engine that return types with arguments of type Record

Modifier and Type	Method and Description
List<Record>	BatchEngine.getBlockFrom(BatchTransactionContext context) Returns the records in the stepping queue which corresponds to the BatchJobInstance referenced by the given context
Iterator<Record>	BatchJobInstanceStore.getFailedRecords(BatchJobInstanceAdapter jobInstance) Retrieves all the records of the given BatchJobInstanceAdapter that failed in at least one step and which execution has finished

Methods in com.mulesoft.mule.runtime.module.batch.engine with parameters of type Record

Modifier and Type	Method and Description
org.mule.runtime.core.api.event.CoreEvent.Builder	BatchEngine.createEventBuilder(Record record, BatchJobInstanceAdapter jobInstance) Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.
org.mule.runtime.core.api.event.CoreEvent.Builder	BatchEngine.createEventBuilder(Record record, BatchJobInstanceAdapter jobInstance, CompletableFuture<Void> externalCompletion) Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.
Record	BatchStepAdapter.onRecord(Record record, BatchTransactionContext ctx) Process the given Record for the given BatchJobInstanceAdapter

Method parameters in com.mulesoft.mule.runtime.module.batch.engine with type arguments of type Record

Modifier and Type	Method and Description
void	BatchJobInstanceStore.storeFailedRecords(BatchJobInstanceAdapter jobInstance, Collection<Record> record) Adds the given Records to the list of failed records
BatchJobInstanceAdapter	BatchEngine.updateStatisticsAndRoute(BatchTransactionContext ctx, List<Record> records)

Uses of Record in com.mulesoft.mule.runtime.module.batch.engine.buffer

Method parameters in com.mulesoft.mule.runtime.module.batch.engine.buffer with type arguments of type Record

Modifier and Type	Method and Description
void	BatchContextTransactionManager.rollback(BatchTransactionContext context, BatchJobInstanceAdapter jobInstance, List<Record> records, org.mule.runtime.api.exception.MuleException e) rollback

Uses of Record in com.mulesoft.mule.runtime.module.batch.engine.queue

Methods in com.mulesoft.mule.runtime.module.batch.engine.queue that return types with arguments of type Record

Modifier and Type	Method and Description
Iterator<List<Record>>	BatchQueueDelegate.iterator(BatchTransactionContext ctx) Returns a streaming Iterator to access the contents of the queue.
List<Record>	BatchQueueDelegate.poll(BatchTransactionContext ctx) Retrieves a block of Record

Method parameters in com.mulesoft.mule.runtime.module.batch.engine.queue with type arguments of type Record

Modifier and Type	Method and Description
void	BatchQueueDelegate.dispatch(BatchTransactionContext ctx, Collection<Record> records) Writes the given records into the queue
void	BatchQueueDelegate.dispatchAndCommit(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, BatchContextTransactionManager committer) Writes the given records into the queue and commits the transaction

Uses of Record in com.mulesoft.mule.runtime.module.batch.internal

Methods in com.mulesoft.mule.runtime.module.batch.internal that return Record

Modifier and Type	Method and Description
Record	DefaultBatchStep.onRecord(Record record, BatchTransactionContext ctx) Process the given Record for the given BatchJobInstanceAdapter

Methods in com.mulesoft.mule.runtime.module.batch.internal with parameters of type Record

Modifier and Type	Method and Description
int	DefaultBatchStepAggregator.add(Record record, BatchTransactionContext ctx)
Record	DefaultBatchStep.onRecord(Record record, BatchTransactionContext ctx) Process the given Record for the given BatchJobInstanceAdapter

Method parameters in com.mulesoft.mule.runtime.module.batch.internal with type arguments of type Record

Modifier and Type	Method and Description
void	BaseBatchProcessingListener.onSteppingQueueDispatch(BatchJobInstanceAdapter jobInstance, Collection<Record> records) Notifies that the given Records were queued into the stepping queue of the given BatchJobInstanceAdapter
void	DefaultBatchJobResult.updateFor(BatchJobAdapter job, Collection<Record> records) Updates the values in this instance
void	BatchJobResultAdapter.updateFor(BatchJobAdapter job, Collection<Record> records) Updates the values in this instance

Uses of Record in com.mulesoft.mule.runtime.module.batch.internal.commit

Constructor parameters in com.mulesoft.mule.runtime.module.batch.internal.commit with type arguments of type Record

Constructor and Description
ImmutableRecordAwareList(List<T> delegate, List<Record> records) Creates a new instance
RecordAwareEventIterator(Iterator<T> delegate, Iterator<Record> recordsIterator) Creates a new instance

Uses of Record in com.mulesoft.mule.runtime.module.batch.internal.engine

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine that return types with arguments of type Record

Modifier and Type	Method and Description
List<Record>	DefaultBatchEngine.getBlockFrom(BatchTransactionContext context)
Iterator<Record>	DefaultBatchJobInstanceStore.getFailedRecords(BatchJobInstanceAdapter jobInstance)

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine with parameters of type Record

Modifier and Type	Method and Description
org.mule.runtime.core.api.event.CoreEvent.Builder	DefaultBatchEngine.createEventBuilder(Record record, BatchJobInstanceAdapter jobInstance) Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.
org.mule.runtime.core.api.event.CoreEvent.Builder	DefaultBatchEngine.createEventBuilder(Record record, BatchJobInstanceAdapter jobInstance, CompletableFuture<Void> externalCompletion) Creates a new CoreEvent.Builder with the base attributes set for a CoreEvent to process the given record for the given jobInstance.

Method parameters in com.mulesoft.mule.runtime.module.batch.internal.engine with type arguments of type Record

Modifier and Type	Method and Description
void	DefaultBatchJobInstanceStore.storeFailedRecords(BatchJobInstanceAdapter jobInstance, Collection<Record> records) Adds the given Records to the list of failed records
BatchJobInstanceAdapter	DefaultBatchEngine.updateStatisticsAndRoute(BatchTransactionContext ctx, List<Record> records)

Uses of Record in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer that return Record

Modifier and Type	Method and Description
Record	StreamingAggregatorIteratorWrapper.getPrevious()

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer that return types with arguments of type Record

Modifier and Type	Method and Description
protected org.mule.runtime.api.util.Pair<Record,RecordELAdapter>	StreamingAggregatorIteratorWrapper.nextRecord()

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer with parameters of type Record

Modifier and Type	Method and Description
int	RecordBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContextProvider ctxProvider, Record record) Invokes RecordBuffer.add(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, Record) using the BatchTransactionContext returned by the context provider
int	AbstractRecordBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContextProvider ctxProvider, Record record) Invokes RecordBuffer.add(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, Record) using the BatchTransactionContext returned by the context provider
int	TransactionalQueueBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, Record record) buffers the given Record for the given BatchJobInstanceAdapter
int	RecordBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, Record record) buffers the given Record for the given BatchJobInstanceAdapter
int	InMemoryRecordBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, Record record) buffers the given Record for the given BatchJobInstanceAdapter
int	StreamingAggregatorBuffer.add(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, Record record)
static int	BufferUtils.addToBufferInSplitTransaction(BatchJobInstanceAdapter jobInstance, RecordBuffer buffer, BatchTransactionContext currentContext, BatchTransactionContextProvider contexts, Record record) Adds a record to the given buffer using a transaction other than the current one.

Method parameters in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer with type arguments of type Record

Modifier and Type	Method and Description
protected org.mule.runtime.core.api.event.CoreEvent	FixedAggregatorTransactionRecordBuffer.configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records)
protected org.mule.runtime.core.api.event.CoreEvent	StreamingAggregatorBuffer.configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records)
protected org.mule.runtime.core.api.event.CoreEvent	FixedAggregatorRecordBuffer.configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records)
protected abstract org.mule.runtime.core.api.event.CoreEvent	AggregatorRecordBuffer.configureChainEvent(org.mule.runtime.core.api.event.CoreEvent event, BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records) Configures the event (set payload, properties, etc) to is going to be used when flushing the aggregated records through the AggregatorRecordBuffer.chain
protected void	TransactionalQueueBuffer.doFlush(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, List<Record> records)
protected void	StreamingAggregatorInputQueueBuffer.doFlush(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, List<Record> records)
protected abstract void	InMemoryRecordBuffer.doFlush(BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records) Implement this logic to perform specific flushing logic
protected void	LoadingQueueBuffer.doFlush(BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records)
protected void	AggregatorRecordBuffer.doFlush(BatchJobInstanceAdapter jobInstance, com.google.common.collect.Multimap<BatchTransactionContext,Record> records) Executes the template returned by AggregatorRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap, Processor, MuleContext) using the CoreEvent returned by AggregatorRecordBuffer.configureChainEvent(CoreEvent, BatchJobInstanceAdapter, Multimap)
protected BatchProcessingTemplate	FixedAggregatorTransactionRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> contexts, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext)
protected BatchProcessingTemplate	StreamingAggregatorBuffer.makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> records, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext)
protected BatchProcessingTemplate	FixedAggregatorRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> contexts, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext)
protected abstract BatchProcessingTemplate	AggregatorRecordBuffer.makeProcessingTemplate(com.google.common.collect.Multimap<BatchTransactionContext,Record> records, org.mule.runtime.core.api.processor.Processor processor, org.mule.runtime.core.api.MuleContext muleContext) Returns the BatchProcessingTemplate through which AggregatorRecordBuffer.chain will be executed
protected void	AggregatorRecordBuffer.markError(BatchJobInstanceAdapter jobInstance, List<Record> records, Exception e) Sets the records as failed in this step
void	PartialErrorMatcher.match(List<Record> records, org.mule.runtime.core.api.event.CoreEvent event)
void	TransactionalQueueBuffer.rollback(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, org.mule.runtime.api.exception.MuleException e)
void	BatchContextTransactionRecorder.tryFlush(BatchTransactionContext ctx, List<Record> records) Attempts to flush records and update statistics.

Constructor parameters in com.mulesoft.mule.runtime.module.batch.internal.engine.buffer with type arguments of type Record

Constructor and Description
StreamingAggregatorIteratorWrapper(Iterator<List<Record>> delegate, BatchTransactionContextProvider outputContextProvider, BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, RecordBuffer outputQueueBuffer, int blockSize)

Uses of Record in com.mulesoft.mule.runtime.module.batch.internal.engine.queue

Methods in com.mulesoft.mule.runtime.module.batch.internal.engine.queue that return types with arguments of type Record

Modifier and Type	Method and Description
Iterator<List<Record>>	AbstractBatchQueueDelegate.iterator(BatchTransactionContext ctx)
List<Record>	AbstractBatchQueueDelegate.poll(BatchTransactionContext ctx) Retrieves a block of Record

Method parameters in com.mulesoft.mule.runtime.module.batch.internal.engine.queue with type arguments of type Record

Modifier and Type	Method and Description
void	SteppingQueueDelegate.dispatch(BatchTransactionContext ctx, Collection<Record> records) Writes the given records into the queue
void	AbstractBatchQueueDelegate.dispatch(BatchTransactionContext ctx, Collection<Record> records) Writes the given records into the queue
void	SteppingQueueDelegate.dispatchAndCommit(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, BatchContextTransactionManager manager)
void	AbstractBatchQueueDelegate.dispatchAndCommit(BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, List<Record> records, BatchContextTransactionManager manager)

Uses of Record in com.mulesoft.mule.runtime.module.batch.internal.engine.threading

Constructor parameters in com.mulesoft.mule.runtime.module.batch.internal.engine.threading with type arguments of type Record

Constructor and Description
BatchRecordWork(BatchEngine batchEngine, BatchJobAdapter job, BatchTransactionContext ctx, BatchProcessingListener listener, List<Record> block)

Uses of Record in com.mulesoft.mule.runtime.module.batch.internal.record

Methods in com.mulesoft.mule.runtime.module.batch.internal.record with parameters of type Record

Modifier and Type	Method and Description
boolean	RecordFilteringStrategy.acceptRecord(org.mule.runtime.core.api.event.CoreEvent event, Record record)

Uses of Record in com.mulesoft.mule.runtime.module.batch.util

Methods in com.mulesoft.mule.runtime.module.batch.util that return Record

Modifier and Type	Method and Description
static Record	BatchUtils.getRecord(org.mule.runtime.api.el.BindingContext bindingContext)
static Record	BatchUtils.getRecord(org.mule.runtime.core.api.event.CoreEvent event)
static Record	BatchUtils.toRecord(org.mule.runtime.core.api.event.CoreEvent event, Object object)

Method parameters in com.mulesoft.mule.runtime.module.batch.util with type arguments of type Record

Modifier and Type	Method and Description
static void	BatchUtils.completeWorkOnBlock(List<Record> block, boolean shouldRollback, BatchProcessingListener listener, BatchTransactionContext ctx) Perform the completion callback for each record in the block as well as any further completion operation needed related to the transaction context.