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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121

//! This module contains transport definitions for the sources and destinations implemented in ConnectorX.

#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
mod bigquery_arrow;
#[cfg(all(feature = "src_bigquery", feature = "dst_arrow2"))]
mod bigquery_arrow2;
#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
mod bigquery_arrowstream;
#[cfg(all(feature = "src_csv", feature = "dst_arrow"))]
mod csv_arrow;
#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
mod dummy_arrow;
#[cfg(all(feature = "src_dummy", feature = "dst_arrow2"))]
mod dummy_arrow2;
#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
mod dummy_arrowstream;
#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
mod mssql_arrow;
#[cfg(all(feature = "src_mssql", feature = "dst_arrow2"))]
mod mssql_arrow2;
#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
mod mssql_arrowstream;
#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
mod mysql_arrow;
#[cfg(all(feature = "src_mysql", feature = "dst_arrow2"))]
mod mysql_arrow2;
#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
mod mysql_arrowstream;
#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
mod oracle_arrow;
#[cfg(all(feature = "src_oracle", feature = "dst_arrow2"))]
mod oracle_arrow2;
#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
mod oracle_arrowstream;
#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
mod postgres_arrow;
#[cfg(all(feature = "src_postgres", feature = "dst_arrow2"))]
mod postgres_arrow2;
#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
mod postgres_arrowstream;
#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
mod sqlite_arrow;
#[cfg(all(feature = "src_sqlite", feature = "dst_arrow2"))]
mod sqlite_arrow2;
#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
mod sqlite_arrowstream;
#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
mod trino_arrow;
#[cfg(all(feature = "src_trino", feature = "dst_arrow2"))]
mod trino_arrow2;
#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
mod trino_arrowstream;
#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
pub use bigquery_arrow::{BigQueryArrowTransport, BigQueryArrowTransportError};
#[cfg(all(feature = "src_bigquery", feature = "dst_arrow2"))]
pub use bigquery_arrow2::{BigQueryArrow2Transport, BigQueryArrow2TransportError};
#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
pub use bigquery_arrowstream::{
    BigQueryArrowTransport as BigQueryArrowStreamTransport,
    BigQueryArrowTransportError as BigQueryArrowStreamTransportError,
};
#[cfg(all(feature = "src_csv", feature = "dst_arrow"))]
pub use csv_arrow::CSVArrowTransport;
#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
pub use dummy_arrow::DummyArrowTransport;
#[cfg(all(feature = "src_dummy", feature = "dst_arrow2"))]
pub use dummy_arrow2::DummyArrow2Transport;
#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
pub use mssql_arrow::{MsSQLArrowTransport, MsSQLArrowTransportError};
#[cfg(all(feature = "src_mssql", feature = "dst_arrow2"))]
pub use mssql_arrow2::{MsSQLArrow2Transport, MsSQLArrow2TransportError};
#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
pub use mssql_arrowstream::{
    MsSQLArrowTransport as MsSQLArrowStreamTransport,
    MsSQLArrowTransportError as MsSQLArrowStreamTransportError,
};
#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
pub use mysql_arrow::{MySQLArrowTransport, MySQLArrowTransportError};
#[cfg(all(feature = "src_mysql", feature = "dst_arrow2"))]
pub use mysql_arrow2::{MySQLArrow2Transport, MySQLArrow2TransportError};
#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
pub use mysql_arrowstream::{
    MySQLArrowTransport as MySQLArrowStreamTransport,
    MySQLArrowTransportError as MySQLArrowStreamTransportError,
};
#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
pub use oracle_arrow::{OracleArrowTransport, OracleArrowTransportError};
#[cfg(all(feature = "src_oracle", feature = "dst_arrow2"))]
pub use oracle_arrow2::{OracleArrow2Transport, OracleArrow2TransportError};
#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
pub use oracle_arrowstream::{
    OracleArrowTransport as OracleArrowStreamTransport,
    OracleArrowTransportError as OracleArrowStreamTransportError,
};
#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
pub use postgres_arrow::{PostgresArrowTransport, PostgresArrowTransportError};
#[cfg(all(feature = "src_postgres", feature = "dst_arrow2"))]
pub use postgres_arrow2::{PostgresArrow2Transport, PostgresArrow2TransportError};
#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
pub use postgres_arrowstream::{
    PostgresArrowTransport as PostgresArrowStreamTransport,
    PostgresArrowTransportError as PostgresArrowStreamTransportError,
};
#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
pub use sqlite_arrow::{SQLiteArrowTransport, SQLiteArrowTransportError};
#[cfg(all(feature = "src_sqlite", feature = "dst_arrow2"))]
pub use sqlite_arrow2::{SQLiteArrow2Transport, SQLiteArrow2TransportError};
#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
pub use sqlite_arrowstream::{
    SQLiteArrowTransport as SQLiteArrowStreamTransport,
    SQLiteArrowTransportError as SQLiteArrowStreamTransportError,
};
#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
pub use trino_arrow::{TrinoArrowTransport, TrinoArrowTransportError};
#[cfg(all(feature = "src_trino", feature = "dst_arrow2"))]
pub use trino_arrow2::{TrinoArrow2Transport, TrinoArrow2TransportError};
#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
pub use trino_arrowstream::{
    TrinoArrowTransport as TrinoArrowStreamTransport,
    TrinoArrowTransportError as TrinoArrowStreamTransportError,
};