krabka_client_streams/dsl/
mod.rs

1//! The high-level `KStream` and `KTable` DSL.
2//!
3//! The DSL records a typed logical graph. It can then apply the JVM-compatible
4//! topology optimizations, and it lowers the graph to the Processor-API
5//! [`Topology`].
6//!
7//! [`Topology`]: crate::topology::Topology
8pub(crate) mod builder;
9pub mod cogrouped;
10pub mod config;
11pub mod emit;
12pub mod global_table;
13pub(crate) mod graph;
14pub mod kgrouped;
15pub(crate) mod kgrouped_table;
16pub mod kstream;
17pub mod ktable;
18pub(crate) mod lower;
19pub(crate) mod names;
20pub(crate) mod optimizer;
21pub(crate) mod processors;
22pub mod session_windowed_cogrouped;
23pub mod session_windowed_kgrouped;
24pub mod sliding_windowed_cogrouped;
25pub mod sliding_windowed_kgrouped;
26pub mod suppress;
27pub mod time_windowed_cogrouped;
28pub mod windowed_kgrouped;
29pub use builder::StreamsBuilder;
30pub use cogrouped::CogroupedKStream;
31pub use config::{Grouped, Joined, Materialized, Repartitioned, StreamJoined, VersionedConfig};
32pub use emit::EmitStrategy;
33pub use global_table::GlobalKTable;
34pub use kgrouped::KGroupedStream;
35pub use kgrouped_table::KGroupedTable;
36pub use kstream::{BranchedStream, KStream};
37pub use ktable::KTable;
38pub use session_windowed_cogrouped::SessionWindowedCogroupedStream;
39pub use session_windowed_kgrouped::SessionWindowedKGroupedStream;
40pub use sliding_windowed_cogrouped::SlidingWindowedCogroupedStream;
41pub use sliding_windowed_kgrouped::SlidingWindowedKGroupedStream;
42pub use suppress::{BufferConfig, Suppressed};
43pub use time_windowed_cogrouped::TimeWindowedCogroupedStream;
44pub use windowed_kgrouped::TimeWindowedKGroupedStream;
45pub mod windows;
46pub use windows::{
47    JoinWindows, SessionWindowedSerde, SessionWindows, SlidingWindows, TimeWindowedSerde,
48    TimeWindows, Window, Windowed,
49};
krabka_client_streams/dsl/mod.rs

krabka_client_streams/dsl/
mod.rs
