Functions — github.com/Frigatebird-db/frigatebird

hub / github.com/Frigatebird-db/frigatebird / functions

Functions1,487 in github.com/Frigatebird-db/frigatebird

⨍ Functions 1,487◇ Types & classes 193

↓ 2 callersMethodset_lifecycle

(&mut self, lifecycle: Option<Arc<dyn CacheLifecycle<T>>>)

src/cache/page_cache.rs:98

↓ 2 callersMethodshard_index_for_table

(&self, table: &str)

src/writer/executor.rs:854

↓ 2 callersMethodshutdown

(&mut self)

src/writer/executor.rs:774

↓ 2 callersMethodsnapshot_block

(&self)

src/wal/wal/runtime/writer.rs:514

↓ 2 callersFunctionsort_batch_in_memory_with_limit

( batch: &ColumnarBatch, clauses: &[OrderClause], catalog: &TableCatalog, limit: Option<usize>

src/sql/runtime/ordering.rs:176

↓ 2 callersFunctionsql_executor_wal_base_dir

()

src/sql/runtime/wal_helpers.rs:3

↓ 2 callersMethodstage_rows_as_new_group

( &mut self, table: &str, columns: &[ColumnCatalog], rows: Vec<Vec<String>>,

src/writer/executor.rs:565

↓ 2 callersFunctionstate_with

(max_size: u64, offset: u64)

src/writer/allocator.rs:147

↓ 2 callersMethodstorage

(&self)

src/wal/wal/storage.rs:192

↓ 2 callersFunctionstrip_cast

(expr: &PhysicalExpr)

src/sql/runtime/physical_evaluator.rs:193

↓ 2 callersFunctiontemp_file

(name: &str)

src/page_handler/page_io.rs:416

↓ 2 callersFunctiontest_wal_instance

()

tests/writer_tests.rs:88

↓ 2 callersFunctionthread_namespace

()

src/wal/wal/paths.rs:75

↓ 2 callersMethodto_bytes_column

Converts this dictionary column to a BytesColumn (expands all values).

src/sql/runtime/batch.rs:598

↓ 2 callersMethodtopic_for_shard

(&self, shard: usize)

src/metadata_store/journal.rs:141

↓ 2 callersMethodtotal_entries

(&self, rows_per_page_group: u64)

src/metadata_store/mod.rs:280

↓ 2 callersMethodunlock

(&self)

src/wal/wal/runtime/allocator.rs:154

↓ 2 callersMethodupdate_latest_entry_count

( &self, table: &str, column: &str, entry_count: u64, )

src/page_handler/mod.rs:102

↓ 2 callersMethodvalue_as_string

(&self, column_idx: usize)

src/sql/runtime/result.rs:113

↓ 2 callersFunctionvectorized_equality_op

( left: &ColumnarPage, right: &ColumnarPage, is_eq: bool, )

src/sql/runtime/expressions.rs:1311

↓ 2 callersFunctionwal_data_dir

()

src/wal/wal/config.rs:81

↓ 2 callersFunctionwildcard_options_supported

(options: &WildcardAdditionalOptions)

src/sql/runtime/helpers.rs:353

↓ 2 callersMethodwrite_back

(&self, id: &str, page: PageCacheEntryUncompressed)

src/page_handler/mod.rs:270

↓ 2 callersMethodwriter

(&self)

src/sql/executor/core.rs:36

↓ 1 callersMethodadd_columns_to_table

( &self, table: &str, columns: Vec<ColumnDefinition>, )

src/metadata_store/mod.rs:927

↓ 1 callersMethodand

(&mut self, other: &Bitmap)

src/sql/runtime/batch.rs:90

↓ 1 callersMethodappend_to_wal

(&self, job: &UpdateJob)

src/writer/executor.rs:799

↓ 1 callersFunctionapply_filter_expr

( _page_handler: &PageHandler, batch: ColumnarBatch, expr: &Expr, physical_expr: Option<&Physi

src/pipeline/filtering.rs:29

↓ 1 callersFunctionapply_limit_offset

( batches: I, offset: usize, limit: Option<usize>, )

src/sql/runtime/limit_exec.rs:4

↓ 1 callersFunctionapply_operations

( page: &mut PageCacheEntryUncompressed, operations: &[UpdateOp], dtype: crate::sql::types::DataTy

src/writer/executor.rs:1167

↓ 1 callersFunctionapply_qualify_filter

( batch: ColumnarBatch, expr: &Expr, catalog: &TableCatalog, )

src/pipeline/filtering.rs:12

↓ 1 callersMethodapply_record

(&self, directory: &Arc<PageDirectory>, record: MetaRecord)

src/metadata_store/journal.rs:95

↓ 1 callersMethodas_disk_page

(&self)

src/sql/runtime/batch.rs:1015

↓ 1 callersMethodas_i64

(&self)

src/sql/runtime/values.rs:102

↓ 1 callersFunctionassign_window_display_aliases

( plans: &mut [WindowFunctionPlan], projection_plan: &ProjectionPlan, )

src/pipeline/window_helpers.rs:187

↓ 1 callersFunctionattach_channels

( grouped_steps: Vec<(String, usize, Vec<FilterExpr>)>, table: String, page_handler: Arc<PageHandl

src/pipeline/builder.rs:103

↓ 1 callersMethodbatch_write

(&self, batch: &[&[u8]])

src/wal/wal/runtime/writer.rs:137

↓ 1 callersFunctionbinary_search_insert_index

(entries: &[Entry], value: &str)

src/ops_handler/helpers.rs:60

↓ 1 callersMethodbuffer_row

(&mut self, table: &str, row: Vec<String>)

src/writer/executor.rs:369

↓ 1 callersFunctionbuild_aggregate_alias_map

(plan: &AggregateProjectionPlan)

src/sql/runtime/select_helpers.rs:41

↓ 1 callersFunctionbuild_dataset

(row_count: usize)

tests/common/mod.rs:265

↓ 1 callersFunctionbuild_distinct_key

(batch: &ColumnarBatch, row_idx: usize, column_count: usize)

src/sql/runtime/executor_utils.rs:18

↓ 1 callersFunctionbuild_group_order_key

( clauses: &[OrderClause], dataset: &AggregateDataset, )

src/sql/runtime/ordering.rs:55

↓ 1 callersFunctionbuild_insert_tuple

( columns: &'a [ColumnCatalog], row: &'a [String], )

src/pipeline/insert_planner.rs:65

↓ 1 callersFunctionbuild_order_clause

(rng: &mut StdRng)

tests/sql_massive_correctness/randomized.rs:899

↓ 1 callersFunctionbuild_page_components

()

tests/sql_crash_recovery_tests.rs:84

↓ 1 callersFunctionbuild_pipeline_scan_stream

( page_handler: &Arc<PageHandler>, table: &str, columns: &[ColumnCatalog], scan_ordinals: &BTr

src/sql/runtime/scan_helpers.rs:162

↓ 1 callersFunctionbuild_prefix_from_clause

( clause: &[Expr], sort_columns: &[ColumnCatalog], sort_names: &HashSet<&str>, )

src/pipeline/planner.rs:230

↓ 1 callersFunctionbuild_prefixes_from_dict

(dict: &DictionaryColumn)

src/writer/executor.rs:1059

↓ 1 callersFunctionbuild_prefixes_from_text

(col: &BytesColumn, null_bitmap: &Bitmap)

src/writer/executor.rs:1036

↓ 1 callersFunctionbuild_projection

( projection: Vec<SelectItem>, table_columns: &[ColumnCatalog], column_ordinals: &HashMap<String,

src/sql/runtime/projection_helpers.rs:15

↓ 1 callersFunctionbuild_projection_alias_map

( plan: &ProjectionPlan, columns: &[ColumnCatalog], )

src/sql/runtime/select_helpers.rs:12

↓ 1 callersFunctionbuild_projection_batch

( batch: &ColumnarBatch, projection_plan: &ProjectionPlan, catalog: &TableCatalog, )

src/sql/runtime/projection_exec.rs:7

↓ 1 callersFunctionbuild_prunable_comparison

( left: &Expr, op: &BinaryOperator, right: &Expr, acc: &mut Vec<PagePrunePredicate>, )

src/sql/runtime/page_pruning.rs:52

↓ 1 callersFunctionbuild_row_id_slice

( page_handler: &PageHandler, table: &str, columns: &[ColumnCatalog], offset: usize, limit

src/pipeline/select_planner.rs:973

↓ 1 callersMethodbump_next_page_id

(&mut self, id: &str)

src/metadata_store/mod.rs:362

↓ 1 callersFunctionchunk_batch

(batch: &ColumnarBatch, chunk_size: usize)

src/sql/runtime/executor_utils.rs:191

↓ 1 callersMethodclear

(&mut self, idx: usize)

src/sql/runtime/batch.rs:52

↓ 1 callersFunctionclear_thread_namespace

()

src/wal/wal/paths.rs:69

↓ 1 callersMethodcoerce_literal_for_type

( &self, expr: PhysicalExpr, target_type: DataType, )

src/sql/planner.rs:1066

↓ 1 callersFunctioncollect_function_arg_columns

( arg: &FunctionArg, columns: &mut BTreeSet<String>, )

src/sql/planner.rs:688

↓ 1 callersFunctioncollect_function_columns

( function: &Function, columns: &mut BTreeSet<String>, )

src/sql/planner.rs:658

↓ 1 callersFunctioncollect_leaves

(filter: &FilterExpr, leaves: &mut Vec<FilterExpr>)

src/pipeline/builder.rs:65

↓ 1 callersFunctioncollect_prunable_predicates

( expr: &PhysicalExpr, root_ordinal: usize, out: &mut Vec<PagePrunePredicate>, )

src/sql/runtime/scan_stream.rs:214

↓ 1 callersFunctioncollect_select_columns

(select: &Select, columns: &mut BTreeSet<String>)

src/sql/planner.rs:349

↓ 1 callersFunctioncollect_sort_key_filters

( expr: Option<&Expr>, sort_columns: &[ColumnCatalog], )

src/pipeline/planner.rs:86

↓ 1 callersFunctioncollect_sort_key_prefixes

( expr: Option<&Expr>, sort_columns: &[ColumnCatalog], )

src/pipeline/planner.rs:189

↓ 1 callersFunctioncollect_window_function_plans

( items: &[SelectItem], )

src/pipeline/window_helpers.rs:122

↓ 1 callersFunctioncolumn_scalar_value

(page: &ColumnarPage, idx: usize)

src/sql/runtime/ordering.rs:335

↓ 1 callersFunctioncolumn_scalar_value

(page: &ColumnarPage, idx: usize)

src/pipeline/window_helpers.rs:1372

↓ 1 callersFunctioncolumn_to_spec

(column: &ColumnDef)

src/sql/planner.rs:725

↓ 1 callersFunctioncombine_and

(left: &[Vec<Expr>], right: &[Vec<Expr>])

src/pipeline/planner.rs:363

↓ 1 callersFunctioncompare_chunk_f64

(values: &[f64], pred: &F)

src/sql/runtime/simd.rs:179

↓ 1 callersFunctioncompare_chunk_i64

(values: &[i64], pred: &F)

src/sql/runtime/simd.rs:91

↓ 1 callersFunctioncompare_chunk_u16_eq

(values: &[u16], target: u16)

src/sql/runtime/simd.rs:234

↓ 1 callersFunctioncompare_entry_value

(entry: &Entry, value: &str)

src/ops_handler/helpers.rs:66

↓ 1 callersFunctioncompare_field_values

(left: &str, right: &str)

src/writer/executor.rs:1236

↓ 1 callersFunctioncompare_i64_eq

(values: &[i64], target: i64, null_bitmap: &Bitmap)

src/sql/runtime/simd.rs:14

↓ 1 callersFunctioncompare_i64_ge

(values: &[i64], target: i64, null_bitmap: &Bitmap)

src/sql/runtime/simd.rs:29

↓ 1 callersFunctioncompare_i64_gt

(values: &[i64], target: i64, null_bitmap: &Bitmap)

src/sql/runtime/simd.rs:24

↓ 1 callersFunctioncompare_i64_le

(values: &[i64], target: i64, null_bitmap: &Bitmap)

src/sql/runtime/simd.rs:39

↓ 1 callersFunctioncompare_i64_lt

(values: &[i64], target: i64, null_bitmap: &Bitmap)

src/sql/runtime/simd.rs:34

↓ 1 callersFunctioncompare_i64_ne

(values: &[i64], target: i64, null_bitmap: &Bitmap)

src/sql/runtime/simd.rs:19

↓ 1 callersFunctioncompare_nulls

(left_null: bool, right_null: bool, clause: &OrderColumn)

src/sql/runtime/ordering.rs:295

↓ 1 callersFunctioncompare_results

( sql: &str, ours: SelectResult, duck_rows: Vec<Vec<Option<String>>>, options: QueryOptions<'_

tests/common/mod.rs:708

↓ 1 callersFunctioncompare_row_against_existing

( handler: &PageHandler, table: &str, columns: &[ColumnCatalog], sort_ordinals: &[usize],

src/ops_handler/helpers.rs:35

↓ 1 callersFunctioncompare_rows

(left: &[String], right: &[String], sort_ordinals: &[usize])

src/writer/executor.rs:1217

↓ 1 callersFunctioncompare_rows_by_columns

( batch: &ColumnarBatch, order_columns: &[OrderColumn], left_idx: usize, right_idx: usize, )

src/sql/runtime/ordering.rs:256

↓ 1 callersFunctioncompare_scalar_with_clause

( left: &ScalarValue, right: &ScalarValue, clause: &OrderClause, )

src/sql/runtime/ordering.rs:71

↓ 1 callersFunctioncompare_strs

(left: &str, right: &str)

tests/order_by_integration_tests.rs:626

↓ 1 callersFunctioncompute_alloc_len

(actual_len: u64)

src/writer/allocator.rs:96

↓ 1 callersMethodconsume_batch

(&mut self, batch: ColumnarBatch)

src/pipeline/window_helpers.rs:963

↓ 1 callersFunctioncreate_mock_page_handler

()

src/executor.rs:62

↓ 1 callersFunctiondatetime_to_seconds

(dt: &NaiveDateTime)

src/sql/runtime/row_functions.rs:417

↓ 1 callersFunctiondedup_single_column

(batches: &[ColumnarBatch])

src/sql/runtime/executor_utils.rs:112

↓ 1 callersFunctiondeduplicate_batches

( batches: Vec<ColumnarBatch>, column_count: usize, )

src/sql/runtime/executor_utils.rs:73

↓ 1 callersFunctiondetermine_group_by_strategy

( group_by: &GroupByExpr, sort_columns: &[ColumnCatalog], order_clauses: &[OrderClause], )

src/sql/runtime/select_helpers.rs:86

↓ 1 callersFunctiondetermine_template_kind

(template: &ColumnarPage, values: &[ScalarValue])

src/pipeline/window_helpers.rs:1531

↓ 1 callersFunctiondummy_batch

(row_ids: &[u64])

tests/pipeline_tests.rs:17

↓ 1 callersFunctionensure_aggregate_plan_for_expr

( expr: &Expr, aggregate_plans: &mut Vec<AggregateFunctionPlan>, aggregate_lookup: &mut HashMap<St

src/sql/runtime/aggregation_helpers.rs:22

← previous next →401–500 of 1,487, ranked by callers