MCPcopy Create free account

hub / github.com/aljazerzen/connector_arrow / functions

Functions290 in github.com/aljazerzen/connector_arrow

⨍ Functions 290◇ Types & classes 70
↓ 30 callersMethodunwrap
(self)
connector_arrow/src/mssql/mod.rs:27
↓ 16 callersFunctiondomains_to_batch_spec
( data_types_domain: &[DataType], is_nullable_domain: &[bool], value_gen_process_domain: &[ValueGe
connector_arrow/tests/it/spec.rs:250
↓ 12 callersFunctiontransport
Take a value of type `ty` from [Produce] and insert it into [Consume].
connector_arrow/src/util/transport.rs:37
↓ 10 callersFunctionbasic_types
()
connector_arrow/tests/it/spec.rs:37
↓ 10 callersMethodfinish
(mut self)
connector_arrow/src/util/row_writer.rs:91
↓ 9 callersFunctioninit
()
connector_arrow/tests/it/test_postgres.rs:6
↓ 8 callersFunctioninit
()
connector_arrow/tests/it/test_mssql.rs:11
↓ 8 callersMethodnext
(&mut self)
connector_arrow/src/duckdb/mod.rs:170
↓ 7 callersFunctioninit
()
connector_arrow/tests/it/test_duckdb.rs:4
↓ 7 callersFunctioninit
()
connector_arrow/tests/it/test_sqlite.rs:4
↓ 7 callersMethodquery
(&'a mut self, query: &str)
connector_arrow/src/mssql/mod.rs:47
↓ 6 callersFunctioninit
()
connector_arrow/tests/it/test_mysql.rs:6
↓ 5 callersFunctionescaped_ident
(ident: &str)
connector_arrow/src/util/escape.rs:7
↓ 4 callersFunctioni128_to_sql
(data: i128, scale: i8, out: &mut BytesMut)
connector_arrow/src/postgres/decimal.rs:95
↓ 4 callersMethodprepare_for_batch
(&mut self, row_count: usize)
connector_arrow/src/util/row_writer.rs:44
↓ 4 callersFunctionquery
Open a connection, execute a single query and return the results.
connector_arrow/src/lib.rs:82
↓ 4 callersMethodstart
Execute this statement once. Returns a reader that can retrieve the result schema and data.
connector_arrow/src/api.rs:50
↓ 4 callersMethodunwrap
(self)
connector_arrow/src/mysql/mod.rs:23
↓ 3 callersFunctioncan_decimal_fit_in_numeric
(precision: u8, scale: i8)
connector_arrow/src/mssql/mod.rs:162
↓ 3 callersFunctioncoerce_schema
( schema: SchemaRef, coerce_fn: F, override_nullable: Option<bool>, )
connector_arrow/src/util/coerce.rs:61
↓ 3 callersFunctiongenerate_batch
( column_specs: ArrowGenSpec, rng: &mut R, )
connector_arrow/tests/it/generator.rs:11
↓ 3 callersMethodget_schema
(&mut self)
connector_arrow/src/duckdb/mod.rs:162
↓ 3 callersFunctionnext_batch_from_rows
Get next [RecordBatch] from a row-major reader.
connector_arrow/src/util/row_collect.rs:9
↓ 3 callersMethodquery
(&mut self, query: &str)
connector_arrow/src/rusqlite/mod.rs:48
↓ 3 callersMethodtable_create
(&mut self, name: &str, schema: SchemaRef)
connector_arrow/src/mssql/schema.rs:80
↓ 3 callersMethodtable_drop
(&mut self, name: &str)
connector_arrow/src/mssql/schema.rs:112
↓ 3 callersMethodunwrap
(self)
connector_arrow/src/rusqlite/mod.rs:28
↓ 2 callersMethodappend
( &mut self, _: arrow::record_batch::RecordBatch, )
connector_arrow/src/api.rs:120
↓ 2 callersMethodas_binary
( &mut self, schema: SchemaRef, )
connector_arrow/src/postgres/append.rs:41
↓ 2 callersFunctioncreate_field
(name: &str, db_ty: &str, nullable: bool)
connector_arrow/src/mssql/types.rs:25
↓ 2 callersFunctioncreate_field
(name: String, db_ty: &str, nullable: bool)
connector_arrow/src/mysql/types.rs:31
↓ 2 callersMethodflush
(&mut self)
connector_arrow/src/util/row_writer.rs:78
↓ 2 callersFunctioninsert_dot
(scale: &i8, value: String)
connector_arrow/src/util/decimal.rs:17
↓ 2 callersFunctionload_into_table
( conn: &mut C, schema: SchemaRef, batches: &[RecordBatch], table_name: &str, )
connector_arrow/tests/it/util.rs:23
↓ 2 callersFunctionnew_singleton_array
(data_type: &DataType, value: Box<dyn ArrowValue>)
connector_arrow/tests/it/util.rs:178
↓ 2 callersMethodnext
(&mut self)
connector_arrow/src/mssql/query.rs:82
↓ 2 callersMethodnext_builder
(&mut self)
connector_arrow/src/util/row_writer.rs:96
↓ 2 callersMethodnext_cell
(&mut self)
connector_arrow/src/mssql/query.rs:123
↓ 2 callersMethodnext_row
(&mut self)
connector_arrow/src/mssql/query.rs:93
↓ 2 callersFunctionpg_field_to_arrow
(name: String, db_ty: &Type, nullable: bool)
connector_arrow/src/postgres/types.rs:21
↓ 2 callersMethodquery
(&'a mut self, query: &str)
connector_arrow/src/postgres/mod.rs:85
↓ 2 callersMethodtable_get
( &mut self, table_name: &str, )
connector_arrow/src/mssql/schema.rs:37
↓ 1 callersMethodallocate
Make sure that there is enough memory allocated in builders for the incoming batch. Might allocate more than needed, for future row reservations.
connector_arrow/src/util/row_writer.rs:52
↓ 1 callersFunctioncoerce_array
(array: ArrayRef, coerce_fn: F)
connector_arrow/src/util/coerce.rs:46
↓ 1 callersFunctioncoerce_batch
( batch: &RecordBatch, coerce_fn: F, override_nullable: Option<bool>, )
connector_arrow/src/util/coerce.rs:27
↓ 1 callersFunctioncoerce_batches
( schema: SchemaRef, batches: &[RecordBatch], coerce_fn: F, override_nullable: Option<bool>, )
connector_arrow/src/util/coerce.rs:9
↓ 1 callersFunctioncoerce_float_16_to_32
(array: &dyn Array)
connector_arrow/src/util/coerce.rs:91
↓ 1 callersFunctioncoerce_float_16_to_64
(array: &dyn Array)
connector_arrow/src/util/coerce.rs:107
↓ 1 callersFunctioncoerce_time32_to_int64
(array: &dyn Array)
connector_arrow/src/util/coerce.rs:123
↓ 1 callersFunctioncollect_args
(batch: &RecordBatch, rows_range: std::ops::Range<usize>)
connector_arrow/src/rusqlite/append.rs:74
↓ 1 callersFunctioncollect_args
(batch: &RecordBatch, rows_range: std::ops::Range<usize>)
connector_arrow/src/mysql/append.rs:75
↓ 1 callersFunctioncollect_rows_to_arrow
Convert row-major reader into [RecordBatch]es.
connector_arrow/src/util/row_collect.rs:39
↓ 1 callersFunctioncount_values
(values: &[ValuesSpec])
connector_arrow/tests/it/generator.rs:34
↓ 1 callersFunctiondecimal128_to_string
(ty: &DataType, value: i128)
connector_arrow/src/util/decimal.rs:3
↓ 1 callersFunctiondecimal256_to_string
(ty: &DataType, value: i256)
connector_arrow/src/util/decimal.rs:10
↓ 1 callersFunctiondecl_ty_to_arrow
(decl_ty: &str, col: &str, table: &str)
connector_arrow/src/rusqlite/types.rs:5
↓ 1 callersFunctionescaped_ident_bt
(ident: &str)
connector_arrow/src/util/escape.rs:12
↓ 1 callersFunctionfrom_sql
(raw: &[u8])
connector_arrow/src/postgres/decimal.rs:38
↓ 1 callersFunctiongen_binary_of_size
(size: usize, rng: &mut R)
connector_arrow/tests/it/generator.rs:439
↓ 1 callersFunctiongen_string_of_size
(size: usize, rng: &mut R)
connector_arrow/tests/it/generator.rs:452
↓ 1 callersFunctiongenerate_array
(data_type: &DataType, values: &[ValuesSpec], rng: &mut R)
connector_arrow/tests/it/generator.rs:67
↓ 1 callersFunctionget_name_of_column_type
(col_ty: &ColumnType)
connector_arrow/src/mssql/types.rs:40
↓ 1 callersFunctionget_name_of_column_type
(col_ty: &ColumnType, unsigned: bool, binary: bool)
connector_arrow/src/mysql/types.rs:38
↓ 1 callersFunctionget_result_schema
(columns: Option<&[Column]>)
connector_arrow/src/mssql/types.rs:10
↓ 1 callersFunctionget_result_schema
( result: &mysql::ResultSet<'a, 'a, 'a, 'a, P>, )
connector_arrow/src/mysql/types.rs:10
↓ 1 callersFunctioni256_to_sql
(data: i256, scale: i8, out: &mut BytesMut)
connector_arrow/src/postgres/decimal.rs:139
↓ 1 callersFunctioninfer_schema
( stmt: &rusqlite::Statement, rows: &Vec<Vec<Value>>, column_count: usize, )
connector_arrow/src/rusqlite/query.rs:72
↓ 1 callersFunctioninsert_query
(table_name: &str, cols: usize, rows: usize)
connector_arrow/src/rusqlite/append.rs:63
↓ 1 callersFunctioninsert_query
(table_name: &str, cols: usize, rows: usize)
connector_arrow/src/mysql/append.rs:61
↓ 1 callersMethodnext
(&mut self)
connector_arrow/src/postgres/query.rs:62
↓ 1 callersMethodnext
(&mut self)
connector_arrow/src/mysql/query.rs:55
↓ 1 callersMethodnext_col_index
(&mut self)
connector_arrow/src/util/row_writer.rs:132
↓ 1 callersFunctionpg_stmt_to_arrow
( stmt: &postgres::Statement, )
connector_arrow/src/postgres/types.rs:10
↓ 1 callersMethodquery
(&'a mut self, query: &str)
connector_arrow/src/duckdb/mod.rs:50
↓ 1 callersFunctionquery_table
( conn: &mut C, table_name: &str, ident_quote_char: char, )
connector_arrow/tests/it/util.rs:59
↓ 1 callersFunctionread_two_bytes
(cursor: &mut Cursor<&[u8]>)
connector_arrow/src/postgres/decimal.rs:8
↓ 1 callersMethodreset_for_batch
(&mut self, row_count: usize)
connector_arrow/src/util/row_writer.rs:126
↓ 1 callersMethodstart_batch
( &mut self, args: (&RecordBatch, usize), )
connector_arrow/src/duckdb/mod.rs:138
↓ 1 callersFunctiontable_create
( conn: &mut SQLiteConnection, name: &str, schema: SchemaRef, )
connector_arrow/src/rusqlite/schema.rs:59
↓ 1 callersFunctiontable_drop
(conn: &mut SQLiteConnection, name: &str)
connector_arrow/src/rusqlite/schema.rs:87
↓ 1 callersMethodtable_list
(&mut self)
connector_arrow/src/mssql/schema.rs:13
↓ 1 callersFunctionty_from_arrow
(data_type: &DataType)
connector_arrow/src/duckdb/schema.rs:84
↓ 1 callersMethodunwrap
(self)
connector_arrow/src/postgres/mod.rs:44
↓ 1 callersMethodunwrap
(self)
connector_arrow/src/duckdb/mod.rs:30
↓ 1 callersFunctionvec_to_record_batch
( args: Vec<&dyn ArrowValue>, )
connector_arrow/src/params.rs:13
Methodaccepts
(_: &postgres::types::Type)
connector_arrow/src/postgres/append.rs:126
Methodaccepts
(_ty: &Type)
connector_arrow/src/postgres/query.rs:203
Methodappend
(&mut self, batch: RecordBatch)
connector_arrow/src/postgres/append.rs:82
Methodappend
(&'a mut self, table_name: &str)
connector_arrow/src/postgres/mod.rs:96
Methodappend
( &mut self, batch: arrow::record_batch::RecordBatch, )
connector_arrow/src/rusqlite/append.rs:28
Methodappend
(&'a mut self, table: &str)
connector_arrow/src/rusqlite/mod.rs:53
Methodappend
(&mut self, batch: RecordBatch)
connector_arrow/src/mssql/append.rs:44
Methodappend
(&'a mut self, table_name: &str)
connector_arrow/src/mssql/mod.rs:54
Methodappend
(&mut self, batch: RecordBatch)
connector_arrow/src/mysql/append.rs:30
Methodappend
(&'a mut self, table_name: &str)
connector_arrow/src/mysql/mod.rs:51
Methodappend
(&mut self, batch: RecordBatch)
connector_arrow/src/duckdb/append.rs:18
Methodappend
(&'a mut self, table_name: &str)
connector_arrow/src/duckdb/mod.rs:55
Functionbinary
()
connector_arrow/tests/it/spec.rs:218
Functionbinary
()
connector_arrow/tests/it/test_postgres.rs:265
Functionbinary
()
connector_arrow/tests/it/test_mssql.rs:322
next →1–100 of 290, ranked by callers