Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Frigatebird-db/frigatebird
/ functions
Functions
1,487 in github.com/Frigatebird-db/frigatebird
⨍
Functions
1,487
◇
Types & classes
193
↓ 2 callers
Function
boolean_page_from_bitmap
(bitmap: &Bitmap, invert: bool)
src/sql/runtime/expressions.rs:1427
↓ 2 callers
Function
build_null_prunable_predicate
( expr: &Expr, expect_null: bool, acc: &mut Vec<PagePrunePredicate>, )
src/sql/runtime/page_pruning.rs:85
↓ 2 callers
Function
collect_all_columns
(table_columns: &[ColumnCatalog])
src/sql/runtime/projection_helpers.rs:124
↓ 2 callers
Function
collect_expr_column_names
(expr: &Expr, columns: &mut BTreeSet<String>)
src/sql/runtime/helpers.rs:235
↓ 2 callers
Function
collect_function_order_ordinals
( expr: &Expr, column_ordinals: &HashMap<String, usize>, table: &str, out: &mut BTreeSet<usize
src/sql/runtime/aggregates.rs:782
↓ 2 callers
Function
collect_matching_row_ids
( executor: &SqlExecutor, table_name: &str, catalog: &crate::metadata_store::TableCatalog, col
src/pipeline/mutation_planner.rs:221
↓ 2 callers
Function
collect_order_by_columns
( order_by: &[OrderByExpr], columns: &mut BTreeSet<String>, )
src/sql/planner.rs:423
↓ 2 callers
Function
collect_select_item
(item: &SelectItem, columns: &mut BTreeSet<String>)
src/sql/planner.rs:412
↓ 2 callers
Function
collect_window_plans_from_expr
( expr: &Expr, plans: &mut Vec<WindowFunctionPlan>, )
src/pipeline/window_helpers.rs:221
↓ 2 callers
Function
column_from_strings
(values: Vec<Option<String>>)
src/sql/runtime/expressions.rs:1060
↓ 2 callers
Function
compare_strs
(left: &str, right: &str)
src/ops_handler/helpers.rs:70
↓ 2 callers
Function
comparison_for_operator
( op: &BinaryOperator, column_on_left: bool, )
src/sql/runtime/page_pruning.rs:105
↓ 2 callers
Function
create_storage_impl
(path: &str)
src/wal/wal/storage.rs:124
↓ 2 callers
Function
data_file_path
(file_id: u32, data_dir: &str)
src/writer/allocator.rs:77
↓ 2 callers
Function
dataset
(config: &MassiveFixtureConfig)
tests/common/mod.rs:249
↓ 2 callers
Function
delete_row
( handler: &PageHandler, table: &str, row_idx: u64, )
src/ops_handler/delete.rs:5
↓ 2 callers
Function
display_joined
( separator: &str, parts: &[FilterExpr], f: &mut fmt::Formatter<'_>, )
src/sql/models.rs:174
↓ 2 callers
Method
do_register_table
( &mut self, name: String, columns: Vec<ColumnDefinition>, sort_key: Vec<Strin
src/metadata_store/mod.rs:444
↓ 2 callers
Function
dummy_batch
(row_ids: &[u64])
tests/pipeline_filtering_integration_tests.rs:16
↓ 2 callers
Method
ensure_compatible
(&mut self, other: &Bitmap)
src/sql/runtime/batch.rs:146
↓ 2 callers
Method
ensure_root
(&self)
src/wal/wal/paths.rs:28
↓ 2 callers
Method
ensure_table_column
(&mut self, table: &str, column: &str)
src/metadata_store/mod.rs:408
↓ 2 callers
Function
estimate_table_row_count
( page_handler: &PageHandler, table: &str, columns: &[ColumnCatalog], )
src/sql/runtime/row_counts.rs:5
↓ 2 callers
Function
evaluate_col_lit
( col: &ColumnData, null_bitmap: &Bitmap, op: &BinaryOperator, lit: &ScalarValue, num_rows
src/sql/runtime/physical_evaluator.rs:214
↓ 2 callers
Function
evaluate_date_trunc_row
( function: &Function, row_idx: u64, dataset: &AggregateDataset, )
src/sql/runtime/row_functions.rs:273
↓ 2 callers
Function
evaluate_filter_expr_with_batch
(filter: &FilterExpr, batch: &ColumnarBatch)
src/pipeline/types.rs:33
↓ 2 callers
Function
evaluate_group_keys_on_batch
( group_by_exprs: &[Expr], batch: &ColumnarBatch, catalog: &TableCatalog, )
src/sql/runtime/grouping_helpers.rs:145
↓ 2 callers
Function
evaluate_is_null
(expr: &PhysicalExpr, batch: &ColumnarBatch)
src/sql/runtime/physical_evaluator.rs:1032
↓ 2 callers
Function
evaluate_time_bucket_row
( function: &Function, row_idx: u64, dataset: &AggregateDataset, )
src/sql/runtime/row_functions.rs:190
↓ 2 callers
Function
execute_grouping_set_aggregation_rows_from_batch
( page_handler: &PageHandler, batch: &ColumnarBatch, table: &str, catalog: &TableCatalog,
src/sql/runtime/aggregation_exec.rs:23
↓ 2 callers
Method
execute_grouping_set_rows_from_batch
( &self, batch: &crate::sql::runtime::batch::ColumnarBatch, group_exprs: &[Expr],
src/pipeline/operators/aggregate.rs:107
↓ 2 callers
Function
execute_statement
( executor: &SqlExecutor, statement: Statement, )
src/pipeline/dispatcher.rs:5
↓ 2 callers
Function
expr_contains_aggregate
(expr: &Expr)
src/sql/runtime/aggregates.rs:632
↓ 2 callers
Function
expression_touches_sort
(expr: &Expr, sort_names: &HashSet<&str>)
src/pipeline/planner.rs:183
↓ 2 callers
Function
extract_single_argument
(function: &Function)
src/sql/runtime/aggregates.rs:1365
↓ 2 callers
Function
finalize_aggregation_rows
( mut aggregated_rows: Vec<AggregatedRow>, order_clauses: &[OrderClause], distinct_flag: bool,
src/sql/runtime/aggregation_exec.rs:118
↓ 2 callers
Method
flush_page_group
(&mut self, table: &str, mut rows: Vec<Vec<String>>)
src/writer/executor.rs:386
↓ 2 callers
Method
flush_pending
(&mut self, table: &str)
src/writer/executor.rs:453
↓ 2 callers
Method
force_register_table
( &mut self, definition: TableDefinition, )
src/metadata_store/mod.rs:524
↓ 2 callers
Function
format_float
(value: f64)
tests/common/mod.rs:224
↓ 2 callers
Function
format_time_value
(seconds: f64, kind: TimeValueKind)
src/sql/runtime/row_functions.rs:422
↓ 2 callers
Function
generate_large_text
(id: usize, prefix: &str, target_size: usize)
benchmarks/high_volume.rs:184
↓ 2 callers
Method
get_as_string
(&self, idx: usize)
src/sql/runtime/batch.rs:681
↓ 2 callers
Method
get_len
(&self, idx: usize)
src/sql/runtime/batch.rs:282
↓ 2 callers
Method
get_or_create_writer
(&self, col_name: &str)
src/wal/wal/runtime/walrus.rs:127
↓ 2 callers
Method
handle_job
(&mut self, job: UpdateJob)
src/writer/executor.rs:220
↓ 2 callers
Function
install_fixture
()
tests/sql_massive_correctness/time.rs:3
↓ 2 callers
Function
install_fixture
()
tests/sql_massive_correctness/windows.rs:3
↓ 2 callers
Method
into_rows
(self)
tests/common/mod.rs:39
↓ 2 callers
Method
invert
(&mut self)
src/sql/runtime/batch.rs:104
↓ 2 callers
Function
is_aggregate_function
(function: &Function)
src/sql/runtime/aggregates.rs:695
↓ 2 callers
Method
is_expr_masked
(&self, expr: &Expr)
src/sql/runtime/aggregates.rs:613
↓ 2 callers
Function
is_numeric_literal
(expr: &Expr)
src/pipeline/planner.rs:447
↓ 2 callers
Method
latest_for_column
(&self, column: &str)
src/page_handler/mod.rs:31
↓ 2 callers
Method
locate_latest
(&self, column: &str)
src/page_handler/mod.rs:361
↓ 2 callers
Function
locate_rows_by_sort_tuple
( page_handler: &PageHandler, page_directory: &PageDirectory, table: &str, sort_columns: &[Col
src/sql/runtime/scan_helpers.rs:40
↓ 2 callers
Method
mark_topic_clean
(&self, topic: &str)
src/wal/wal/runtime/walrus.rs:115
↓ 2 callers
Method
mark_topic_dirty
(&self, topic: &str)
src/wal/wal/runtime/walrus.rs:108
↓ 2 callers
Method
mask_unused_bits
(&mut self)
src/sql/runtime/batch.rs:159
↓ 2 callers
Function
materialize_column_in_batch
( page_handler: &PageHandler, table: &str, column: &str, row_ids: &[u64], )
src/pipeline/types.rs:438
↓ 2 callers
Method
meta_wal
(&self)
tests/writer_tests.rs:83
↓ 2 callers
Function
normalize_rows
(rows: Vec<Vec<Option<String>>>)
tests/common/mod.rs:622
↓ 2 callers
Function
numeric_to_seconds
(value: f64)
src/sql/runtime/row_functions.rs:394
↓ 2 callers
Function
open_direct_reader
(path: &str)
src/page_handler/page_io.rs:376
↓ 2 callers
Function
page_value_truthy
(page: &ColumnarPage, row_idx: usize)
src/sql/runtime/expressions.rs:1016
↓ 2 callers
Function
parse_bool_bytes
(bytes: &[u8])
src/sql/runtime/expressions.rs:1496
↓ 2 callers
Method
parse_insert_values
( &self, statement: Statement, )
src/sql/executor/dml.rs:12
↓ 2 callers
Function
parse_interval_seconds
(expr: &Expr, context: &str)
src/sql/runtime/helpers.rs:86
↓ 2 callers
Function
parse_numeric_literal
(expr: &Expr)
src/sql/runtime/page_pruning.rs:135
↓ 2 callers
Function
parse_usize_literal
(expr: &Expr, context: &str)
src/sql/runtime/helpers.rs:73
↓ 2 callers
Method
partial_cmp
(&self, other: &Self)
src/pipeline/types.rs:515
↓ 2 callers
Method
persist
(&self)
src/wal/wal/runtime/index.rs:70
↓ 2 callers
Function
plan_create_table_statement
(statement: &Statement)
src/sql/planner.rs:86
↓ 2 callers
Method
plan_like
( &self, expr: &Expr, pattern: &Expr, case_insensitive: bool, negated:
src/sql/planner.rs:999
↓ 2 callers
Function
plan_order_clauses
( order_by: &[OrderByExpr], alias_map: Option<&HashMap<String, Expr>>, )
src/pipeline/window_helpers.rs:20
↓ 2 callers
Function
plan_query
(query: &Query, directory: &PageDirectory)
src/sql/planner.rs:147
↓ 2 callers
Function
plan_row_ids_for_select
( executor: &SqlExecutor, table_name: &str, sort_columns: &[ColumnCatalog], selection_expr: Op
src/pipeline/planner.rs:60
↓ 2 callers
Method
prefer_exact_numeric
(&self)
src/sql/runtime/aggregates.rs:619
↓ 2 callers
Function
print_help
()
src/main.rs:194
↓ 2 callers
Function
print_usage
()
benchmarks/high_volume.rs:167
↓ 2 callers
Method
process_partition
( &self, mut batch: ColumnarBatch, )
src/pipeline/window_helpers.rs:1007
↓ 2 callers
Function
prune_predicate_for_op
( op: &sqlparser::ast::BinaryOperator, value: crate::sql::runtime::values::ScalarValue, )
src/sql/runtime/scan_stream.rs:322
↓ 2 callers
Function
push_expression_item
( expr: Expr, alias: Option<String>, column_ordinals: &HashMap<String, usize>, table_name: &st
src/sql/runtime/projection_helpers.rs:99
↓ 2 callers
Function
push_projection_item
( item: SelectItem, column_ordinals: &HashMap<String, usize>, table_name: &str, plan: &mut Pro
src/sql/runtime/projection_helpers.rs:74
↓ 2 callers
Method
range_in_table
( &self, table: &str, column: &str, l_bound: u64, r_bound: u64,
src/metadata_store/mod.rs:1013
↓ 2 callers
Method
read_batch_from_path
( &self, path: &str, offsets: &[u64], )
src/page_handler/page_io.rs:87
↓ 2 callers
Function
read_size_from_meta
(buf: &[u8])
src/page_handler/page_io.rs:325
↓ 2 callers
Method
replace_with_disk_page
(&mut self, page: Page, dtype: DataType)
src/cache/page_cache.rs:38
↓ 2 callers
Method
reserve_descriptor_id
(&mut self)
src/metadata_store/mod.rs:356
↓ 2 callers
Function
resolve_batch_column
( name: &str, batch: &ColumnarBatch, catalog: &TableCatalog, )
src/sql/runtime/expressions.rs:1125
↓ 2 callers
Function
resolve_projection_reference
( expr: &Expr, projection_exprs: &[Expr], )
src/sql/runtime/select_helpers.rs:160
↓ 2 callers
Function
reverse_operator
(op: &BinaryOperator)
src/sql/runtime/physical_evaluator.rs:201
↓ 2 callers
Method
root
(&self)
src/wal/wal/paths.rs:54
↓ 2 callers
Method
rows
(&self)
tests/sql_e2e_tests.rs:14
↓ 2 callers
Function
rows_to_batch
(rows: Vec<Vec<Option<String>>>)
src/sql/runtime/executor_utils.rs:240
↓ 2 callers
Function
run_random_suite
(iterations: usize)
tests/sql_massive_correctness/randomized.rs:29
↓ 2 callers
Function
scalar_to_string
(value: &ScalarValue)
src/sql/runtime/ordering.rs:126
↓ 2 callers
Function
scalar_to_string
(val: &ScalarValue)
src/sql/runtime/physical_evaluator.rs:868
↓ 2 callers
Function
seconds_to_datetime
(seconds: f64)
src/sql/runtime/row_functions.rs:410
↓ 2 callers
Method
send_job_to_shard
( &self, shard_index: usize, message: WriterMessage, )
src/writer/executor.rs:861
← previous
next →
301–400 of 1,487, ranked by callers