Expand description
Stream transformations and operations.
Structs§
- Aggregate
Operator - Aggregate operator.
- AvgAggregate
- Average aggregate (stores sum and count).
- Broadcast
Partitioner - Broadcast partitioner (returns all partitions).
- CoGroup
Operator - CoGroup operator for two streams.
- Concat
Fold - Simple concatenation fold function.
- Count
Aggregate - Count aggregate.
- Element
KeySelector - Simple key selector that uses the element’s key field.
- Filter
Transform - Filter transformation.
- Flat
MapTransform - FlatMap transformation.
- Fold
Operator - Fold operator.
- Hash
Partitioner - Hash-based partitioner.
- Interval
Join - Interval join operator.
- Join
Config - Configuration for join operations.
- Join
Operator - Join operator for two streams.
- KeyBy
Transform - KeyBy transformation.
- MapTransform
- Map transformation.
- MaxAggregate
- Max aggregate.
- MinAggregate
- Min aggregate.
- Range
Partitioner - Range-based partitioner.
- Reduce
Operator - Reduce operator.
- Round
Robin Partitioner - Round-robin partitioner.
- Scan
Operator - Scan operator (like fold but emits intermediate results).
- SumAggregate
- Sum aggregate.
- SumReduce
- Simple sum reduce function.
Enums§
- Join
Type - Type of join operation.
- Partition
Strategy - Strategy for partitioning stream elements.
Traits§
- Aggregate
Function - Trait for aggregate functions.
- Fold
Function - Function for folding elements with an accumulator.
- KeySelector
- Key selector function for partitioning.
- Partitioner
- Partitioner trait.
- Reduce
Function - Function for reducing elements.