//! Everything you'll ever need to build your processing chains.
pub use crate::input::InputStreamBuilder;
pub use crate::add::Column;
pub use crate::flush::Target;
pub use crate::row_stream::RowStream;
pub use crate::{Row, Headers, RowResult};
pub use crate::reduce::reducer::Reducer;
pub use crate::reduce::aggregate::Aggregate;
pub use crate::group::GroupCriteria;
pub use crate::mock::MockStream;
pub use crate::Error;