oxigdal-streaming 0.1.4

Real-time data processing and streaming pipelines for OxiGDAL
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

//! Stream transformations and operations.

mod aggregate;
mod join;
mod partition;
mod reduce;
mod transform;

pub use aggregate::{
    AggregateFunction, AggregateOperator, AvgAggregate, CountAggregate, MaxAggregate, MinAggregate,
    SumAggregate,
};
pub use join::{CoGroupOperator, IntervalJoin, JoinConfig, JoinOperator, JoinType};
pub use partition::{
    BroadcastPartitioner, ElementKeySelector, HashPartitioner, KeySelector, PartitionStrategy,
    Partitioner, RangePartitioner, RoundRobinPartitioner,
};
pub use reduce::{
    ConcatFold, FoldFunction, FoldOperator, ReduceFunction, ReduceOperator, ScanOperator, SumReduce,
};
pub use transform::{FilterTransform, FlatMapTransform, KeyByTransform, MapTransform};