datu 0.3.4

datu - a data file utility
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! DataFusion [`DataFrame`] pipeline: sources, writers, transforms, and CLI/REPL execution.

mod execute;
mod from_path;
mod source;
mod steps;
mod transform;
mod writer;

#[cfg(test)]
mod tests;

pub use execute::DataFramePipeline;
pub use execute::DataFrameSink;
pub use source::DataFrameSource;
pub use steps::DataframeHead;
pub use steps::DataframeSample;
pub use steps::DataframeSelect;
pub use steps::DataframeTail;
pub use transform::DataframeToRecordBatch;
pub use transform::dataframe_apply_head;
pub use transform::dataframe_apply_sample;
pub use transform::dataframe_apply_tail;
pub use writer::DataFrameWriter;
pub use writer::write_dataframe_pipeline_output;

pub use crate::pipeline::write::write_record_batches_from_reader;