Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.event.transformation.event.impl

Class TransformableEventIterable

java.lang.Object

io.axoniq.axonserver.connector.event.transformation.event.impl.TransformableEventIterable

All Implemented Interfaces:

TransformableEventStream

public class TransformableEventIterable
extends Object
implements TransformableEventStream

TransformableEventStream implementation that is based on an Iterable.

Since:

2023.1.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor	Description
TransformableEventIterable(Iterable<EventWithToken> events)	Constructs an instance based on the specified Iterable

Method Summary

Modifier and Type	Method	Description
TransformableEventStream	filter(Predicate<EventWithToken> predicate)	Filters events based on the provided predicate.
EventTransformationExecutor	transform(String transformationDescription, EventTransformer eventTransformer)	Transforms events by providing transformation description and the transformer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransformableEventIterable

public TransformableEventIterable(Iterable<EventWithToken> events)

Constructs an instance based on the specified Iterable

Parameters:

events - the Iterable of EventWithTokens used to retrieve events

Method Detail

filter

public TransformableEventStream filter(Predicate<EventWithToken> predicate)

Description copied from interface: TransformableEventStream

Filters events based on the provided predicate.

Specified by:

filter in interface TransformableEventStream

Parameters:

predicate - the predicate used for filtering events

Returns:

filtered stream

transform

public EventTransformationExecutor transform(String transformationDescription,
                                             EventTransformer eventTransformer)

Description copied from interface: TransformableEventStream

Transforms events by providing transformation description and the transformer.

Specified by:

transform in interface TransformableEventStream

Parameters:

transformationDescription - the description of the transformation

eventTransformer - the transformer

Returns:

the executor used to transform events