diff --git a/rust-docs/connectorx/all.html b/rust-docs/connectorx/all.html index 00f69c3ad..ced7748b3 100644 --- a/rust-docs/connectorx/all.html +++ b/rust-docs/connectorx/all.html @@ -1 +1 @@ -List of all items in this crate

List of all items

Structs

Enums

Traits

Macros

Functions

Type Aliases

Constants

\ No newline at end of file +List of all items in this crate

List of all items

Structs

Enums

Traits

Macros

Functions

Type Aliases

Constants

\ No newline at end of file diff --git a/rust-docs/connectorx/arrow_batch_iter/fn.set_global_num_thread.html b/rust-docs/connectorx/arrow_batch_iter/fn.set_global_num_thread.html index ed104b988..77148644b 100644 --- a/rust-docs/connectorx/arrow_batch_iter/fn.set_global_num_thread.html +++ b/rust-docs/connectorx/arrow_batch_iter/fn.set_global_num_thread.html @@ -1 +1 @@ -set_global_num_thread in connectorx::arrow_batch_iter - Rust

Function connectorx::arrow_batch_iter::set_global_num_thread

source · 
pub fn set_global_num_thread(num: usize)
\ No newline at end of file +set_global_num_thread in connectorx::arrow_batch_iter - Rust

Function connectorx::arrow_batch_iter::set_global_num_thread

source · 
pub fn set_global_num_thread(num: usize)
\ No newline at end of file diff --git a/rust-docs/connectorx/arrow_batch_iter/index.html b/rust-docs/connectorx/arrow_batch_iter/index.html index 28c035b1c..b04d93ee0 100644 --- a/rust-docs/connectorx/arrow_batch_iter/index.html +++ b/rust-docs/connectorx/arrow_batch_iter/index.html @@ -1 +1 @@ -connectorx::arrow_batch_iter - Rust

Module connectorx::arrow_batch_iter

source ·

Structs§

Traits§

Functions§

\ No newline at end of file +connectorx::arrow_batch_iter - Rust

Module connectorx::arrow_batch_iter

source ·

Structs§

Traits§

Functions§

\ No newline at end of file diff --git a/rust-docs/connectorx/arrow_batch_iter/struct.ArrowBatchIter.html b/rust-docs/connectorx/arrow_batch_iter/struct.ArrowBatchIter.html index af4e0d88d..0a2bf8e1d 100644 --- a/rust-docs/connectorx/arrow_batch_iter/struct.ArrowBatchIter.html +++ b/rust-docs/connectorx/arrow_batch_iter/struct.ArrowBatchIter.html @@ -1,4 +1,4 @@ -ArrowBatchIter in connectorx::arrow_batch_iter - Rust

Struct connectorx::arrow_batch_iter::ArrowBatchIter

source · 
pub struct ArrowBatchIter<S, TP>
where
+ArrowBatchIter in connectorx::arrow_batch_iter - Rust
Struct connectorx::arrow_batch_iter::ArrowBatchIter
source · 
pub struct ArrowBatchIter<S, TP>
where
     S: Source,
     TP: Transport<TSS = S::TypeSystem, TSD = ArrowStreamTypeSystem, S = S, D = ArrowStreamDestination>,
     <S as Source>::Partition: 'static,
diff --git a/rust-docs/connectorx/arrow_batch_iter/trait.RecordBatchIterator.html b/rust-docs/connectorx/arrow_batch_iter/trait.RecordBatchIterator.html
index c5124ac1a..e5fc008a1 100644
--- a/rust-docs/connectorx/arrow_batch_iter/trait.RecordBatchIterator.html
+++ b/rust-docs/connectorx/arrow_batch_iter/trait.RecordBatchIterator.html
@@ -1,4 +1,4 @@
-RecordBatchIterator in connectorx::arrow_batch_iter - Rust
Trait connectorx::arrow_batch_iter::RecordBatchIterator
source · 
pub trait RecordBatchIterator {
+RecordBatchIterator in connectorx::arrow_batch_iter - Rust
Trait connectorx::arrow_batch_iter::RecordBatchIterator
source · 
pub trait RecordBatchIterator {
     // Required methods
     fn get_schema(&self) -> (RecordBatch, &[String]);
     fn prepare(&mut self);
diff --git a/rust-docs/connectorx/constants/constant.CONNECTORX_PROTOCOL.html b/rust-docs/connectorx/constants/constant.CONNECTORX_PROTOCOL.html
index 4b3941435..63756fc02 100644
--- a/rust-docs/connectorx/constants/constant.CONNECTORX_PROTOCOL.html
+++ b/rust-docs/connectorx/constants/constant.CONNECTORX_PROTOCOL.html
@@ -1 +1 @@
-CONNECTORX_PROTOCOL in connectorx::constants - Rust
Constant connectorx::constants::CONNECTORX_PROTOCOL
source · 
pub const CONNECTORX_PROTOCOL: &str = "cxprotocol";

\ No newline at end of file
+CONNECTORX_PROTOCOL in connectorx::constants - Rust
Constant connectorx::constants::CONNECTORX_PROTOCOL
source · 
pub const CONNECTORX_PROTOCOL: &str = "cxprotocol";

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/constant.CX_REWRITER_PATH.html b/rust-docs/connectorx/constants/constant.CX_REWRITER_PATH.html
index bf00520ff..0976f67eb 100644
--- a/rust-docs/connectorx/constants/constant.CX_REWRITER_PATH.html
+++ b/rust-docs/connectorx/constants/constant.CX_REWRITER_PATH.html
@@ -1 +1 @@
-CX_REWRITER_PATH in connectorx::constants - Rust
Constant connectorx::constants::CX_REWRITER_PATH
source · 
pub const CX_REWRITER_PATH: &str = "../connectorx-python/connectorx/dependencies/federated-rewriter.jar";

\ No newline at end of file
+CX_REWRITER_PATH in connectorx::constants - Rust
Constant connectorx::constants::CX_REWRITER_PATH
source · 
pub const CX_REWRITER_PATH: &str = "../connectorx-python/connectorx/dependencies/federated-rewriter.jar";

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/constant.DB_BUFFER_SIZE.html b/rust-docs/connectorx/constants/constant.DB_BUFFER_SIZE.html
index 8d7f30d82..17e4d4e9d 100644
--- a/rust-docs/connectorx/constants/constant.DB_BUFFER_SIZE.html
+++ b/rust-docs/connectorx/constants/constant.DB_BUFFER_SIZE.html
@@ -1 +1 @@
-DB_BUFFER_SIZE in connectorx::constants - Rust
Constant connectorx::constants::DB_BUFFER_SIZE
source · 
pub const DB_BUFFER_SIZE: usize = 32;

\ No newline at end of file
+DB_BUFFER_SIZE in connectorx::constants - Rust
Constant connectorx::constants::DB_BUFFER_SIZE
source · 
pub const DB_BUFFER_SIZE: usize = 32;

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/constant.DUCKDB_JDBC_DRIVER.html b/rust-docs/connectorx/constants/constant.DUCKDB_JDBC_DRIVER.html
index 3d6588437..3d6dd136a 100644
--- a/rust-docs/connectorx/constants/constant.DUCKDB_JDBC_DRIVER.html
+++ b/rust-docs/connectorx/constants/constant.DUCKDB_JDBC_DRIVER.html
@@ -1 +1 @@
-DUCKDB_JDBC_DRIVER in connectorx::constants - Rust
Constant connectorx::constants::DUCKDB_JDBC_DRIVER
source · 
pub const DUCKDB_JDBC_DRIVER: &str = "org.duckdb.DuckDBDriver";

\ No newline at end of file
+DUCKDB_JDBC_DRIVER in connectorx::constants - Rust
Constant connectorx::constants::DUCKDB_JDBC_DRIVER
source · 
pub const DUCKDB_JDBC_DRIVER: &str = "org.duckdb.DuckDBDriver";

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/constant.J4RS_BASE_PATH.html b/rust-docs/connectorx/constants/constant.J4RS_BASE_PATH.html
index 879e70f15..4319b8292 100644
--- a/rust-docs/connectorx/constants/constant.J4RS_BASE_PATH.html
+++ b/rust-docs/connectorx/constants/constant.J4RS_BASE_PATH.html
@@ -1 +1 @@
-J4RS_BASE_PATH in connectorx::constants - Rust
Constant connectorx::constants::J4RS_BASE_PATH
source · 
pub const J4RS_BASE_PATH: &str = "../target/debug";

\ No newline at end of file
+J4RS_BASE_PATH in connectorx::constants - Rust
Constant connectorx::constants::J4RS_BASE_PATH
source · 
pub const J4RS_BASE_PATH: &str = "../target/debug";

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/constant.MYSQL_JDBC_DRIVER.html b/rust-docs/connectorx/constants/constant.MYSQL_JDBC_DRIVER.html
index 9b17bc665..f9f3ca391 100644
--- a/rust-docs/connectorx/constants/constant.MYSQL_JDBC_DRIVER.html
+++ b/rust-docs/connectorx/constants/constant.MYSQL_JDBC_DRIVER.html
@@ -1 +1 @@
-MYSQL_JDBC_DRIVER in connectorx::constants - Rust
Constant connectorx::constants::MYSQL_JDBC_DRIVER
source · 
pub const MYSQL_JDBC_DRIVER: &str = "com.mysql.cj.jdbc.Driver";

\ No newline at end of file
+MYSQL_JDBC_DRIVER in connectorx::constants - Rust
Constant connectorx::constants::MYSQL_JDBC_DRIVER
source · 
pub const MYSQL_JDBC_DRIVER: &str = "com.mysql.cj.jdbc.Driver";

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/constant.ORACLE_ARRAY_SIZE.html b/rust-docs/connectorx/constants/constant.ORACLE_ARRAY_SIZE.html
index 18f2fbeb5..a6206a366 100644
--- a/rust-docs/connectorx/constants/constant.ORACLE_ARRAY_SIZE.html
+++ b/rust-docs/connectorx/constants/constant.ORACLE_ARRAY_SIZE.html
@@ -1 +1 @@
-ORACLE_ARRAY_SIZE in connectorx::constants - Rust
Constant connectorx::constants::ORACLE_ARRAY_SIZE
source · 
pub const ORACLE_ARRAY_SIZE: u32 = _; // 1_024u32

\ No newline at end of file
+ORACLE_ARRAY_SIZE in connectorx::constants - Rust
Constant connectorx::constants::ORACLE_ARRAY_SIZE
source · 
pub const ORACLE_ARRAY_SIZE: u32 = _; // 1_024u32

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/constant.POSTGRES_JDBC_DRIVER.html b/rust-docs/connectorx/constants/constant.POSTGRES_JDBC_DRIVER.html
index 59d5ee690..4d8d08828 100644
--- a/rust-docs/connectorx/constants/constant.POSTGRES_JDBC_DRIVER.html
+++ b/rust-docs/connectorx/constants/constant.POSTGRES_JDBC_DRIVER.html
@@ -1 +1 @@
-POSTGRES_JDBC_DRIVER in connectorx::constants - Rust
Constant connectorx::constants::POSTGRES_JDBC_DRIVER
source · 
pub const POSTGRES_JDBC_DRIVER: &str = "org.postgresql.Driver";

\ No newline at end of file
+POSTGRES_JDBC_DRIVER in connectorx::constants - Rust
Constant connectorx::constants::POSTGRES_JDBC_DRIVER
source · 
pub const POSTGRES_JDBC_DRIVER: &str = "org.postgresql.Driver";

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/constant.RECORD_BATCH_SIZE.html b/rust-docs/connectorx/constants/constant.RECORD_BATCH_SIZE.html
index 3999123ef..451adc29a 100644
--- a/rust-docs/connectorx/constants/constant.RECORD_BATCH_SIZE.html
+++ b/rust-docs/connectorx/constants/constant.RECORD_BATCH_SIZE.html
@@ -1 +1 @@
-RECORD_BATCH_SIZE in connectorx::constants - Rust
Constant connectorx::constants::RECORD_BATCH_SIZE
source · 
pub const RECORD_BATCH_SIZE: usize = _; // 65_536usize

\ No newline at end of file
+RECORD_BATCH_SIZE in connectorx::constants - Rust
Constant connectorx::constants::RECORD_BATCH_SIZE
source · 
pub const RECORD_BATCH_SIZE: usize = _; // 65_536usize

\ No newline at end of file
diff --git a/rust-docs/connectorx/constants/index.html b/rust-docs/connectorx/constants/index.html
index 428c36c16..2ce245268 100644
--- a/rust-docs/connectorx/constants/index.html
+++ b/rust-docs/connectorx/constants/index.html
@@ -1 +1 @@
-connectorx::constants - Rust
Module connectorx::constants
source · 
Constants§

\ No newline at end of file
+connectorx::constants - Rust
Module connectorx::constants
source · 
Constants§

\ No newline at end of file
diff --git a/rust-docs/connectorx/data_order/enum.DataOrder.html b/rust-docs/connectorx/data_order/enum.DataOrder.html
index d67ccf030..f1c0c4ad4 100644
--- a/rust-docs/connectorx/data_order/enum.DataOrder.html
+++ b/rust-docs/connectorx/data_order/enum.DataOrder.html
@@ -1,4 +1,4 @@
-DataOrder in connectorx::data_order - Rust
Enum connectorx::data_order::DataOrder
source · 
pub enum DataOrder {
+DataOrder in connectorx::data_order - Rust
Enum connectorx::data_order::DataOrder
source · 
pub enum DataOrder {
     RowMajor,
     ColumnMajor,
 }
Variants§
§
RowMajor
§
ColumnMajor
Trait Implementations§
source§
impl Clone for DataOrder
source§
fn clone(&self) -> DataOrder
Returns a copy of the value. Read more
1.0.0 · source§
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read more
source§
impl Debug for DataOrder
source§
fn fmt(&self, f: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl PartialEq for DataOrder
source§
fn eq(&self, other: &DataOrder) -> bool
This method tests for self and other values to be equal, and is used
diff --git a/rust-docs/connectorx/data_order/fn.coordinate.html b/rust-docs/connectorx/data_order/fn.coordinate.html
index a2537ac88..ec1c7cebf 100644
--- a/rust-docs/connectorx/data_order/fn.coordinate.html
+++ b/rust-docs/connectorx/data_order/fn.coordinate.html
@@ -1,4 +1,4 @@
-coordinate in connectorx::data_order - Rust
Function connectorx::data_order::coordinate
source · 
pub fn coordinate(
+coordinate in connectorx::data_order - Rust
Function connectorx::data_order::coordinate
source · 
pub fn coordinate(
     src: &[DataOrder],
     dst: &[DataOrder]
 ) -> Result<DataOrder, ConnectorXError>
Expand description
Given the supported data order from source and destination, decide the optimal data order
diff --git a/rust-docs/connectorx/data_order/index.html b/rust-docs/connectorx/data_order/index.html
index a8b18fc8e..9f894aa4a 100644
--- a/rust-docs/connectorx/data_order/index.html
+++ b/rust-docs/connectorx/data_order/index.html
@@ -1,4 +1,4 @@
-connectorx::data_order - Rust
Module connectorx::data_order
source · 
Expand description
This module provides two data orders: row-wise and column-wise for tabular data,
+connectorx::data_order - Rust
Module connectorx::data_order
source · 
Expand description
This module provides two data orders: row-wise and column-wise for tabular data,
 as well as a function to coordinate the data order between source and destination.

 
Enums§
Functions§
  • coordinate
    Given the supported data order from source and destination, decide the optimal data order
 for producing and writing.

\ No newline at end of file
diff --git a/rust-docs/connectorx/destinations/arrow/enum.ArrowDestinationError.html b/rust-docs/connectorx/destinations/arrow/enum.ArrowDestinationError.html
index 233d22e31..b05288fed 100644
--- a/rust-docs/connectorx/destinations/arrow/enum.ArrowDestinationError.html
+++ b/rust-docs/connectorx/destinations/arrow/enum.ArrowDestinationError.html
@@ -1,9 +1,9 @@
-ArrowDestinationError in connectorx::destinations::arrow - Rust
Enum connectorx::destinations::arrow::ArrowDestinationError
source · 
pub enum ArrowDestinationError {
+ArrowDestinationError in connectorx::destinations::arrow - Rust
Enum connectorx::destinations::arrow::ArrowDestinationError
source · 
pub enum ArrowDestinationError {
     ArrowError(ArrowError),
     ConnectorXError(ConnectorXError),
     Other(Error),
 }
Variants§
§
ArrowError(ArrowError)
§
ConnectorXError(ConnectorXError)
§
Other(Error)
Any other errors that are too trivial to be put here explicitly.

-
Trait Implementations§
source§
impl Debug for ArrowDestinationError
source§
fn fmt(&self, f: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Display for ArrowDestinationError
source§
fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Error for ArrowDestinationError
source§
fn source(&self) -> Option<&(dyn Error + 'static)>
The lower-level source of this error, if any. Read more
1.0.0 · source§
fn description(&self) -> &str
👎Deprecated since 1.42.0: use the Display impl or to_string()
 Read more
1.0.0 · source§
fn cause(&self) -> Option<&dyn Error>
👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting
source§
fn provide<'a>(&'a self, request: &mut Request<'a>)
🔬This is a nightly-only experimental API. (error_generic_member_access)
Provides type based access to context intended for error reports. Read more
source§
impl From<ArrowDestinationError> for BigQueryArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for ConnectorXOutError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for MsSQLArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for MySQLArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for OracleArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for PostgresArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for SQLiteArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for TrinoArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowError> for ArrowDestinationError
source§
fn from(source: ArrowError) -> Self
Converts to this type from the input type.
source§
impl From<ConnectorXError> for ArrowDestinationError
source§
fn from(source: ConnectorXError) -> Self
Converts to this type from the input type.
source§
impl From<Error> for ArrowDestinationError
source§
fn from(source: Error) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+
Trait Implementations§
source§
impl Debug for ArrowDestinationError
source§
fn fmt(&self, f: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Display for ArrowDestinationError
source§
fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Error for ArrowDestinationError
source§
fn source(&self) -> Option<&(dyn Error + 'static)>
The lower-level source of this error, if any. Read more
1.0.0 · source§
fn description(&self) -> &str
👎Deprecated since 1.42.0: use the Display impl or to_string()
 Read more
1.0.0 · source§
fn cause(&self) -> Option<&dyn Error>
👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting
source§
fn provide<'a>(&'a self, request: &mut Request<'a>)
🔬This is a nightly-only experimental API. (error_generic_member_access)
Provides type based access to context intended for error reports. Read more
source§
impl From<ArrowDestinationError> for BigQueryArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for ConnectorXOutError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for MsSQLArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for MySQLArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for OracleArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for PostgresArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for SQLiteArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for TrinoArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowError> for ArrowDestinationError
source§
fn from(source: ArrowError) -> Self
Converts to this type from the input type.
source§
impl From<ConnectorXError> for ArrowDestinationError
source§
fn from(source: ConnectorXError) -> Self
Converts to this type from the input type.
source§
impl From<Error> for ArrowDestinationError
source§
fn from(source: Error) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
§
impl<T> AsErrorSource for T
where
     T: Error + 'static,
§
fn as_error_source(&self) -> &(dyn Error + 'static)
For maximum effectiveness, this needs to be called as a method
 to benefit from Rust’s automatic dereferencing of method
diff --git a/rust-docs/connectorx/destinations/arrow/index.html b/rust-docs/connectorx/destinations/arrow/index.html
index 44f72c3c2..4a2d83b35 100644
--- a/rust-docs/connectorx/destinations/arrow/index.html
+++ b/rust-docs/connectorx/destinations/arrow/index.html
@@ -1,2 +1,2 @@
-connectorx::destinations::arrow - Rust
Module connectorx::destinations::arrow
source · 
Expand description
Destination implementation for Arrow and Polars.

+connectorx::destinations::arrow - Rust
Module connectorx::destinations::arrow
source · 
Expand description
Destination implementation for Arrow and Polars.

 
Re-exports§
Modules§
Structs§
Enums§
Type Aliases§

\ No newline at end of file
diff --git a/rust-docs/connectorx/destinations/arrow/struct.ArrowDestination.html b/rust-docs/connectorx/destinations/arrow/struct.ArrowDestination.html
index 15dcc0658..867c901e2 100644
--- a/rust-docs/connectorx/destinations/arrow/struct.ArrowDestination.html
+++ b/rust-docs/connectorx/destinations/arrow/struct.ArrowDestination.html
@@ -1,4 +1,4 @@
-ArrowDestination in connectorx::destinations::arrow - Rust
Struct connectorx::destinations::arrow::ArrowDestination
source · 
pub struct ArrowDestination { /* private fields */ }
Implementations§
source§
impl ArrowDestination
source
pub fn new() -> Self
source
pub fn new_with_batch_size(batch_size: usize) -> Self
source§
impl ArrowDestination
source
pub fn arrow(self) -> Result<Vec<RecordBatch>, ArrowDestinationError>
source
pub fn record_batch(
+ArrowDestination in connectorx::destinations::arrow - Rust
Struct connectorx::destinations::arrow::ArrowDestination
source · 
pub struct ArrowDestination { /* private fields */ }
Implementations§
source§
impl ArrowDestination
source
pub fn new() -> Self
source
pub fn new_with_batch_size(batch_size: usize) -> Self
source§
impl ArrowDestination
source
pub fn arrow(self) -> Result<Vec<RecordBatch>, ArrowDestinationError>
source
pub fn record_batch(
     &mut self
 ) -> Result<Option<RecordBatch>, ArrowDestinationError>
source
pub fn empty_batch(&self) -> RecordBatch
source
pub fn arrow_schema(&self) -> Arc<Schema>
source
pub fn names(&self) -> &[String]
Trait Implementations§
source§
impl Default for ArrowDestination
source§
fn default() -> Self
Returns the “default value” for a type. Read more
source§
impl Destination for ArrowDestination
source§
const DATA_ORDERS: &'static [DataOrder] = _
§
type TypeSystem = ArrowTypeSystem
§
type Partition<'a> = ArrowPartitionWriter
§
type Error = ArrowDestinationError
source§
fn needs_count(&self) -> bool
Specify whether the destination needs total rows in advance
 in order to pre-allocate the buffer.
source§
fn allocate<S: AsRef<str>>(
diff --git a/rust-docs/connectorx/destinations/arrow/struct.ArrowPartitionWriter.html b/rust-docs/connectorx/destinations/arrow/struct.ArrowPartitionWriter.html
index 0c9eabca7..8cc1b5ffa 100644
--- a/rust-docs/connectorx/destinations/arrow/struct.ArrowPartitionWriter.html
+++ b/rust-docs/connectorx/destinations/arrow/struct.ArrowPartitionWriter.html
@@ -1,5 +1,5 @@
-ArrowPartitionWriter in connectorx::destinations::arrow - Rust
Struct connectorx::destinations::arrow::ArrowPartitionWriter
source · 
pub struct ArrowPartitionWriter { /* private fields */ }
Trait Implementations§
source§
impl<'a, T> Consume<T> for ArrowPartitionWriter
where
-    T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,
§
type Error = ArrowDestinationError
source§
fn consume(&mut self, value: T) -> Result<(), ArrowDestinationError>
source§
impl<'a> DestinationPartition<'a> for ArrowPartitionWriter
§
type TypeSystem = ArrowTypeSystem
§
type Error = ArrowDestinationError
source§
fn finalize(&mut self) -> Result<(), ArrowDestinationError>
Final clean ups
source§
fn aquire_row(&mut self, _n: usize) -> Result<usize, ArrowDestinationError>
Aquire n rows in final destination
source§
fn ncols(&self) -> usize
Number of rows this PartitionDestination controls.
source§
fn write<T>(
+ArrowPartitionWriter in connectorx::destinations::arrow - Rust
Struct connectorx::destinations::arrow::ArrowPartitionWriter
source · 
pub struct ArrowPartitionWriter { /* private fields */ }
Trait Implementations§
source§
impl<'a, T> Consume<T> for ArrowPartitionWriter
where
+    T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,
§
type Error = ArrowDestinationError
source§
fn consume(&mut self, value: T) -> Result<(), ArrowDestinationError>
source§
impl<'a> DestinationPartition<'a> for ArrowPartitionWriter
§
type TypeSystem = ArrowTypeSystem
§
type Error = ArrowDestinationError
source§
fn finalize(&mut self) -> Result<(), ArrowDestinationError>
Final clean ups
source§
fn aquire_row(&mut self, _n: usize) -> Result<usize, ArrowDestinationError>
Aquire n rows in final destination
source§
fn ncols(&self) -> usize
Number of rows this PartitionDestination controls.
source§
fn write<T>(
     &mut self,
     value: T
 ) -> Result<(), <Self as DestinationPartition<'a>>::Error>
where
diff --git a/rust-docs/connectorx/destinations/arrow/type.Result.html b/rust-docs/connectorx/destinations/arrow/type.Result.html
index f697bdbf8..bf51e5a50 100644
--- a/rust-docs/connectorx/destinations/arrow/type.Result.html
+++ b/rust-docs/connectorx/destinations/arrow/type.Result.html
@@ -1,4 +1,4 @@
-Result in connectorx::destinations::arrow - Rust
Type Alias connectorx::destinations::arrow::Result
source · 
pub type Result<T> = Result<T, ArrowDestinationError>;
Aliased Type§
enum Result<T> {
+Result in connectorx::destinations::arrow - Rust
Type Alias connectorx::destinations::arrow::Result
source · 
pub type Result<T> = Result<T, ArrowDestinationError>;
Aliased Type§
enum Result<T> {
     Ok(T),
     Err(ArrowDestinationError),
 }
Variants§
§1.0.0
Ok(T)
Contains the success value

diff --git a/rust-docs/connectorx/destinations/arrow/typesystem/enum.ArrowTypeSystem.html b/rust-docs/connectorx/destinations/arrow/typesystem/enum.ArrowTypeSystem.html
index 8b9ee03b5..eb58d3214 100644
--- a/rust-docs/connectorx/destinations/arrow/typesystem/enum.ArrowTypeSystem.html
+++ b/rust-docs/connectorx/destinations/arrow/typesystem/enum.ArrowTypeSystem.html
@@ -1,4 +1,4 @@
-ArrowTypeSystem in connectorx::destinations::arrow::typesystem - Rust
Enum connectorx::destinations::arrow::typesystem::ArrowTypeSystem
source · 
pub enum ArrowTypeSystem {
+ArrowTypeSystem in connectorx::destinations::arrow::typesystem - Rust
Enum connectorx::destinations::arrow::typesystem::ArrowTypeSystem
source · 
pub enum ArrowTypeSystem {
 
Show 16 variants    Int32(bool),
     Int64(bool),
     UInt32(bool),
diff --git a/rust-docs/connectorx/destinations/arrow/typesystem/index.html b/rust-docs/connectorx/destinations/arrow/typesystem/index.html
index b9605e01d..42aee65e8 100644
--- a/rust-docs/connectorx/destinations/arrow/typesystem/index.html
+++ b/rust-docs/connectorx/destinations/arrow/typesystem/index.html
@@ -1 +1 @@
-connectorx::destinations::arrow::typesystem - Rust
Module connectorx::destinations::arrow::typesystem
source · 
Structs§
Enums§

\ No newline at end of file
+connectorx::destinations::arrow::typesystem - Rust
Module connectorx::destinations::arrow::typesystem
source · 
Structs§
Enums§

\ No newline at end of file
diff --git a/rust-docs/connectorx/destinations/arrow/typesystem/struct.DateTimeWrapperMicro.html b/rust-docs/connectorx/destinations/arrow/typesystem/struct.DateTimeWrapperMicro.html
index 72924c2f0..b1f6cce3d 100644
--- a/rust-docs/connectorx/destinations/arrow/typesystem/struct.DateTimeWrapperMicro.html
+++ b/rust-docs/connectorx/destinations/arrow/typesystem/struct.DateTimeWrapperMicro.html
@@ -1,4 +1,4 @@
-DateTimeWrapperMicro in connectorx::destinations::arrow::typesystem - Rust
Struct connectorx::destinations::arrow::typesystem::DateTimeWrapperMicro
source · 
pub struct DateTimeWrapperMicro(pub DateTime<Utc>);
Tuple Fields§
§0: DateTime<Utc>
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+DateTimeWrapperMicro in connectorx::destinations::arrow::typesystem - Rust
Struct connectorx::destinations::arrow::typesystem::DateTimeWrapperMicro
source · 
pub struct DateTimeWrapperMicro(pub DateTime<Utc>);
Tuple Fields§
§0: DateTime<Utc>
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
source§
impl<T> Borrow<T> for T
where
     T: ?Sized,
source§
fn borrow(&self) -> &T
Immutably borrows from an owned value. Read more
source§
impl<T> BorrowMut<T> for T
where
     T: ?Sized,
source§
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§
impl<T> Conv for T
§
fn conv<T>(self) -> T
where
diff --git a/rust-docs/connectorx/destinations/arrow/typesystem/struct.NaiveDateTimeWrapperMicro.html b/rust-docs/connectorx/destinations/arrow/typesystem/struct.NaiveDateTimeWrapperMicro.html
index 1b93ac9a9..87a41e05f 100644
--- a/rust-docs/connectorx/destinations/arrow/typesystem/struct.NaiveDateTimeWrapperMicro.html
+++ b/rust-docs/connectorx/destinations/arrow/typesystem/struct.NaiveDateTimeWrapperMicro.html
@@ -1,4 +1,4 @@
-NaiveDateTimeWrapperMicro in connectorx::destinations::arrow::typesystem - Rust
Struct connectorx::destinations::arrow::typesystem::NaiveDateTimeWrapperMicro
source · 
pub struct NaiveDateTimeWrapperMicro(pub NaiveDateTime);
Tuple Fields§
§0: NaiveDateTime
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+NaiveDateTimeWrapperMicro in connectorx::destinations::arrow::typesystem - Rust
Struct connectorx::destinations::arrow::typesystem::NaiveDateTimeWrapperMicro
source · 
pub struct NaiveDateTimeWrapperMicro(pub NaiveDateTime);
Tuple Fields§
§0: NaiveDateTime
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
source§
impl<T> Borrow<T> for T
where
     T: ?Sized,
source§
fn borrow(&self) -> &T
Immutably borrows from an owned value. Read more
source§
impl<T> BorrowMut<T> for T
where
     T: ?Sized,
source§
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§
impl<T> Conv for T
§
fn conv<T>(self) -> T
where
diff --git a/rust-docs/connectorx/destinations/arrow/typesystem/struct.NaiveTimeWrapperMicro.html b/rust-docs/connectorx/destinations/arrow/typesystem/struct.NaiveTimeWrapperMicro.html
index d5f3f6c49..81f763d8b 100644
--- a/rust-docs/connectorx/destinations/arrow/typesystem/struct.NaiveTimeWrapperMicro.html
+++ b/rust-docs/connectorx/destinations/arrow/typesystem/struct.NaiveTimeWrapperMicro.html
@@ -1,4 +1,4 @@
-NaiveTimeWrapperMicro in connectorx::destinations::arrow::typesystem - Rust
Struct connectorx::destinations::arrow::typesystem::NaiveTimeWrapperMicro
source · 
pub struct NaiveTimeWrapperMicro(pub NaiveTime);
Tuple Fields§
§0: NaiveTime
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+NaiveTimeWrapperMicro in connectorx::destinations::arrow::typesystem - Rust
Struct connectorx::destinations::arrow::typesystem::NaiveTimeWrapperMicro
source · 
pub struct NaiveTimeWrapperMicro(pub NaiveTime);
Tuple Fields§
§0: NaiveTime
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
source§
impl<T> Borrow<T> for T
where
     T: ?Sized,
source§
fn borrow(&self) -> &T
Immutably borrows from an owned value. Read more
source§
impl<T> BorrowMut<T> for T
where
     T: ?Sized,
source§
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§
impl<T> Conv for T
§
fn conv<T>(self) -> T
where
diff --git a/rust-docs/connectorx/destinations/arrow2/enum.Arrow2DestinationError.html b/rust-docs/connectorx/destinations/arrow2/enum.Arrow2DestinationError.html
index 176cb9503..5c5bfcf08 100644
--- a/rust-docs/connectorx/destinations/arrow2/enum.Arrow2DestinationError.html
+++ b/rust-docs/connectorx/destinations/arrow2/enum.Arrow2DestinationError.html
@@ -1,10 +1,10 @@
-Arrow2DestinationError in connectorx::destinations::arrow2 - Rust
Enum connectorx::destinations::arrow2::Arrow2DestinationError
source · 
pub enum Arrow2DestinationError {
+Arrow2DestinationError in connectorx::destinations::arrow2 - Rust
Enum connectorx::destinations::arrow2::Arrow2DestinationError
source · 
pub enum Arrow2DestinationError {
     ArrowError(Error),
     PolarsError(PolarsError),
     ConnectorXError(ConnectorXError),
     Other(Error),
 }
Variants§
§
ArrowError(Error)
§
PolarsError(PolarsError)
§
ConnectorXError(ConnectorXError)
§
Other(Error)
Any other errors that are too trivial to be put here explicitly.

-
Trait Implementations§
source§
impl Debug for Arrow2DestinationError
source§
fn fmt(&self, f: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Display for Arrow2DestinationError
source§
fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Error for Arrow2DestinationError
source§
fn source(&self) -> Option<&(dyn Error + 'static)>
The lower-level source of this error, if any. Read more
1.0.0 · source§
fn description(&self) -> &str
👎Deprecated since 1.42.0: use the Display impl or to_string()
 Read more
1.0.0 · source§
fn cause(&self) -> Option<&dyn Error>
👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting
source§
fn provide<'a>(&'a self, request: &mut Request<'a>)
🔬This is a nightly-only experimental API. (error_generic_member_access)
Provides type based access to context intended for error reports. Read more
source§
impl From<Arrow2DestinationError> for BigQueryArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for ConnectorXOutError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for MsSQLArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for MySQLArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for OracleArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for PostgresArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for SQLiteArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for TrinoArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ConnectorXError> for Arrow2DestinationError
source§
fn from(source: ConnectorXError) -> Self
Converts to this type from the input type.
source§
impl From<Error> for Arrow2DestinationError
source§
fn from(source: Error) -> Self
Converts to this type from the input type.
source§
impl From<Error> for Arrow2DestinationError
source§
fn from(source: Error) -> Self
Converts to this type from the input type.
source§
impl From<PolarsError> for Arrow2DestinationError
source§
fn from(source: PolarsError) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+
Trait Implementations§
source§
impl Debug for Arrow2DestinationError
source§
fn fmt(&self, f: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Display for Arrow2DestinationError
source§
fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Error for Arrow2DestinationError
source§
fn source(&self) -> Option<&(dyn Error + 'static)>
The lower-level source of this error, if any. Read more
1.0.0 · source§
fn description(&self) -> &str
👎Deprecated since 1.42.0: use the Display impl or to_string()
 Read more
1.0.0 · source§
fn cause(&self) -> Option<&dyn Error>
👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting
source§
fn provide<'a>(&'a self, request: &mut Request<'a>)
🔬This is a nightly-only experimental API. (error_generic_member_access)
Provides type based access to context intended for error reports. Read more
source§
impl From<Arrow2DestinationError> for BigQueryArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for ConnectorXOutError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for MsSQLArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for MySQLArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for OracleArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for PostgresArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for SQLiteArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<Arrow2DestinationError> for TrinoArrow2TransportError
source§
fn from(source: Arrow2DestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ConnectorXError> for Arrow2DestinationError
source§
fn from(source: ConnectorXError) -> Self
Converts to this type from the input type.
source§
impl From<Error> for Arrow2DestinationError
source§
fn from(source: Error) -> Self
Converts to this type from the input type.
source§
impl From<Error> for Arrow2DestinationError
source§
fn from(source: Error) -> Self
Converts to this type from the input type.
source§
impl From<PolarsError> for Arrow2DestinationError
source§
fn from(source: PolarsError) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
§
impl<T> AsErrorSource for T
where
     T: Error + 'static,
§
fn as_error_source(&self) -> &(dyn Error + 'static)
For maximum effectiveness, this needs to be called as a method
 to benefit from Rust’s automatic dereferencing of method
diff --git a/rust-docs/connectorx/destinations/arrow2/index.html b/rust-docs/connectorx/destinations/arrow2/index.html
index fb048aafc..714614e27 100644
--- a/rust-docs/connectorx/destinations/arrow2/index.html
+++ b/rust-docs/connectorx/destinations/arrow2/index.html
@@ -1,2 +1,2 @@
-connectorx::destinations::arrow2 - Rust
Module connectorx::destinations::arrow2
source · 
Expand description
Destination implementation for Arrow2.

+connectorx::destinations::arrow2 - Rust
Module connectorx::destinations::arrow2
source · 
Expand description
Destination implementation for Arrow2.

 
Re-exports§
Modules§
Structs§
Enums§
Type Aliases§

\ No newline at end of file
diff --git a/rust-docs/connectorx/destinations/arrow2/struct.Arrow2Destination.html b/rust-docs/connectorx/destinations/arrow2/struct.Arrow2Destination.html
index 2f54f0d1d..61faf8eb3 100644
--- a/rust-docs/connectorx/destinations/arrow2/struct.Arrow2Destination.html
+++ b/rust-docs/connectorx/destinations/arrow2/struct.Arrow2Destination.html
@@ -1,4 +1,4 @@
-Arrow2Destination in connectorx::destinations::arrow2 - Rust
Struct connectorx::destinations::arrow2::Arrow2Destination
source · 
pub struct Arrow2Destination { /* private fields */ }
Implementations§
source§
impl Arrow2Destination
source
pub fn new() -> Self
source§
impl Arrow2Destination
source
pub fn arrow(
+Arrow2Destination in connectorx::destinations::arrow2 - Rust
Struct connectorx::destinations::arrow2::Arrow2Destination
source · 
pub struct Arrow2Destination { /* private fields */ }
Implementations§
source§
impl Arrow2Destination
source
pub fn new() -> Self
source§
impl Arrow2Destination
source
pub fn arrow(
     self
 ) -> Result<(Vec<Chunk<Box<dyn Array>>>, Arc<Schema>), Arrow2DestinationError>
source
pub fn polars(self) -> Result<DataFrame, Arrow2DestinationError>
Trait Implementations§
source§
impl Default for Arrow2Destination
source§
fn default() -> Self
Returns the “default value” for a type. Read more
source§
impl Destination for Arrow2Destination
source§
const DATA_ORDERS: &'static [DataOrder] = _
§
type TypeSystem = Arrow2TypeSystem
§
type Partition<'a> = ArrowPartitionWriter
§
type Error = Arrow2DestinationError
source§
fn needs_count(&self) -> bool
Specify whether the destination needs total rows in advance
 in order to pre-allocate the buffer.
source§
fn allocate<S: AsRef<str>>(
diff --git a/rust-docs/connectorx/destinations/arrow2/struct.ArrowPartitionWriter.html b/rust-docs/connectorx/destinations/arrow2/struct.ArrowPartitionWriter.html
index 65eea705b..19eb7a49e 100644
--- a/rust-docs/connectorx/destinations/arrow2/struct.ArrowPartitionWriter.html
+++ b/rust-docs/connectorx/destinations/arrow2/struct.ArrowPartitionWriter.html
@@ -1,5 +1,5 @@
-ArrowPartitionWriter in connectorx::destinations::arrow2 - Rust
Struct connectorx::destinations::arrow2::ArrowPartitionWriter
source · 
pub struct ArrowPartitionWriter { /* private fields */ }
Trait Implementations§
source§
impl<'a, T> Consume<T> for ArrowPartitionWriter
where
-    T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,
§
type Error = Arrow2DestinationError
source§
fn consume(&mut self, value: T) -> Result<(), Arrow2DestinationError>
source§
impl<'a> DestinationPartition<'a> for ArrowPartitionWriter
§
type TypeSystem = Arrow2TypeSystem
§
type Error = Arrow2DestinationError
source§
fn ncols(&self) -> usize
Number of rows this PartitionDestination controls.
source§
fn finalize(&mut self) -> Result<(), Arrow2DestinationError>
Final clean ups
source§
fn aquire_row(&mut self, _n: usize) -> Result<usize, Arrow2DestinationError>
Aquire n rows in final destination
source§
fn write<T>(
+ArrowPartitionWriter in connectorx::destinations::arrow2 - Rust
Struct connectorx::destinations::arrow2::ArrowPartitionWriter
source · 
pub struct ArrowPartitionWriter { /* private fields */ }
Trait Implementations§
source§
impl<'a, T> Consume<T> for ArrowPartitionWriter
where
+    T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,
§
type Error = Arrow2DestinationError
source§
fn consume(&mut self, value: T) -> Result<(), Arrow2DestinationError>
source§
impl<'a> DestinationPartition<'a> for ArrowPartitionWriter
§
type TypeSystem = Arrow2TypeSystem
§
type Error = Arrow2DestinationError
source§
fn ncols(&self) -> usize
Number of rows this PartitionDestination controls.
source§
fn finalize(&mut self) -> Result<(), Arrow2DestinationError>
Final clean ups
source§
fn aquire_row(&mut self, _n: usize) -> Result<usize, Arrow2DestinationError>
Aquire n rows in final destination
source§
fn write<T>(
     &mut self,
     value: T
 ) -> Result<(), <Self as DestinationPartition<'a>>::Error>
where
diff --git a/rust-docs/connectorx/destinations/arrow2/type.Result.html b/rust-docs/connectorx/destinations/arrow2/type.Result.html
index 91bca8688..c8b0e9208 100644
--- a/rust-docs/connectorx/destinations/arrow2/type.Result.html
+++ b/rust-docs/connectorx/destinations/arrow2/type.Result.html
@@ -1,4 +1,4 @@
-Result in connectorx::destinations::arrow2 - Rust
Type Alias connectorx::destinations::arrow2::Result
source · 
pub type Result<T> = Result<T, Arrow2DestinationError>;
Aliased Type§
enum Result<T> {
+Result in connectorx::destinations::arrow2 - Rust
Type Alias connectorx::destinations::arrow2::Result
source · 
pub type Result<T> = Result<T, Arrow2DestinationError>;
Aliased Type§
enum Result<T> {
     Ok(T),
     Err(Arrow2DestinationError),
 }
Variants§
§1.0.0
Ok(T)
Contains the success value

diff --git a/rust-docs/connectorx/destinations/arrow2/typesystem/enum.Arrow2TypeSystem.html b/rust-docs/connectorx/destinations/arrow2/typesystem/enum.Arrow2TypeSystem.html
index bad9523ab..286302da5 100644
--- a/rust-docs/connectorx/destinations/arrow2/typesystem/enum.Arrow2TypeSystem.html
+++ b/rust-docs/connectorx/destinations/arrow2/typesystem/enum.Arrow2TypeSystem.html
@@ -1,4 +1,4 @@
-Arrow2TypeSystem in connectorx::destinations::arrow2::typesystem - Rust
Enum connectorx::destinations::arrow2::typesystem::Arrow2TypeSystem
source · 
pub enum Arrow2TypeSystem {
+Arrow2TypeSystem in connectorx::destinations::arrow2::typesystem - Rust
Enum connectorx::destinations::arrow2::typesystem::Arrow2TypeSystem
source · 
pub enum Arrow2TypeSystem {
 
Show 24 variants    Int32(bool),
     Int64(bool),
     UInt32(bool),
diff --git a/rust-docs/connectorx/destinations/arrow2/typesystem/index.html b/rust-docs/connectorx/destinations/arrow2/typesystem/index.html
index a9a2a78fd..7e941526e 100644
--- a/rust-docs/connectorx/destinations/arrow2/typesystem/index.html
+++ b/rust-docs/connectorx/destinations/arrow2/typesystem/index.html
@@ -1 +1 @@
-connectorx::destinations::arrow2::typesystem - Rust
Module connectorx::destinations::arrow2::typesystem
source · 
Structs§
Enums§

\ No newline at end of file
+connectorx::destinations::arrow2::typesystem - Rust
Module connectorx::destinations::arrow2::typesystem
source · 
Structs§
Enums§

\ No newline at end of file
diff --git a/rust-docs/connectorx/destinations/arrow2/typesystem/struct.DateTimeWrapperMicro.html b/rust-docs/connectorx/destinations/arrow2/typesystem/struct.DateTimeWrapperMicro.html
index af5471ba5..512d34e26 100644
--- a/rust-docs/connectorx/destinations/arrow2/typesystem/struct.DateTimeWrapperMicro.html
+++ b/rust-docs/connectorx/destinations/arrow2/typesystem/struct.DateTimeWrapperMicro.html
@@ -1,4 +1,4 @@
-DateTimeWrapperMicro in connectorx::destinations::arrow2::typesystem - Rust
Struct connectorx::destinations::arrow2::typesystem::DateTimeWrapperMicro
source · 
pub struct DateTimeWrapperMicro(pub DateTime<Utc>);
Tuple Fields§
§0: DateTime<Utc>
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+DateTimeWrapperMicro in connectorx::destinations::arrow2::typesystem - Rust
Struct connectorx::destinations::arrow2::typesystem::DateTimeWrapperMicro
source · 
pub struct DateTimeWrapperMicro(pub DateTime<Utc>);
Tuple Fields§
§0: DateTime<Utc>
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
source§
impl<T> Borrow<T> for T
where
     T: ?Sized,
source§
fn borrow(&self) -> &T
Immutably borrows from an owned value. Read more
source§
impl<T> BorrowMut<T> for T
where
     T: ?Sized,
source§
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§
impl<T> Conv for T
§
fn conv<T>(self) -> T
where
diff --git a/rust-docs/connectorx/destinations/arrow2/typesystem/struct.NaiveDateTimeWrapperMicro.html b/rust-docs/connectorx/destinations/arrow2/typesystem/struct.NaiveDateTimeWrapperMicro.html
index 92da9d040..ca79baff8 100644
--- a/rust-docs/connectorx/destinations/arrow2/typesystem/struct.NaiveDateTimeWrapperMicro.html
+++ b/rust-docs/connectorx/destinations/arrow2/typesystem/struct.NaiveDateTimeWrapperMicro.html
@@ -1,4 +1,4 @@
-NaiveDateTimeWrapperMicro in connectorx::destinations::arrow2::typesystem - Rust
Struct connectorx::destinations::arrow2::typesystem::NaiveDateTimeWrapperMicro
source · 
pub struct NaiveDateTimeWrapperMicro(pub NaiveDateTime);
Tuple Fields§
§0: NaiveDateTime
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+NaiveDateTimeWrapperMicro in connectorx::destinations::arrow2::typesystem - Rust
Struct connectorx::destinations::arrow2::typesystem::NaiveDateTimeWrapperMicro
source · 
pub struct NaiveDateTimeWrapperMicro(pub NaiveDateTime);
Tuple Fields§
§0: NaiveDateTime
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
source§
impl<T> Borrow<T> for T
where
     T: ?Sized,
source§
fn borrow(&self) -> &T
Immutably borrows from an owned value. Read more
source§
impl<T> BorrowMut<T> for T
where
     T: ?Sized,
source§
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§
impl<T> Conv for T
§
fn conv<T>(self) -> T
where
diff --git a/rust-docs/connectorx/destinations/arrow2/typesystem/struct.NaiveTimeWrapperMicro.html b/rust-docs/connectorx/destinations/arrow2/typesystem/struct.NaiveTimeWrapperMicro.html
index 78c92b044..19228f19b 100644
--- a/rust-docs/connectorx/destinations/arrow2/typesystem/struct.NaiveTimeWrapperMicro.html
+++ b/rust-docs/connectorx/destinations/arrow2/typesystem/struct.NaiveTimeWrapperMicro.html
@@ -1,4 +1,4 @@
-NaiveTimeWrapperMicro in connectorx::destinations::arrow2::typesystem - Rust
Struct connectorx::destinations::arrow2::typesystem::NaiveTimeWrapperMicro
source · 
pub struct NaiveTimeWrapperMicro(pub NaiveTime);
Tuple Fields§
§0: NaiveTime
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+NaiveTimeWrapperMicro in connectorx::destinations::arrow2::typesystem - Rust
Struct connectorx::destinations::arrow2::typesystem::NaiveTimeWrapperMicro
source · 
pub struct NaiveTimeWrapperMicro(pub NaiveTime);
Tuple Fields§
§0: NaiveTime
Trait Implementations§
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
source§
impl<T> Borrow<T> for T
where
     T: ?Sized,
source§
fn borrow(&self) -> &T
Immutably borrows from an owned value. Read more
source§
impl<T> BorrowMut<T> for T
where
     T: ?Sized,
source§
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§
impl<T> Conv for T
§
fn conv<T>(self) -> T
where
diff --git a/rust-docs/connectorx/destinations/arrowstream/enum.ArrowDestinationError.html b/rust-docs/connectorx/destinations/arrowstream/enum.ArrowDestinationError.html
index 12fb0dd2f..162bdc148 100644
--- a/rust-docs/connectorx/destinations/arrowstream/enum.ArrowDestinationError.html
+++ b/rust-docs/connectorx/destinations/arrowstream/enum.ArrowDestinationError.html
@@ -1,9 +1,9 @@
-ArrowDestinationError in connectorx::destinations::arrowstream - Rust
Enum connectorx::destinations::arrowstream::ArrowDestinationError
source · 
pub enum ArrowDestinationError {
+ArrowDestinationError in connectorx::destinations::arrowstream - Rust
Enum connectorx::destinations::arrowstream::ArrowDestinationError
source · 
pub enum ArrowDestinationError {
     ArrowError(ArrowError),
     ConnectorXError(ConnectorXError),
     Other(Error),
 }
Variants§
§
ArrowError(ArrowError)
§
ConnectorXError(ConnectorXError)
§
Other(Error)
Any other errors that are too trivial to be put here explicitly.

-
Trait Implementations§
source§
impl Debug for ArrowDestinationError
source§
fn fmt(&self, f: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Display for ArrowDestinationError
source§
fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Error for ArrowDestinationError
source§
fn source(&self) -> Option<&(dyn Error + 'static)>
The lower-level source of this error, if any. Read more
1.0.0 · source§
fn description(&self) -> &str
👎Deprecated since 1.42.0: use the Display impl or to_string()
 Read more
1.0.0 · source§
fn cause(&self) -> Option<&dyn Error>
👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting
source§
fn provide<'a>(&'a self, request: &mut Request<'a>)
🔬This is a nightly-only experimental API. (error_generic_member_access)
Provides type based access to context intended for error reports. Read more
source§
impl From<ArrowDestinationError> for BigQueryArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for ConnectorXOutError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for MsSQLArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for MySQLArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for OracleArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for PostgresArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for SQLiteArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for TrinoArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowError> for ArrowDestinationError
source§
fn from(source: ArrowError) -> Self
Converts to this type from the input type.
source§
impl From<ConnectorXError> for ArrowDestinationError
source§
fn from(source: ConnectorXError) -> Self
Converts to this type from the input type.
source§
impl From<Error> for ArrowDestinationError
source§
fn from(source: Error) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
+
Trait Implementations§
source§
impl Debug for ArrowDestinationError
source§
fn fmt(&self, f: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Display for ArrowDestinationError
source§
fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result
Formats the value using the given formatter. Read more
source§
impl Error for ArrowDestinationError
source§
fn source(&self) -> Option<&(dyn Error + 'static)>
The lower-level source of this error, if any. Read more
1.0.0 · source§
fn description(&self) -> &str
👎Deprecated since 1.42.0: use the Display impl or to_string()
 Read more
1.0.0 · source§
fn cause(&self) -> Option<&dyn Error>
👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting
source§
fn provide<'a>(&'a self, request: &mut Request<'a>)
🔬This is a nightly-only experimental API. (error_generic_member_access)
Provides type based access to context intended for error reports. Read more
source§
impl From<ArrowDestinationError> for BigQueryArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for ConnectorXOutError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for MsSQLArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for MySQLArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for OracleArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for PostgresArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for SQLiteArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowDestinationError> for TrinoArrowTransportError
source§
fn from(source: ArrowDestinationError) -> Self
Converts to this type from the input type.
source§
impl From<ArrowError> for ArrowDestinationError
source§
fn from(source: ArrowError) -> Self
Converts to this type from the input type.
source§
impl From<ConnectorXError> for ArrowDestinationError
source§
fn from(source: ConnectorXError) -> Self
Converts to this type from the input type.
source§
impl From<Error> for ArrowDestinationError
source§
fn from(source: Error) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
Blanket Implementations§
source§
impl<T> Any for T
where
     T: 'static + ?Sized,
source§
fn type_id(&self) -> TypeId
Gets the TypeId of self. Read more
§
impl<T> AsErrorSource for T
where
     T: Error + 'static,
§
fn as_error_source(&self) -> &(dyn Error + 'static)
For maximum effectiveness, this needs to be called as a method
 to benefit from Rust’s automatic dereferencing of method
diff --git a/rust-docs/connectorx/destinations/arrowstream/index.html b/rust-docs/connectorx/destinations/arrowstream/index.html
index ab451ca85..9706392e3 100644
--- a/rust-docs/connectorx/destinations/arrowstream/index.html
+++ b/rust-docs/connectorx/destinations/arrowstream/index.html
@@ -1,2 +1,2 @@
-connectorx::destinations::arrowstream - Rust
Module connectorx::destinations::arrowstream
source · 
Expand description
Destination implementation for Arrow and Polars.

+connectorx::destinations::arrowstream - Rust
Module connectorx::destinations::arrowstream
source · 
Expand description
Destination implementation for Arrow and Polars.

 
Re-exports§
Modules§
Structs§
Enums§
Type Aliases§

\ No newline at end of file
diff --git a/rust-docs/connectorx/destinations/arrowstream/struct.ArrowDestination.html b/rust-docs/connectorx/destinations/arrowstream/struct.ArrowDestination.html
index a49751455..9b77ab3e4 100644
--- a/rust-docs/connectorx/destinations/arrowstream/struct.ArrowDestination.html
+++ b/rust-docs/connectorx/destinations/arrowstream/struct.ArrowDestination.html
@@ -1,4 +1,4 @@
-ArrowDestination in connectorx::destinations::arrowstream - Rust
Struct connectorx::destinations::arrowstream::ArrowDestination
source · 
pub struct ArrowDestination { /* private fields */ }
Implementations§
source§
impl ArrowDestination
source
pub fn new() -> Self
source
pub fn new_with_batch_size(batch_size: usize) -> Self
source§
impl ArrowDestination
source
pub fn arrow(self) -> Result<Vec<RecordBatch>, ArrowDestinationError>
source
pub fn record_batch(
+ArrowDestination in connectorx::destinations::arrowstream - Rust
Struct connectorx::destinations::arrowstream::ArrowDestination
source · 
pub struct ArrowDestination { /* private fields */ }
Implementations§
source§
impl ArrowDestination
source
pub fn new() -> Self
source
pub fn new_with_batch_size(batch_size: usize) -> Self
source§
impl ArrowDestination
source
pub fn arrow(self) -> Result<Vec<RecordBatch>, ArrowDestinationError>
source
pub fn record_batch(
     &mut self
 ) -> Result<Option<RecordBatch>, ArrowDestinationError>
source
pub fn empty_batch(&self) -> RecordBatch
source
pub fn arrow_schema(&self) -> Arc<Schema>
source
pub fn names(&self) -> &[String]
Trait Implementations§
source§
impl Default for ArrowDestination
source§
fn default() -> Self
Returns the “default value” for a type. Read more
source§
impl Destination for ArrowDestination
source§
const DATA_ORDERS: &'static [DataOrder] = _
§
type TypeSystem = ArrowTypeSystem
§
type Partition<'a> = ArrowPartitionWriter
§
type Error = ArrowDestinationError
source§
fn needs_count(&self) -> bool
Specify whether the destination needs total rows in advance
 in order to pre-allocate the buffer.
source§
fn allocate<S: AsRef<str>>(
diff --git a/rust-docs/connectorx/destinations/arrowstream/struct.ArrowPartitionWriter.html b/rust-docs/connectorx/destinations/arrowstream/struct.ArrowPartitionWriter.html
index 5be398e00..26a7c3506 100644
--- a/rust-docs/connectorx/destinations/arrowstream/struct.ArrowPartitionWriter.html
+++ b/rust-docs/connectorx/destinations/arrowstream/struct.ArrowPartitionWriter.html
@@ -1,4 +1,4 @@
-ArrowPartitionWriter in connectorx::destinations::arrowstream - Rust
Struct connectorx::destinations::arrowstream::ArrowPartitionWriter
source · 
pub struct ArrowPartitionWriter { /* private fields */ }
Trait Implementations§
source§
impl<'a, T> Consume<T> for ArrowPartitionWriter
where
+ArrowPartitionWriter in connectorx::destinations::arrowstream - Rust
Struct connectorx::destinations::arrowstream::ArrowPartitionWriter
source · 
pub struct ArrowPartitionWriter { /* private fields */ }
Trait Implementations§
source§
impl<'a, T> Consume<T> for ArrowPartitionWriter
where
     T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,
§
type Error = ArrowDestinationError
source§
fn consume(&mut self, value: T) -> Result<(), ArrowDestinationError>
source§
impl<'a> DestinationPartition<'a> for ArrowPartitionWriter
§
type TypeSystem = ArrowTypeSystem
§
type Error = ArrowDestinationError
source§
fn finalize(&mut self) -> Result<(), ArrowDestinationError>
Final clean ups
source§
fn aquire_row(&mut self, _n: usize) -> Result<usize, ArrowDestinationError>
Aquire n rows in final destination
source§
fn ncols(&self) -> usize
Number of rows this PartitionDestination controls.
source§
fn write<T>(
     &mut self,
     value: T
diff --git a/rust-docs/connectorx/destinations/arrowstream/type.Result.html b/rust-docs/connectorx/destinations/arrowstream/type.Result.html
index 4d2d394d8..161226d13 100644
--- a/rust-docs/connectorx/destinations/arrowstream/type.Result.html
+++ b/rust-docs/connectorx/destinations/arrowstream/type.Result.html
@@ -1,4 +1,4 @@
-Result in connectorx::destinations::arrowstream - Rust
Type Alias connectorx::destinations::arrowstream::Result
source · 
pub type Result<T> = Result<T, ArrowDestinationError>;
Aliased Type§
enum Result<T> {
+Result in connectorx::destinations::arrowstream - Rust
Type Alias connectorx::destinations::arrowstream::Result
source · 
pub type Result<T> = Result<T, ArrowDestinationError>;
Aliased Type§
enum Result<T> {
     Ok(T),
     Err(ArrowDestinationError),
 }
Variants§
§1.0.0
Ok(T)
Contains the success value

diff --git a/rust-docs/connectorx/destinations/arrowstream/typesystem/enum.ArrowTypeSystem.html b/rust-docs/connectorx/destinations/arrowstream/typesystem/enum.ArrowTypeSystem.html
index 3359016d8..070dfc40b 100644
--- a/rust-docs/connectorx/destinations/arrowstream/typesystem/enum.ArrowTypeSystem.html
+++ b/rust-docs/connectorx/destinations/arrowstream/typesystem/enum.ArrowTypeSystem.html
@@ -1,4 +1,4 @@
-ArrowTypeSystem in connectorx::destinations::arrowstream::typesystem - Rust
Enum connectorx::destinations::arrowstream::typesystem::ArrowTypeSystem
source · 
pub enum ArrowTypeSystem {
+ArrowTypeSystem in connectorx::destinations::arrowstream::typesystem - Rust
Enum connectorx::destinations::arrowstream::typesystem::ArrowTypeSystem
source · 
pub enum ArrowTypeSystem {
 
Show 13 variants    Int32(bool),
     Int64(bool),
     UInt32(bool),
diff --git a/rust-docs/connectorx/destinations/arrowstream/typesystem/index.html b/rust-docs/connectorx/destinations/arrowstream/typesystem/index.html
index f2f584ac4..04a9a7527 100644
--- a/rust-docs/connectorx/destinations/arrowstream/typesystem/index.html
+++ b/rust-docs/connectorx/destinations/arrowstream/typesystem/index.html
@@ -1 +1 @@
-connectorx::destinations::arrowstream::typesystem - Rust
Module connectorx::destinations::arrowstream::typesystem
source · 
Enums§

\ No newline at end of file
+connectorx::destinations::arrowstream::typesystem - Rust
Module connectorx::destinations::arrowstream::typesystem
source · 
Enums§

\ No newline at end of file
diff --git a/rust-docs/connectorx/destinations/index.html b/rust-docs/connectorx/destinations/index.html
index d926dfa7c..797e2ce98 100644
--- a/rust-docs/connectorx/destinations/index.html
+++ b/rust-docs/connectorx/destinations/index.html
@@ -1,4 +1,4 @@
-connectorx::destinations - Rust
Module connectorx::destinations
source · 
Expand description
This module defines three traits Destination, DestinationPartition, and Consume to define a destination.
+connectorx::destinations - Rust
Module connectorx::destinations
source · 
Expand description
This module defines three traits Destination, DestinationPartition, and Consume to define a destination.
 This module also contains destination implementations for various dataframes.

 
Modules§
  • arrow
    Destination implementation for Arrow and Polars.
  • arrow2
    Destination implementation for Arrow2.
  • arrowstream
    Destination implementation for Arrow and Polars.
Traits§