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::arrow2::Arrow2Destination;
• 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::get_arrow2::get_arrow2;
• 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::ParameterizedFunc;
• pub use crate::typesystem::ParameterizedOn;
• pub use crate::typesystem::Realize;
• pub use crate::typesystem::Transport;
• pub use crate::typesystem::TypeAssoc;
• pub use crate::typesystem::TypeConversion;
• pub use crate::typesystem::TypeSystem;
• 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