Modifier and Type | Class and Description |
---|---|
class |
ArrayListAggregationPolicy<S>
An aggregation policy that creates
ArrayList aggregates. |
class |
IdentityAggregationPolicy<T extends Message>
An aggregation policy that returns the original unmodified
message as the aggregate.
|
class |
MappingAggregationPolicy<S,T extends Message>
An aggregation policy that performs a simple map operation
on the given message.
|
Constructor and Description |
---|
AggregatingMessageProducer(String id,
AggregationPolicy<S,T,?> policy) |
Aggregator(String id,
AggregationPolicy<S,T,?> policy,
AggregatingMessageProducer<S,T> messageProducer) |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<S,T,?> |
SinkModule.getAggregationPolicy()
Defines how messages should be combined, and when they
should be "released".
|
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<S,T,?> |
MockSinkModule.getAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<Event,Log,Log> |
EventSinkModule.getAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<MinionIdentityDTO,MinionIdentityDTO,MinionIdentityDTO> |
HeartbeatModule.getAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<SyslogConnection,SyslogMessageLogDTO,SyslogMessageLogDTO> |
SyslogSinkModule.getAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<TelemetryMessage,TelemetryProtos.TelemetryMessageLog,TelemetryProtos.TelemetryMessageLog.Builder> |
TelemetrySinkModule.getAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<TrapInformationWrapper,TrapLogDTO,TrapLogDTO> |
TrapSinkModule.getAggregationPolicy() |
Copyright © 2020. All rights reserved.