MCPcopy Create free account

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

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

↓ 2 callersFunctionboolean_page_from_bitmap
(bitmap: &Bitmap, invert: bool)
src/sql/runtime/expressions.rs:1427
↓ 2 callersFunctionbuild_null_prunable_predicate
( expr: &Expr, expect_null: bool, acc: &mut Vec<PagePrunePredicate>, )
src/sql/runtime/page_pruning.rs:85
↓ 2 callersFunctioncollect_all_columns
(table_columns: &[ColumnCatalog])
src/sql/runtime/projection_helpers.rs:124
↓ 2 callersFunctioncollect_expr_column_names
(expr: &Expr, columns: &mut BTreeSet<String>)
src/sql/runtime/helpers.rs:235
↓ 2 callersFunctioncollect_function_order_ordinals
( expr: &Expr, column_ordinals: &HashMap<String, usize>, table: &str, out: &mut BTreeSet<usize
src/sql/runtime/aggregates.rs:782
↓ 2 callersFunctioncollect_matching_row_ids
( executor: &SqlExecutor, table_name: &str, catalog: &crate::metadata_store::TableCatalog, col
src/pipeline/mutation_planner.rs:221
↓ 2 callersFunctioncollect_order_by_columns
( order_by: &[OrderByExpr], columns: &mut BTreeSet<String>, )
src/sql/planner.rs:423
↓ 2 callersFunctioncollect_select_item
(item: &SelectItem, columns: &mut BTreeSet<String>)
src/sql/planner.rs:412
↓ 2 callersFunctioncollect_window_plans_from_expr
( expr: &Expr, plans: &mut Vec<WindowFunctionPlan>, )
src/pipeline/window_helpers.rs:221
↓ 2 callersFunctioncolumn_from_strings
(values: Vec<Option<String>>)
src/sql/runtime/expressions.rs:1060
↓ 2 callersFunctioncompare_strs
(left: &str, right: &str)
src/ops_handler/helpers.rs:70
↓ 2 callersFunctioncomparison_for_operator
( op: &BinaryOperator, column_on_left: bool, )
src/sql/runtime/page_pruning.rs:105
↓ 2 callersFunctioncreate_storage_impl
(path: &str)
src/wal/wal/storage.rs:124
↓ 2 callersFunctiondata_file_path
(file_id: u32, data_dir: &str)
src/writer/allocator.rs:77
↓ 2 callersFunctiondataset
(config: &MassiveFixtureConfig)
tests/common/mod.rs:249
↓ 2 callersFunctiondelete_row
( handler: &PageHandler, table: &str, row_idx: u64, )
src/ops_handler/delete.rs:5
↓ 2 callersFunctiondisplay_joined
( separator: &str, parts: &[FilterExpr], f: &mut fmt::Formatter<'_>, )
src/sql/models.rs:174
↓ 2 callersMethoddo_register_table
( &mut self, name: String, columns: Vec<ColumnDefinition>, sort_key: Vec<Strin
src/metadata_store/mod.rs:444
↓ 2 callersFunctiondummy_batch
(row_ids: &[u64])
tests/pipeline_filtering_integration_tests.rs:16
↓ 2 callersMethodensure_compatible
(&mut self, other: &Bitmap)
src/sql/runtime/batch.rs:146
↓ 2 callersMethodensure_root
(&self)
src/wal/wal/paths.rs:28
↓ 2 callersMethodensure_table_column
(&mut self, table: &str, column: &str)
src/metadata_store/mod.rs:408
↓ 2 callersFunctionestimate_table_row_count
( page_handler: &PageHandler, table: &str, columns: &[ColumnCatalog], )
src/sql/runtime/row_counts.rs:5
↓ 2 callersFunctionevaluate_col_lit
( col: &ColumnData, null_bitmap: &Bitmap, op: &BinaryOperator, lit: &ScalarValue, num_rows
src/sql/runtime/physical_evaluator.rs:214
↓ 2 callersFunctionevaluate_date_trunc_row
( function: &Function, row_idx: u64, dataset: &AggregateDataset, )
src/sql/runtime/row_functions.rs:273
↓ 2 callersFunctionevaluate_filter_expr_with_batch
(filter: &FilterExpr, batch: &ColumnarBatch)
src/pipeline/types.rs:33
↓ 2 callersFunctionevaluate_group_keys_on_batch
( group_by_exprs: &[Expr], batch: &ColumnarBatch, catalog: &TableCatalog, )
src/sql/runtime/grouping_helpers.rs:145
↓ 2 callersFunctionevaluate_is_null
(expr: &PhysicalExpr, batch: &ColumnarBatch)
src/sql/runtime/physical_evaluator.rs:1032
↓ 2 callersFunctionevaluate_time_bucket_row
( function: &Function, row_idx: u64, dataset: &AggregateDataset, )
src/sql/runtime/row_functions.rs:190
↓ 2 callersFunctionexecute_grouping_set_aggregation_rows_from_batch
( page_handler: &PageHandler, batch: &ColumnarBatch, table: &str, catalog: &TableCatalog,
src/sql/runtime/aggregation_exec.rs:23
↓ 2 callersMethodexecute_grouping_set_rows_from_batch
( &self, batch: &crate::sql::runtime::batch::ColumnarBatch, group_exprs: &[Expr],
src/pipeline/operators/aggregate.rs:107
↓ 2 callersFunctionexecute_statement
( executor: &SqlExecutor, statement: Statement, )
src/pipeline/dispatcher.rs:5
↓ 2 callersFunctionexpr_contains_aggregate
(expr: &Expr)
src/sql/runtime/aggregates.rs:632
↓ 2 callersFunctionexpression_touches_sort
(expr: &Expr, sort_names: &HashSet<&str>)
src/pipeline/planner.rs:183
↓ 2 callersFunctionextract_single_argument
(function: &Function)
src/sql/runtime/aggregates.rs:1365
↓ 2 callersFunctionfinalize_aggregation_rows
( mut aggregated_rows: Vec<AggregatedRow>, order_clauses: &[OrderClause], distinct_flag: bool,
src/sql/runtime/aggregation_exec.rs:118
↓ 2 callersMethodflush_page_group
(&mut self, table: &str, mut rows: Vec<Vec<String>>)
src/writer/executor.rs:386
↓ 2 callersMethodflush_pending
(&mut self, table: &str)
src/writer/executor.rs:453
↓ 2 callersMethodforce_register_table
( &mut self, definition: TableDefinition, )
src/metadata_store/mod.rs:524
↓ 2 callersFunctionformat_float
(value: f64)
tests/common/mod.rs:224
↓ 2 callersFunctionformat_time_value
(seconds: f64, kind: TimeValueKind)
src/sql/runtime/row_functions.rs:422
↓ 2 callersFunctiongenerate_large_text
(id: usize, prefix: &str, target_size: usize)
benchmarks/high_volume.rs:184
↓ 2 callersMethodget_as_string
(&self, idx: usize)
src/sql/runtime/batch.rs:681
↓ 2 callersMethodget_len
(&self, idx: usize)
src/sql/runtime/batch.rs:282
↓ 2 callersMethodget_or_create_writer
(&self, col_name: &str)
src/wal/wal/runtime/walrus.rs:127
↓ 2 callersMethodhandle_job
(&mut self, job: UpdateJob)
src/writer/executor.rs:220
↓ 2 callersFunctioninstall_fixture
()
tests/sql_massive_correctness/time.rs:3
↓ 2 callersFunctioninstall_fixture
()
tests/sql_massive_correctness/windows.rs:3
↓ 2 callersMethodinto_rows
(self)
tests/common/mod.rs:39
↓ 2 callersMethodinvert
(&mut self)
src/sql/runtime/batch.rs:104
↓ 2 callersFunctionis_aggregate_function
(function: &Function)
src/sql/runtime/aggregates.rs:695
↓ 2 callersMethodis_expr_masked
(&self, expr: &Expr)
src/sql/runtime/aggregates.rs:613
↓ 2 callersFunctionis_numeric_literal
(expr: &Expr)
src/pipeline/planner.rs:447
↓ 2 callersMethodlatest_for_column
(&self, column: &str)
src/page_handler/mod.rs:31
↓ 2 callersMethodlocate_latest
(&self, column: &str)
src/page_handler/mod.rs:361
↓ 2 callersFunctionlocate_rows_by_sort_tuple
( page_handler: &PageHandler, page_directory: &PageDirectory, table: &str, sort_columns: &[Col
src/sql/runtime/scan_helpers.rs:40
↓ 2 callersMethodmark_topic_clean
(&self, topic: &str)
src/wal/wal/runtime/walrus.rs:115
↓ 2 callersMethodmark_topic_dirty
(&self, topic: &str)
src/wal/wal/runtime/walrus.rs:108
↓ 2 callersMethodmask_unused_bits
(&mut self)
src/sql/runtime/batch.rs:159
↓ 2 callersFunctionmaterialize_column_in_batch
( page_handler: &PageHandler, table: &str, column: &str, row_ids: &[u64], )
src/pipeline/types.rs:438
↓ 2 callersMethodmeta_wal
(&self)
tests/writer_tests.rs:83
↓ 2 callersFunctionnormalize_rows
(rows: Vec<Vec<Option<String>>>)
tests/common/mod.rs:622
↓ 2 callersFunctionnumeric_to_seconds
(value: f64)
src/sql/runtime/row_functions.rs:394
↓ 2 callersFunctionopen_direct_reader
(path: &str)
src/page_handler/page_io.rs:376
↓ 2 callersFunctionpage_value_truthy
(page: &ColumnarPage, row_idx: usize)
src/sql/runtime/expressions.rs:1016
↓ 2 callersFunctionparse_bool_bytes
(bytes: &[u8])
src/sql/runtime/expressions.rs:1496
↓ 2 callersMethodparse_insert_values
( &self, statement: Statement, )
src/sql/executor/dml.rs:12
↓ 2 callersFunctionparse_interval_seconds
(expr: &Expr, context: &str)
src/sql/runtime/helpers.rs:86
↓ 2 callersFunctionparse_numeric_literal
(expr: &Expr)
src/sql/runtime/page_pruning.rs:135
↓ 2 callersFunctionparse_usize_literal
(expr: &Expr, context: &str)
src/sql/runtime/helpers.rs:73
↓ 2 callersMethodpartial_cmp
(&self, other: &Self)
src/pipeline/types.rs:515
↓ 2 callersMethodpersist
(&self)
src/wal/wal/runtime/index.rs:70
↓ 2 callersFunctionplan_create_table_statement
(statement: &Statement)
src/sql/planner.rs:86
↓ 2 callersMethodplan_like
( &self, expr: &Expr, pattern: &Expr, case_insensitive: bool, negated:
src/sql/planner.rs:999
↓ 2 callersFunctionplan_order_clauses
( order_by: &[OrderByExpr], alias_map: Option<&HashMap<String, Expr>>, )
src/pipeline/window_helpers.rs:20
↓ 2 callersFunctionplan_query
(query: &Query, directory: &PageDirectory)
src/sql/planner.rs:147
↓ 2 callersFunctionplan_row_ids_for_select
( executor: &SqlExecutor, table_name: &str, sort_columns: &[ColumnCatalog], selection_expr: Op
src/pipeline/planner.rs:60
↓ 2 callersMethodprefer_exact_numeric
(&self)
src/sql/runtime/aggregates.rs:619
↓ 2 callersFunctionprint_help
()
src/main.rs:194
↓ 2 callersFunctionprint_usage
()
benchmarks/high_volume.rs:167
↓ 2 callersMethodprocess_partition
( &self, mut batch: ColumnarBatch, )
src/pipeline/window_helpers.rs:1007
↓ 2 callersFunctionprune_predicate_for_op
( op: &sqlparser::ast::BinaryOperator, value: crate::sql::runtime::values::ScalarValue, )
src/sql/runtime/scan_stream.rs:322
↓ 2 callersFunctionpush_expression_item
( expr: Expr, alias: Option<String>, column_ordinals: &HashMap<String, usize>, table_name: &st
src/sql/runtime/projection_helpers.rs:99
↓ 2 callersFunctionpush_projection_item
( item: SelectItem, column_ordinals: &HashMap<String, usize>, table_name: &str, plan: &mut Pro
src/sql/runtime/projection_helpers.rs:74
↓ 2 callersMethodrange_in_table
( &self, table: &str, column: &str, l_bound: u64, r_bound: u64,
src/metadata_store/mod.rs:1013
↓ 2 callersMethodread_batch_from_path
( &self, path: &str, offsets: &[u64], )
src/page_handler/page_io.rs:87
↓ 2 callersFunctionread_size_from_meta
(buf: &[u8])
src/page_handler/page_io.rs:325
↓ 2 callersMethodreplace_with_disk_page
(&mut self, page: Page, dtype: DataType)
src/cache/page_cache.rs:38
↓ 2 callersMethodreserve_descriptor_id
(&mut self)
src/metadata_store/mod.rs:356
↓ 2 callersFunctionresolve_batch_column
( name: &str, batch: &ColumnarBatch, catalog: &TableCatalog, )
src/sql/runtime/expressions.rs:1125
↓ 2 callersFunctionresolve_projection_reference
( expr: &Expr, projection_exprs: &[Expr], )
src/sql/runtime/select_helpers.rs:160
↓ 2 callersFunctionreverse_operator
(op: &BinaryOperator)
src/sql/runtime/physical_evaluator.rs:201
↓ 2 callersMethodroot
(&self)
src/wal/wal/paths.rs:54
↓ 2 callersMethodrows
(&self)
tests/sql_e2e_tests.rs:14
↓ 2 callersFunctionrows_to_batch
(rows: Vec<Vec<Option<String>>>)
src/sql/runtime/executor_utils.rs:240
↓ 2 callersFunctionrun_random_suite
(iterations: usize)
tests/sql_massive_correctness/randomized.rs:29
↓ 2 callersFunctionscalar_to_string
(value: &ScalarValue)
src/sql/runtime/ordering.rs:126
↓ 2 callersFunctionscalar_to_string
(val: &ScalarValue)
src/sql/runtime/physical_evaluator.rs:868
↓ 2 callersFunctionseconds_to_datetime
(seconds: f64)
src/sql/runtime/row_functions.rs:410
↓ 2 callersMethodsend_job_to_shard
( &self, shard_index: usize, message: WriterMessage, )
src/writer/executor.rs:861
← previousnext →301–400 of 1,487, ranked by callers