DoStream streams data from the outlet to inlet.

FanOut creates a number of identical flows from the single outlet.

Flatten creates a Flow to flatten the stream of slices.

Merge merges multiple flows into a single flow.

NewBatch returns a new Batch operator using the specified maximum batch size and the time interval.

NewFilter returns a new Filter operator.

NewFlatMap returns a new FlatMap operator.

NewKeyed returns a new Keyed operator, which takes a stream and splits it into multiple streams based on the keys extracted from the elements using the keySelector function.

NewMap returns a new Map operator.

NewPassThrough returns a new PassThrough operator.

NewReduce returns a new Reduce operator.

NewSessionWindow returns a new SessionWindow operator.

NewSlidingWindow returns a new SlidingWindow operator based on processing time.

NewSlidingWindowWithExtractor returns a new SlidingWindow operator based on event time.

NewThrottler returns a new Throttler operator.

NewTumblingWindow returns a new TumblingWindow operator.

RoundRobin creates a balanced number of flows from the single outlet.

Split splits the stream into two flows according to the given boolean predicate.

ZipWith combines elements from multiple input streams using a combiner function.

Backpressure slows down upstream ingestion when the element buffer overflows.

Discard drops incoming elements when the element buffer overflows.

Batch processor breaks a stream of elements into batches based on size or timing.

Filter filters incoming elements using a filter predicate.

FlatMap takes one element and produces zero, one, or more elements.

Keyed represents a flow where stream elements are partitioned by key using a provided key selector function.

Map takes one element and produces one element.

PassThrough retransmits incoming elements downstream as they are.

Reduce represents a “rolling” reduce on a data stream.

SessionWindow generates groups of elements by sessions of activity.

SlidingWindow assigns elements to windows of fixed length configured by the window size parameter.

Throttler limits the throughput to a specific number of elements per time unit.

TumblingWindow assigns each element to a window of a specified window size.

FilterPredicate represents a filter predicate (boolean-valued function).

FlatMapFunction represents a FlatMap transformation function.

MapFunction represents a Map transformation function.

ReduceFunction combines the current element with the last reduced value.

ThrottleMode represents Throttler's processing behavior when its element buffer overflows.