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

↓ 1 callersFunctionensure_capacity

(page: &mut Page, row_idx: usize)

src/writer/executor.rs:1200

↓ 1 callersMethodensure_capacity

(&mut self, size: u64)

src/writer/allocator.rs:50

↓ 1 callersFunctionensure_common_partition

( plans: &[WindowFunctionPlan], )

src/pipeline/window_helpers.rs:888

↓ 1 callersMethodensure_default_table_column

(&mut self, column: &str)

src/metadata_store/mod.rs:374

↓ 1 callersMethodensure_executed

(&mut self)

src/sql/runtime/scan_stream.rs:74

↓ 1 callersFunctionensure_sql_executor_wal_root

()

src/sql/runtime/wal_helpers.rs:9

↓ 1 callersMethodequals_with_tol

(&self, other: &Self, abs_tol: f64, rel_tol: f64)

tests/common/mod.rs:563

↓ 1 callersFunctionevaluate_aggregate_function

( function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:872

↓ 1 callersFunctionevaluate_aggregate_outputs

( plan: &AggregateProjectionPlan, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:860

↓ 1 callersFunctionevaluate_approx_quantile

( function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:1115

↓ 1 callersFunctionevaluate_avg_if

( function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:1245

↓ 1 callersFunctionevaluate_case_expression

( operand: Option<&Expr>, conditions: &[Expr], results: &[Expr], else_result: Option<&Expr>,

src/sql/runtime/expressions.rs:329

↓ 1 callersFunctionevaluate_case_expression_vectorized

( operand: Option<&Expr>, conditions: &[Expr], results: &[Expr], else_result: Option<&Expr>,

src/sql/runtime/expressions.rs:859

↓ 1 callersFunctionevaluate_coalesce_function

( function: &Function, batch: &ColumnarBatch, catalog: &TableCatalog, )

src/sql/runtime/expressions.rs:816

↓ 1 callersFunctionevaluate_count

( function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:900

↓ 1 callersFunctionevaluate_count_if

( function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:1306

↓ 1 callersFunctionevaluate_having

( having: &Option<Expr>, dataset: &AggregateDataset, )

src/sql/runtime/grouping_helpers.rs:133

↓ 1 callersFunctionevaluate_in_list

( expr: &PhysicalExpr, list: &[PhysicalExpr], negated: bool, batch: &ColumnarBatch, )

src/sql/runtime/physical_evaluator.rs:726

↓ 1 callersFunctionevaluate_in_list_column

(page: &ColumnarPage, list: &[PhysicalExpr], negated: bool)

src/sql/runtime/physical_evaluator.rs:741

↓ 1 callersFunctionevaluate_like

( expr: &PhysicalExpr, pattern: &PhysicalExpr, case_insensitive: bool, negated: bool, batc

src/sql/runtime/physical_evaluator.rs:879

↓ 1 callersFunctionevaluate_numeric_aggregate

( name: &str, function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:948

↓ 1 callersFunctionevaluate_percentile_cont

( function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:1027

↓ 1 callersFunctionevaluate_rlike

( expr: &PhysicalExpr, pattern: &PhysicalExpr, negated: bool, batch: &ColumnarBatch, )

src/sql/runtime/physical_evaluator.rs:983

↓ 1 callersFunctionevaluate_row_case_expr

( operand: Option<&Expr>, conditions: &[Expr], results: &[Expr], else_result: Option<&Expr>,

src/sql/runtime/expressions.rs:1081

↓ 1 callersFunctionevaluate_row_function

( function: &Function, row_idx: u64, dataset: &AggregateDataset, )

src/sql/runtime/row_functions.rs:9

↓ 1 callersFunctionevaluate_scalar_function

( function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/scalar_functions.rs:8

↓ 1 callersFunctionevaluate_scalar_function_on_batch

( function: &Function, batch: &ColumnarBatch, catalog: &TableCatalog, )

src/sql/runtime/expressions.rs:796

↓ 1 callersFunctionevaluate_sum_if

( function: &Function, dataset: &AggregateDataset, )

src/sql/runtime/aggregates.rs:1184

↓ 1 callersMethodexecute_batches

( &mut self, batches: Vec<PipelineBatch>, )

src/pipeline/operators/distinct.rs:15

↓ 1 callersFunctionexecute_create

(executor: &SqlExecutor, statement: Statement)

src/pipeline/ddl_planner.rs:20

↓ 1 callersFunctionexecute_ddl_plan

( executor: &SqlExecutor, statement: Statement, )

src/pipeline/ddl_planner.rs:8

↓ 1 callersFunctionexecute_delete_plan

( executor: &SqlExecutor, tables: Vec<ObjectName>, from: FromTable, using: Option<Vec<TableWit

src/pipeline/mutation_planner.rs:132

↓ 1 callersFunctionexecute_file

(executor: &SqlExecutor, path: &str)

src/main.rs:229

↓ 1 callersFunctionexecute_insert_legacy

( executor: &SqlExecutor, statement: Statement, )

src/pipeline/insert_planner.rs:42

↓ 1 callersFunctionexecute_insert_plan

( executor: &SqlExecutor, statement: Statement, )

src/pipeline/insert_planner.rs:8

↓ 1 callersFunctionexecute_insert_writer

( executor: &SqlExecutor, statement: Statement, )

src/pipeline/insert_planner.rs:19

↓ 1 callersMethodexecute_non_root

(&self)

src/pipeline/types.rs:233

↓ 1 callersFunctionexecute_projection_pipeline

( executor: &SqlExecutor, table: &str, catalog: &TableCatalog, columns: &[ColumnCatalog],

src/pipeline/select_planner.rs:52

↓ 1 callersMethodexecute_root

(&self)

src/pipeline/types.rs:146

↓ 1 callersMethodexecute_root_for_row_ids

(&self, row_ids: &[u64])

src/pipeline/types.rs:190

↓ 1 callersMethodexecute_select

( &self, mut query: Query, )

src/sql/executor/select.rs:6

↓ 1 callersFunctionexecute_select_plan

( executor: &SqlExecutor, mut query: Query, )

src/pipeline/select_planner.rs:404

↓ 1 callersMethodexecute_simple_from_batch

( &self, batch: &crate::sql::runtime::batch::ColumnarBatch, group_exprs: &[Expr],

src/pipeline/operators/aggregate.rs:74

↓ 1 callersFunctionexecute_sort

( batches: I, clauses: &[OrderClause], catalog: &TableCatalog, limit: Option<usize>, )

src/sql/runtime/sort_exec.rs:9

↓ 1 callersFunctionexecute_update_plan

( executor: &SqlExecutor, table: TableWithJoins, assignments: Vec<Assignment>, selection: Opti

src/pipeline/mutation_planner.rs:24

↓ 1 callersFunctionexecute_window_pipeline

( executor: &SqlExecutor, table: &str, catalog: &TableCatalog, columns: &[ColumnCatalog],

src/pipeline/select_planner.rs:234

↓ 1 callersFunctionexpand_group_by_sets

(exprs: &[Expr])

src/sql/runtime/grouping_helpers.rs:53

↓ 1 callersFunctionexpand_rollup_sets

(groups: &[Vec<Expr>])

src/sql/runtime/grouping_helpers.rs:100

↓ 1 callersFunctionexpr_to_dnf

(expr: &Expr)

src/pipeline/planner.rs:299

↓ 1 callersMethodextend_from

(&mut self, other: &Bitmap)

src/sql/runtime/batch.rs:124

↓ 1 callersMethodextend_partial_tail

( &mut self, table: &str, columns: &[ColumnCatalog], rows_per_page_group: u64,

src/writer/executor.rs:459

↓ 1 callersFunctionextract_leaf_filters

(filter: &FilterExpr)

src/pipeline/builder.rs:59

↓ 1 callersFunctionextract_like_prefix

(pattern: &str)

src/sql/runtime/physical_evaluator.rs:1007

↓ 1 callersFunctionextract_literal_string

(expr: &Expr)

src/sql/runtime/row_functions.rs:431

↓ 1 callersFunctionextract_order_columns

( clauses: &[OrderClause], batch: &ColumnarBatch, catalog: &TableCatalog, )

src/sql/runtime/ordering.rs:235

↓ 1 callersFunctionextract_page_prunable_predicates

(expr: &Expr)

src/sql/runtime/page_pruning.rs:22

↓ 1 callersFunctionextract_primary_column_physical

(expr: &PhysicalExpr)

src/pipeline/builder.rs:91

↓ 1 callersFunctionextract_sort_equality

(expr: &Expr, sort_names: &HashSet<&str>)

src/pipeline/planner.rs:274

↓ 1 callersFunctionextract_sort_key_filters

( expr: &Expr, sort_names: &HashSet<&str>, filters: &mut HashMap<String, String>, )

src/pipeline/planner.rs:116

↓ 1 callersFunctionextract_window_plan

( expr: &Expr, )

src/pipeline/window_helpers.rs:340

↓ 1 callersFunctionfast_hash

(value: &str)

src/metadata_store/journal.rs:146

↓ 1 callersFunctionfast_table_hash

(table: &str)

src/writer/executor.rs:887

↓ 1 callersMethodfetch_and_insert

(&self, meta: &PageDescriptor)

src/page_handler/mod.rs:150

↓ 1 callersFunctionfind_insert_position

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

src/ops_handler/helpers.rs:11

↓ 1 callersFunctionformat_binary_op

(op: &BinaryOperator)

src/sql/physical_plan.rs:149

↓ 1 callersFunctionformat_scalar

(val: &ScalarValue)

src/sql/physical_plan.rs:131

↓ 1 callersFunctionformat_unary_op

(op: &UnaryOperator)

src/sql/physical_plan.rs:169

↓ 1 callersMethodfsync_schedule

(mut self, schedule: FsyncSchedule)

src/sql/executor/wal_options.rs:40

↓ 1 callersFunctiongather_filters

( expr: &Expr, filters: &mut HashMap<String, String>, )

src/sql/runtime/helpers.rs:178

↓ 1 callersFunctiongather_numeric_prunable_predicates

(expr: &Expr, acc: &mut Vec<PagePrunePredicate>)

src/sql/runtime/page_pruning.rs:31

↓ 1 callersFunctiongenerate_pipeline_id

()

src/pipeline/builder.rs:137

↓ 1 callersFunctiongenerate_random_query

(table: &str, row_count: i64, rng: &mut StdRng)

tests/sql_massive_correctness/randomized.rs:538

↓ 1 callersMethodget_datatype

(&self)

src/sql/runtime/values.rs:72

↓ 1 callersMethodget_next_available_block

SAFETY: Caller must ensure the returned `Block` is treated as uniquely owned by a single writer until it is sealed. Internally, a spin lock ensures ex

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

↓ 1 callersFunctiongroup_filters_by_column

(filters: Vec<FilterExpr>)

src/pipeline/builder.rs:78

↓ 1 callersFunctionhandle_backslash_command

(executor: &SqlExecutor, cmd: &str)

src/main.rs:133

↓ 1 callersFunctionhandle_dot_command

(executor: &SqlExecutor, cmd: &str)

src/main.rs:170

↓ 1 callersMethodindex_path

(&self, file_name: &str)

src/wal/wal/paths.rs:32

↓ 1 callersFunctioninfer_column_type

(values: &[&str])

tests/order_by_integration_tests.rs:159

↓ 1 callersMethodinitialise_table_with_row

( &self, table: &str, columns: &[ColumnCatalog], row: &[String], )

src/sql/executor/dml.rs:113

↓ 1 callersFunctioninstall_fixture

()

tests/sql_massive_correctness/filters.rs:9

↓ 1 callersFunctioninstall_fixture

()

tests/sql_massive_correctness/ordering.rs:3

↓ 1 callersFunctioninstall_fixture

()

tests/sql_massive_correctness/aggregates.rs:9

↓ 1 callersMethodinto_disk_page

(self)

src/sql/runtime/batch.rs:1019

↓ 1 callersMethodis_empty

(&self)

src/sql/runtime/result.rs:23

↓ 1 callersMethodlatest

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

src/metadata_store/mod.rs:653

↓ 1 callersMethodlatest_descriptor

(&self, _table: &str, _column: &str)

src/writer/executor.rs:58

↓ 1 callersMethodlen

(&self)

src/cache/page_cache.rs:82

↓ 1 callersFunctionlike_match_dfs

(value: &[char], pattern: &[char], mut v_idx: usize, mut p_idx: usize)

src/sql/runtime/helpers.rs:410

↓ 1 callersFunctionlike_match_recursive

(value: &str, pattern: &str)

src/sql/runtime/helpers.rs:399

↓ 1 callersFunctionlike_match_recursive

(value: &str, pattern: &str)

src/pipeline/pattern_matching.rs:16

↓ 1 callersFunctionlike_prefix_bounds

(pattern: &str)

src/sql/runtime/scan_stream.rs:343

↓ 1 callersMethodlist_range_in_table

( &self, table: &str, column: &str, start_row: u64, end_row: u64,

src/page_handler/mod.rs:390

↓ 1 callersMethodlocate_row_in_table

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

src/metadata_store/mod.rs:984

↓ 1 callersFunctionlocate_rows_by_sort_prefixes

( page_handler: &PageHandler, page_directory: &PageDirectory, table: &str, sort_columns: &[Col

src/sql/runtime/scan_helpers.rs:15

↓ 1 callersFunctionmaterialize_columns

( page_handler: &PageHandler, table: &str, table_columns: &[ColumnCatalog], ordinals: &BTreeSe

src/sql/runtime/projection_helpers.rs:136

↓ 1 callersMethodmerge_from

(&mut self, other: &TableAccess)

src/sql/models.rs:62

↓ 1 callersFunctionmerge_tables

(tables: Vec<TableAccess>)

src/sql/planner.rs:737

↓ 1 callersMethodmeta_journal

(&self)

src/sql/executor/core.rs:52

↓ 1 callersMethodnext_batch

(&mut self)

src/sql/runtime/scan_stream.rs:30

← previous next →501–600 of 1,487, ranked by callers