Module prelude

Re-exports

pub use crate::arrow_batch_iter::set_global_num_thread;

pub use crate::arrow_batch_iter::RecordBatchIterator;

pub use crate::data_order::coordinate;

pub use crate::data_order::DataOrder;

pub use crate::destinations::arrow::ArrowDestination;

pub use crate::destinations::arrow::ArrowPartitionWriter;

pub use crate::destinations::arrow::ArrowTypeSystem;

pub use crate::destinations::arrowstream::ArrowDestination as ArrowStreamDestination;

pub use crate::destinations::arrowstream::ArrowPartitionWriter as ArrowStreamPartitionWriter;

pub use crate::destinations::arrowstream::ArrowTypeSystem as ArrowStreamTypeSystem;

pub use crate::destinations::Consume;

pub use crate::destinations::Destination;

pub use crate::destinations::DestinationPartition;

pub use crate::errors::ConnectorXError;

pub use crate::errors::ConnectorXOutError;

pub use crate::fed_rewriter::rewrite_sql;

pub use crate::fed_rewriter::FederatedDataSourceInfo;

pub use crate::fed_rewriter::Plan;

pub use crate::get_arrow::get_arrow;

pub use crate::get_arrow::new_record_batch_iter;

pub use crate::sources::bigquery::BigQuerySource;

pub use crate::sources::csv::CSVSource;

pub use crate::sources::dummy::DummySource;

pub use crate::sources::mssql::MsSQLSource;

pub use crate::sources::mysql::MySQLSource;

pub use crate::sources::oracle::OracleSource;

pub use crate::sources::postgres::PostgresSource;

pub use crate::sources::sqlite::SQLiteSource;

pub use crate::sources::trino::TrinoSource;

pub use crate::sources::PartitionParser;

pub use crate::sources::Produce;

pub use crate::sources::Source;

pub use crate::sources::SourcePartition;

pub use crate::typesystem::Transport;

pub use crate::typesystem::TypeConversion;

pub use crate::source_router::*;

pub use crate::transports::*;

Structs

Dispatcher

A dispatcher takes a S: Source, a D: Destination, a TP: Transport and a vector of queries as input to load data from S to D using the queries.

Enums

CXQuery