Module erdos::dataflow::operators

Library of generic operators for building ERDOS applications.

Structs

ConcatOperator

Merges the contents of two streams.

FilterOperator

Filters an incoming stream of type D, retaining messages in the stream that the provided condition function evaluates to true when applied.

FlatMapOperator

Maps an incoming stream of type D to a stream of type I::Item using the provided function.

SplitOperator

Splits an incoming stream of type D1 into two different streams of type D1 using the provided condition function. When evaluated to true, sends messages to left stream, and right stream otherwise.

TimestampJoinOperator

Joins messages with matching timestamps from two different streams.

Traits

Concat

Extension trait for merging the contents of two streams.

Filter

Join

Extension trait for joining pairs of streams.

Map

Extension trait for mapping a stream of type D1 to a stream of type D2.

Split