Module operators 

Structs

FilterOperator

FlatMapOperator

MapOperator

WindowAggregator

WindowSkipper

WindowSorter

sort_by operator for windowed stream.

WindowTimestampSorter

sort_by_ts operator for windowed stream.

Enums

SortOrder

Specify sorting method of sort_by_ts