List of all items

Structs

• arrow_batch_iter::ArrowBatchIter
• destinations::arrow2::Arrow2Destination
• destinations::arrow2::ArrowPartitionWriter
• destinations::arrow2::typesystem::DateTimeWrapperMicro
• destinations::arrow2::typesystem::NaiveDateTimeWrapperMicro
• destinations::arrow2::typesystem::NaiveTimeWrapperMicro
• destinations::arrow::ArrowDestination
• destinations::arrow::ArrowPartitionWriter
• destinations::arrow::typesystem::DateTimeWrapperMicro
• destinations::arrow::typesystem::NaiveDateTimeWrapperMicro
• destinations::arrow::typesystem::NaiveTimeWrapperMicro
• destinations::arrowstream::ArrowDestination
• destinations::arrowstream::ArrowPartitionWriter
• fed_rewriter::FederatedDataSourceInfo
• fed_rewriter::Plan
• partition::PartitionQuery
• prelude::Dispatcher
• source_router::SourceConn
• sources::bigquery::BigQueryDialect
• sources::bigquery::BigQuerySource
• sources::bigquery::BigQuerySourceParser
• sources::bigquery::BigQuerySourcePartition
• sources::csv::CSVSource
• sources::csv::CSVSourcePartition
• sources::csv::CSVSourcePartitionParser
• sources::dummy::DummySource
• sources::dummy::DummySourcePartition
• sources::dummy::DummySourcePartitionParser
• sources::mssql::FloatN
• sources::mssql::IntN
• sources::mssql::MsSQLSource
• sources::mssql::MsSQLSourceParser
• sources::mssql::MsSQLSourcePartition
• sources::mysql::MySQLBinarySourceParser
• sources::mysql::MySQLSource
• sources::mysql::MySQLSourcePartition
• sources::mysql::MySQLTextSourceParser
• sources::oracle::OracleDialect
• sources::oracle::OracleSource
• sources::oracle::OracleSourcePartition
• sources::oracle::OracleTextSourceParser
• sources::postgres::PostgresBinarySourcePartitionParser
• sources::postgres::PostgresCSVSourceParser
• sources::postgres::PostgresRawSourceParser
• sources::postgres::PostgresSimpleSourceParser
• sources::postgres::PostgresSource
• sources::postgres::PostgresSourcePartition
• sources::postgres::PostgresTypePairs
• sources::sqlite::SQLiteSource
• sources::sqlite::SQLiteSourcePartition
• sources::sqlite::SQLiteSourcePartitionParser
• sources::trino::TrinoDialect
• sources::trino::TrinoPartitionQueryResult
• sources::trino::TrinoSource
• sources::trino::TrinoSourcePartition
• sources::trino::TrinoSourcePartitionParser
• sources::trino::__TrinoPartitionQueryResultSeed
• transports::BigQueryArrow2Transport
• transports::BigQueryArrowStreamTransport
• transports::BigQueryArrowTransport
• transports::CSVArrowTransport
• transports::DummyArrow2Transport
• transports::DummyArrowTransport
• transports::MsSQLArrow2Transport
• transports::MsSQLArrowStreamTransport
• transports::MsSQLArrowTransport
• transports::MySQLArrow2Transport
• transports::MySQLArrowStreamTransport
• transports::MySQLArrowTransport
• transports::OracleArrow2Transport
• transports::OracleArrowStreamTransport
• transports::OracleArrowTransport
• transports::PostgresArrow2Transport
• transports::PostgresArrowStreamTransport
• transports::PostgresArrowTransport
• transports::SQLiteArrow2Transport
• transports::SQLiteArrowStreamTransport
• transports::SQLiteArrowTransport
• transports::TrinoArrow2Transport
• transports::TrinoArrowStreamTransport
• transports::TrinoArrowTransport

Enums

• data_order::DataOrder
• destinations::arrow2::Arrow2DestinationError
• destinations::arrow2::typesystem::Arrow2TypeSystem
• destinations::arrow::ArrowDestinationError
• destinations::arrow::typesystem::ArrowTypeSystem
• destinations::arrowstream::ArrowDestinationError
• destinations::arrowstream::typesystem::ArrowTypeSystem
• errors::ConnectorXError
• errors::ConnectorXOutError
• errors::ProduceContext
• prelude::CXQuery
• source_router::SourceType
• sources::bigquery::BigQuerySourceError
• sources::bigquery::BigQueryTypeSystem
• sources::csv::CSVSourceError
• sources::csv::CSVTypeSystem
• sources::dummy::DummyTypeSystem
• sources::mssql::MsSQLSourceError
• sources::mssql::MsSQLTypeSystem
• sources::mysql::BinaryProtocol
• sources::mysql::MySQLSourceError
• sources::mysql::MySQLTypeSystem
• sources::mysql::TextProtocol
• sources::oracle::OracleSourceError
• sources::oracle::OracleTypeSystem
• sources::postgres::BinaryProtocol
• sources::postgres::CSVProtocol
• sources::postgres::CursorProtocol
• sources::postgres::PostgresSourceError
• sources::postgres::PostgresTypeSystem
• sources::postgres::SimpleProtocol
• sources::sqlite::SQLiteSourceError
• sources::sqlite::SQLiteTypeSystem
• sources::trino::errors::TrinoSourceError
• sources::trino::typesystem::TrinoTypeSystem
• transports::BigQueryArrow2TransportError
• transports::BigQueryArrowStreamTransportError
• transports::BigQueryArrowTransportError
• transports::MsSQLArrow2TransportError
• transports::MsSQLArrowStreamTransportError
• transports::MsSQLArrowTransportError
• transports::MySQLArrow2TransportError
• transports::MySQLArrowStreamTransportError
• transports::MySQLArrowTransportError
• transports::OracleArrow2TransportError
• transports::OracleArrowStreamTransportError
• transports::OracleArrowTransportError
• transports::PostgresArrow2TransportError
• transports::PostgresArrowStreamTransportError
• transports::PostgresArrowTransportError
• transports::SQLiteArrow2TransportError
• transports::SQLiteArrowStreamTransportError
• transports::SQLiteArrowTransportError
• transports::TrinoArrow2TransportError
• transports::TrinoArrowStreamTransportError
• transports::TrinoArrowTransportError

Traits

• arrow_batch_iter::RecordBatchIterator
• destinations::Consume
• destinations::Destination
• destinations::DestinationPartition
• sources::PartitionParser
• sources::Produce
• sources::Source
• sources::SourcePartition
• typesystem::Transport
• typesystem::TypeConversion

Macros

• impl_transport
• impl_typesystem

Functions

• arrow_batch_iter::set_global_num_thread
• data_order::coordinate
• fed_dispatcher::run
• fed_rewriter::rewrite_sql
• get_arrow2::get_arrow2
• get_arrow::get_arrow
• get_arrow::new_record_batch_iter
• partition::get_col_range
• partition::get_part_query
• partition::partition
• source_router::parse_source
• sources::mssql::mssql_config
• sources::oracle::connect_oracle
• sources::postgres::rewrite_tls_args

Type Aliases

• destinations::arrow2::Result
• destinations::arrow::Result
• destinations::arrowstream::Result
• errors::OutResult
• errors::Result

Constants

• constants::CONNECTORX_PROTOCOL
• constants::CX_REWRITER_PATH
• constants::DB_BUFFER_SIZE
• constants::DUCKDB_JDBC_DRIVER
• constants::J4RS_BASE_PATH
• constants::MYSQL_JDBC_DRIVER
• constants::ORACLE_ARRAY_SIZE
• constants::POSTGRES_JDBC_DRIVER
• constants::RECORD_BATCH_SIZE