| Package | Description |
|---|---|
| org.mule.extension.aggregator.internal.operations |
| Modifier and Type | Method and Description |
|---|---|
void |
GroupBasedAggregatorOperations.aggregateByGroup(GroupBasedAggregatorParameterGroup aggregatorParameters,
IncrementalAggregationRoute incrementalAggregationRoute,
AggregationCompleteRoute onAggregationCompleteRoute,
org.mule.runtime.extension.api.runtime.process.RouterCompletionCallback completionCallback)
Aggregates a new event to the group and executes the routes and listeners if it corresponds.
|
void |
SizeBasedAggregatorOperations.aggregateBySize(SizeBasedAggregatorParameterGroup aggregatorParameters,
IncrementalAggregationRoute incrementalAggregationRoute,
AggregationCompleteRoute onAggregationCompleteRoute,
org.mule.runtime.extension.api.runtime.process.RouterCompletionCallback completionCallback)
Aggregates a new event and executes the routes and listeners if it corresponds.
|
void |
TimeBasedAggregatorOperations.aggregateByTime(TimeBasedAggregatorParameterGroup aggregatorParameters,
IncrementalAggregationRoute incrementalAggregationRoute,
org.mule.runtime.extension.api.runtime.process.RouterCompletionCallback completionCallback)
This aggregator aggregates elements until it reaches the specified time period.
|
Copyright © 2024 MuleSoft, Inc.. All rights reserved.