MCPcopy Create free account

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

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

↓ 4 callersFunctionchecksum64
(data: &[u8])
src/wal/wal/config.rs:69
↓ 4 callersMethodcleanup_on_drop
(mut self, value: bool)
src/sql/executor/wal_options.rs:25
↓ 4 callersFunctioncollect_stream_batches
( mut stream: Box<dyn BatchStream>, )
src/sql/runtime/scan_stream.rs:35
↓ 4 callersMethodcolumn_type
(&self, column: &str)
src/sql/runtime/aggregates.rs:609
↓ 4 callersMethodcolumn_value
(&self, column: &str, row_idx: u64)
src/sql/runtime/aggregates.rs:602
↓ 4 callersFunctioncreate_test_page
(entries: usize)
tests/batch_and_prefetch_tests.rs:13
↓ 4 callersFunctiondescriptor_with_stats
(stats: ColumnStats, entry_count: u64)
src/sql/runtime/page_pruning.rs:294
↓ 4 callersMethodempty_like
(&self)
src/sql/runtime/batch.rs:1065
↓ 4 callersFunctionensure_result
(res: i32)
src/page_handler/page_io.rs:336
↓ 4 callersFunctionflush_check
(file_path: String)
src/wal/wal/runtime/allocator.rs:167
↓ 4 callersMethodinsert_column
(&mut self, name: String, data_type: DataType)
src/metadata_store/mod.rs:169
↓ 4 callersFunctioninsert_sorted_row
( handler: &PageHandler, table: &str, row: &[(&str, &str)], )
src/ops_handler/insert.rs:100
↓ 4 callersFunctioninstall_fixture
()
tests/sql_massive_correctness/randomized.rs:11
↓ 4 callersFunctionis_literal_or_cast
(expr: &PhysicalExpr)
src/sql/runtime/physical_evaluator.rs:61
↓ 4 callersMethodlocate_row_in_table
(&self, table: &str, column: &str, row: u64)
src/page_handler/mod.rs:98
↓ 4 callersMethodmaterialize_many
( &self, items: Vec<(String, Arc<PageCacheEntryCompressed>)>, dtypes: &HashMap<String,
src/page_handler/mod.rs:292
↓ 4 callersFunctionmerge_batches
(mut batches: Vec<ColumnarBatch>)
src/sql/runtime/executor_utils.rs:208
↓ 4 callersFunctionobject_name_to_string
(name: &ObjectName)
src/sql/runtime/helpers.rs:10
↓ 4 callersFunctionpage_numeric_value
(page: &ColumnarPage, row_idx: usize)
src/sql/runtime/expressions.rs:1049
↓ 4 callersFunctionparse_bool
(s: &str)
src/sql/utils.rs:3
↓ 4 callersFunctionparse_datetime
(s: &str)
src/sql/utils.rs:11
↓ 4 callersFunctionparse_limit
(limit: Option<Expr>)
src/sql/runtime/helpers.rs:58
↓ 4 callersFunctionparse_offset
(offset: Option<Offset>)
src/sql/runtime/helpers.rs:66
↓ 4 callersMethodpipeline_executor
(&self)
src/sql/executor/core.rs:40
↓ 4 callersMethodread
(&self, offset: usize, dest: &mut [u8])
src/wal/wal/storage.rs:41
↓ 4 callersFunctionremove_sql_executor_wal_dir
(namespace: &str)
src/sql/runtime/wal_helpers.rs:13
↓ 4 callersMethodreset_namespace
(mut self, value: bool)
src/sql/executor/wal_options.rs:30
↓ 4 callersFunctionround_up_4k
(len: u64)
src/writer/allocator.rs:92
↓ 4 callersFunctionsanitize_namespace
(key: &str)
src/wal/wal/config.rs:87
↓ 4 callersMethodsubmit
(&self, job: UpdateJob)
src/writer/executor.rs:746
↓ 4 callersFunctionsubmit_entry
(ring: &mut IoUring, entry: io_uring::squeue::Entry)
src/page_handler/page_io.rs:345
↓ 4 callersFunctionvectorized_numeric_binary_op
( left: &ColumnarPage, right: &ColumnarPage, op: F, )
src/sql/runtime/expressions.rs:1149
↓ 4 callersFunctionvectorized_ordering_comparison_op
( left: &ColumnarPage, right: &ColumnarPage, predicate: F, )
src/sql/runtime/expressions.rs:1246
↓ 4 callersMethodwrite_to_path
(&self, path: &str, offset: u64, data: Vec<u8>)
src/page_handler/page_io.rs:201
↓ 3 callersMethodappend_block_to_chain
(&self, col: &str, block: Block)
src/wal/wal/runtime/reader.rs:31
↓ 3 callersMethodas_fd
(&self)
src/wal/wal/storage.rs:106
↓ 3 callersFunctionboolean_value_at
(page: &ColumnarPage, idx: usize)
src/sql/runtime/expressions.rs:1483
↓ 3 callersFunctionbuild_non_null_bitmap
(num_rows: usize, null_bitmap: &Bitmap)
src/sql/runtime/physical_evaluator.rs:673
↓ 3 callersFunctionbuild_order_keys_on_batch
( clauses: &[OrderClause], batch: &ColumnarBatch, catalog: &TableCatalog, )
src/sql/runtime/ordering.rs:143
↓ 3 callersFunctioncan_skip_sort
( page_handler: &PageHandler, table: &str, order_clauses: &[OrderClause], catalog: &TableCatal
src/pipeline/select_planner.rs:926
↓ 3 callersMethodclean_marker_path
(&self, topic: &str)
src/wal/wal/runtime/walrus.rs:100
↓ 3 callersMethodcoerce_binary_op
( &self, left: PhysicalExpr, op: BinaryOperator, right: PhysicalExpr, )
src/sql/planner.rs:861
↓ 3 callersFunctioncollect_column_values
( handler: &PageHandler, directory: &PageDirectory, table: &str, column: &str, )
tests/order_by_integration_tests.rs:137
↓ 3 callersFunctioncollect_select_items
(items: &[SelectItem], columns: &mut BTreeSet<String>)
src/sql/planner.rs:405
↓ 3 callersFunctioncolumn_expr
(name: &str)
src/sql/runtime/page_pruning.rs:246
↓ 3 callersMethodcolumns
(&self)
tests/common/mod.rs:488
↓ 3 callersFunctioncombine_group_sets
(current: &[Vec<Expr>], additions: &[Vec<Expr>])
src/sql/runtime/grouping_helpers.rs:80
↓ 3 callersMethodcreate_new_file
(&self)
src/wal/wal/paths.rs:36
↓ 3 callersFunctioncreate_test_page_handler
()
tests/executor_tests.rs:17
↓ 3 callersFunctiondescribe_table
(executor: &SqlExecutor, table: &str)
src/main.rs:216
↓ 3 callersFunctionencode_null
()
src/sql/runtime/values.rs:9
↓ 3 callersFunctionensure_parent_dir
(path: &str)
src/page_handler/page_io.rs:302
↓ 3 callersFunctionevaluate_condition
( expr: &Expr, row_idx: u64, dataset: &AggregateDataset, )
src/sql/runtime/aggregates.rs:1356
↓ 3 callersFunctionevaluate_filters
(filters: &[FilterExpr], batch: &ColumnarBatch)
src/pipeline/types.rs:19
↓ 3 callersFunctionexecute_sql
(executor: &SqlExecutor, sql: &str)
src/main.rs:117
↓ 3 callersFunctionextract_table_name
(table: &TableWithJoins)
src/sql/planner.rs:710
↓ 3 callersMethodfetch_and_insert_batch
( &self, metas: &[PageDescriptor], )
src/page_handler/mod.rs:174
↓ 3 callersMethodfile
(&self)
src/wal/wal/storage.rs:55
↓ 3 callersFunctionfilter_expr_from_physical
(expr: PhysicalExpr)
src/sql/planner.rs:327
↓ 3 callersMethodfind_key
(&self, value: &[u8])
src/sql/runtime/batch.rs:513
↓ 3 callersMethodfinish
(self)
src/sql/runtime/spill.rs:21
↓ 3 callersFunctionfloat_eq
(left: f64, right: f64)
src/sql/runtime/expressions.rs:1505
↓ 3 callersFunctionformat_timestamp_micros
(micros: i64)
src/sql/runtime/values.rs:175
↓ 3 callersMethodgather_column_for_rows
( &self, table: &str, column: &str, row_ids: &[u64], )
src/page_handler/mod.rs:421
↓ 3 callersMethodget_value_as_string
(&self, idx: usize)
src/sql/runtime/batch.rs:1061
↓ 3 callersFunctionglue_predicates
(predicates: &[String], rng: &mut StdRng)
tests/sql_massive_correctness/randomized.rs:757
↓ 3 callersFunctionlist_tables
(executor: &SqlExecutor)
src/main.rs:205
↓ 3 callersMethodlocate_range_in_table
( &self, table: &str, column: &str, start_row: u64, end_row: u64,
src/metadata_store/mod.rs:994
↓ 3 callersMethodlocate_row
(&self, table: &str, column: &str, row: u64)
src/metadata_store/mod.rs:670
↓ 3 callersFunctionmake_bitmap
(len: usize, null_indices: &[usize])
src/writer/executor.rs:1084
↓ 3 callersMethodmaterialize_one
( &self, id: &str, compressed: Arc<PageCacheEntryCompressed>, dtype: DataType,
src/page_handler/mod.rs:275
↓ 3 callersFunctionnumber_expr
(value: &str)
src/sql/runtime/page_pruning.rs:250
↓ 3 callersFunctionobject_name_to_string
(name: &ObjectName)
src/sql/planner.rs:729
↓ 3 callersFunctionopen_data_file
(file_id: u32, data_dir: &str)
src/writer/allocator.rs:81
↓ 3 callersFunctionopen_direct_writer
(path: &str)
src/page_handler/page_io.rs:384
↓ 3 callersMethodpages_for_in_table
(&self, table: &str, column: &str)
src/metadata_store/mod.rs:966
↓ 3 callersFunctionparse_usize_literal
(expr: &Expr)
src/pipeline/window_helpers.rs:333
↓ 3 callersMethodpublish_staged_columns
(&mut self, table: &str, staged: Vec<StagedColumn>)
src/writer/executor.rs:290
↓ 3 callersFunctionrandom_predicate
(_row_count: i64, rng: &mut StdRng)
tests/sql_massive_correctness/randomized.rs:778
↓ 3 callersMethodread_entry_at
(&self, table: &str, column: &str, row: u64)
src/page_handler/mod.rs:409
↓ 3 callersMethodread_next
(&self, col_name: &str, checkpoint: bool)
src/wal/wal/runtime/walrus_read.rs:23
↓ 3 callersFunctionregex_match
(value: &str, pattern: &str)
src/sql/runtime/helpers.rs:455
↓ 3 callersFunctionrewrite_window_expressions
( expr: &mut Expr, alias_map: &HashMap<String, String>, )
src/pipeline/window_helpers.rs:754
↓ 3 callersMethodrows
(&self)
tests/sql_crash_recovery_tests.rs:22
↓ 3 callersFunctionscalar_to_seconds
(value: &ScalarValue)
src/sql/runtime/row_functions.rs:381
↓ 3 callersFunctionsetup_writer_components
()
tests/writer_tests.rs:109
↓ 3 callersFunctionvectorized_boolean_binary_op
( left: &ColumnarPage, right: &ColumnarPage, op: F, )
src/sql/runtime/expressions.rs:1365
↓ 3 callersFunctionwait_for
(ring: &mut IoUring, expected: usize, mut on_complete: F)
src/page_handler/page_io.rs:358
↓ 3 callersMethodwrite
(&self, offset: usize, data: &[u8])
src/wal/wal/storage.rs:35
↓ 3 callersMethodzero_range
(&self, in_block_offset: u64, size: u64)
src/wal/wal/block.rs:130
↓ 2 callersMethodack_wal_entries
(&self, table: &str, mut count: usize)
src/writer/executor.rs:341
↓ 2 callersMethodadd_columns
( &mut self, table: &str, columns: Vec<ColumnDefinition>, )
src/metadata_store/mod.rs:573
↓ 2 callersMethodall_pages
(&self)
src/metadata_store/mod.rs:294
↓ 2 callersMethodalloc_block
SAFETY: Caller must ensure the resulting `Block` remains uniquely used by one writer and not read concurrently while being written. The internal spin
src/wal/wal/runtime/allocator.rs:85
↓ 2 callersMethodallocate_descriptor
( &mut self, descriptor_id: Option<String>, disk_path: String, offset: u64,
src/metadata_store/mod.rs:608
↓ 2 callersMethodand
(lhs: FilterExpr, rhs: FilterExpr)
src/sql/models.rs:125
↓ 2 callersMethodas_slice_mut
(&mut self)
src/page_handler/page_io.rs:65
↓ 2 callersFunctionassert_batches_match
(lhs: &PipelineBatch, rhs: &PipelineBatch)
tests/pipeline_tests.rs:24
↓ 2 callersFunctionassert_batches_match
(lhs: &PipelineBatch, rhs: &PipelineBatch)
tests/pipeline_filtering_integration_tests.rs:23
↓ 2 callersFunctionboolean_bitmap_from_page
(page: &ColumnarPage)
src/pipeline/filtering.rs:61
← previousnext →201–300 of 1,487, ranked by callers