Functions — github.com/databendlabs/databend

hub / github.com/databendlabs/databend / functions

Functions29,332 in github.com/databendlabs/databend

⨍ Functions 29,332◇ Types & classes 5,717↳ Endpoints 41

↓ 85 callersMethodinsert

(&mut self, value: u64)

src/common/io/src/bitmap.rs:147

↓ 85 callersMethodput_and_commit

(&mut self, item: V)

src/query/expression/src/types/string.rs:318

↓ 85 callersMethodregister_function_factory

(&mut self, name: &str, factory: FunctionFactory)

src/query/expression/src/function.rs:357

↓ 84 callersMethodget_table

( &self, )

src/meta/schema-api-test-suite/src/db_table_harness.rs:287

↓ 84 callersMethodtry_into

(self)

src/query/config/src/config.rs:322

↓ 83 callersMethodfirst

(&self)

src/query/pipeline/transforms/src/processors/transforms/sorts/core/rows.rs:50

↓ 83 callersMethodput_str

(&mut self, item: &str)

src/query/expression/src/types/string.rs:313

↓ 83 callersFunctiontokenize_sql

(sql: &str)

src/query/ast/src/parser/parser.rs:42

↓ 82 callersMethodbuild

(self)

src/query/sql/src/planner/binder/explain.rs:97

↓ 82 callersMethodidentity

(&self)

src/meta/app/src/principal/user_info.rs:99

↓ 82 callersMethodregister_aliases

(&mut self, fn_name: &str, aliases: &[&str])

src/query/expression/src/function.rs:365

↓ 82 callersFunctionwrite_comma_separated_list

Write input items into `a, b, c`

src/query/ast/src/ast/common.rs:225

↓ 81 callersMethodexecute

(self, sql)

tests/fuzz/fuzz.py:169

↓ 81 callersMethodremove

(&self, key: Data::Key)

src/query/service/src/sessions/queue_mgr.rs:178

↓ 80 callersMethodinsert

(key: K, value: K::ValueType)

src/meta/api/src/kv/pb_api/upsert_pb.rs:56

↓ 79 callersMethodis_empty

(&self)

src/query/service/src/servers/http/v1/query/blocks_serializer.rs:124

↓ 79 callersMethodis_empty

(&self)

src/query/expression/src/kernels/take_chunks.rs:1058

↓ 78 callersMethodget

(&self, id: &RuleID)

src/query/sql/src/planner/optimizer/optimizers/rule/rule_set.rs:82

↓ 78 callersMethodget_table

( &self, catalog: &str, database: &str, table: &str, max_batch_size: O

src/query/service/src/sessions/query_ctx_shared.rs:413

↓ 78 callersMethodis_empty

(&self)

src/meta/app/src/schema/database.rs:164

↓ 78 callersFunctionmap_res

A fork of `map_res` from nom, but doesn't require `FromExternalError`.

src/query/ast/src/parser/common.rs:629

↓ 78 callersFunctionparse

(bencher: divan::Bencher, n: usize)

src/query/functions/benches/bench.rs:40

↓ 78 callersMethodwrite

(&mut self, query_result: Result<()>)

src/query/service/src/servers/mysql/writers/init_result_writer.rs:31

↓ 77 callersMethodchecked_add

(self, rhs: Self)

src/query/expression/src/types/decimal.rs:739

↓ 77 callersMethodcollect

(&self)

src/common/tracing/src/remote_log.rs:306

↓ 77 callersMethodhas_data

(&self)

src/query/pipeline/src/core/port.rs:183

↓ 77 callersMethodnum_columns

(&self)

src/query/expression/src/block.rs:563

↓ 77 callersFunctionrun_optimizer

Runs the optimizer with the given predicates and returns the result

src/query/service/tests/it/sql/planner/optimizer/optimizers/operator/filter/infer_filter_test.rs:29

↓ 77 callersMethodwrite

(&mut self, block: DataBlock)

src/query/service/src/spillers/block_writer.rs:46

↓ 76 callersMethodget_database

( &self, )

src/meta/schema-api-test-suite/src/db_table_harness.rs:162

↓ 76 callersMethodkeys

Collect all the keys from the HeaderMap.

src/query/service/src/servers/http/middleware/session.rs:169

↓ 76 callersMethodslice

(&self, range: R)

src/query/ast/src/parser/input.rs:44

↓ 75 callersMethodadd_pipe

(&mut self, pipe: Pipe)

src/query/pipeline/src/core/pipeline.rs:205

↓ 75 callersMethodlower_ast_expr

(&mut self, expr: &'a Expr)

src/query/sql/src/planner/semantic/type_check/core_expr.rs:72

↓ 75 callersMethodremove

(&self, params: &LoadParams)

src/query/storages/common/cache/src/read/cached_ttl_reader.rs:144

↓ 75 callersMethodsend

(&self, data: DataPacket)

src/query/service/src/servers/flight/flight_client.rs:294

↓ 74 callersMethodclone

(&self)

src/query/expression/src/expression.rs:212

↓ 74 callersMethoddefault_db_name

(&self)

src/query/service/src/test_kits/fixture.rs:344

↓ 74 callersMethodget

(&self, k: &Q)

src/query/service/src/servers/http/v1/query/expiring_map.rs:117

↓ 74 callersMethodget_current_user

(&self)

src/query/service/src/sessions/session.rs:281

↓ 74 callersMethodnum_rows

Get the number of rows in this collection

src/query/storages/fuse/src/io/read/block/parquet/adapter.rs:114

↓ 74 callersFunctionnumber

(ty: NumberDataType)

src/query/expression/tests/it/conversion.rs:580

↓ 73 callersMethodlatest_default_table

(&self)

src/query/service/src/test_kits/fixture.rs:877

↓ 73 callersMethodposition

(&self, predicate: P)

src/query/ast/src/parser/input.rs:106

↓ 72 callersMethodexecute

(&self, pipeline: &mut Pipeline)

src/query/service/src/interpreters/hook/hook.rs:77

↓ 72 callersMethodname

()

src/query/service/src/servers/http/v1/http_query_handlers.rs:1244

↓ 72 callersMethodoptions

(&self)

src/query/sql/src/planner/format/display.rs:120

↓ 72 callersMethodspawn

( query_id: &str, ctx: Arc<QueryContext>, exchange: FlightExchange, executor:

src/query/service/src/servers/flight/v1/exchange/statistics_sender.rs:53

↓ 72 callersMethodsplit

(&mut self, pred: &ScalarExpr, column_map: &HashMap<Symbol, ScalarExpr>)

src/query/sql/src/planner/optimizer/optimizers/rule/agg_rules/agg_index/query_rewrite.rs:439

↓ 72 callersMethodsplit

Split the error into `AppError` or `MetaError`. Returns `Ok(AppError)` for application-level errors, or `Err(MetaError)` for infrastructure errors.

src/meta/api/src/error/app_error.rs:187

↓ 71 callersFunctionassume

(condition: bool)

src/common/base/src/hints/mod.rs:16

↓ 71 callersFunctionfrom_slice

()

src/common/column/tests/it/bitmap/mutable.rs:20

↓ 71 callersMethodget_or_create

Get or create an operator from cache

src/common/storage/src/operator_cache.rs:73

↓ 71 callersMethodis_empty

(&self)

src/query/ast/src/ast/statements/udf.rs:128

↓ 70 callersMethodlen

(&self)

src/query/ast/src/ast/statements/udf.rs:121

↓ 70 callersMethodlen

(&self)

src/query/expression/src/kernels/take_index.rs:49

↓ 70 callersMethodpush

Tries to push `value` onto the heap, calling `comparer` with `state` to determine ordering. # Returns `None` if there was spare capacity to accommod

src/common/base/src/containers/fixed_heap.rs:194

↓ 69 callersMethodcmp

(&self, other: &Self)

src/query/storages/fuse/src/pruning/vector_index_pruner.rs:667

↓ 69 callersMethodindex

Get the index this table entry.

src/query/sql/src/planner/metadata/metadata.rs:595

↓ 69 callersMethodindex

(&self, index: usize)

src/query/expression/src/block.rs:180

↓ 69 callersMethodto_str

(&self)

src/meta/app/src/principal/user_auth.rs:123

↓ 69 callersMethodwith_context

Set the context of the error.

src/meta/proto-conv/src/error.rs:43

↓ 68 callersMethodas_remote_expr

(&self)

src/query/expression/src/expression.rs:927

↓ 68 callersMethodblock_on

(&self, future: F)

src/query/sql/src/planner/semantic/type_check/adapter.rs:94

↓ 68 callersMethodname

(&self)

src/query/service/src/physical_plans/physical_constant_table_scan.rs:89

↓ 68 callersMethodproject_column_ref

( &self, f: impl Fn(&Index) -> ToIndex + Copy, )

src/query/expression/src/expression.rs:566

↓ 68 callersMethodreplace

(&mut self, i: usize, data_block: DataBlock)

src/query/expression/src/block_vec.rs:266

↓ 67 callersMethodappend

(&mut self, batch: BytesBatch)

src/query/storages/stage/src/read/row_based/formats/csv/separator.rs:70

↓ 67 callersMethoddata_type

(&self)

src/query/expression/src/types/opaque.rs:341

↓ 67 callersMethodprecision

(&self)

src/query/expression/src/types/decimal.rs:540

↓ 67 callersMethodread_table_snapshot

(&self)

src/query/storages/fuse/src/fuse_table.rs:413

↓ 67 callersFunctionset

(byte: u8, i: usize, value: bool)

src/common/column/src/bitmap/utils/mod.rs:58

↓ 66 callersMethodcall

( &mut self, span: Span, func_name: &'static str, args: CoreExprArgs, )

src/query/sql/src/planner/semantic/type_check/core_expr.rs:458

↓ 66 callersMethodcheck_enterprise_enabled

(&self, license_key: String, feature: Feature)

src/query/sql/tests/it/framework/lite_context.rs:180

↓ 66 callersMethodget_operator

(&self)

src/query/storages/fuse/src/fuse_table.rs:496

↓ 66 callersMethodnext

(&mut self)

src/query/service/src/pipelines/processors/transforms/new_hash_join/join.rs:58

↓ 66 callersFunctionschema

()

src/query/storages/stream/src/stream_status_table_func.rs:241

↓ 65 callersMethodchecked_mul

(self, rhs: Self)

src/query/expression/src/types/decimal.rs:751

↓ 65 callersMethodcreate_db

(&mut self)

src/meta/schema-api-test-suite/src/db_table_harness.rs:134

↓ 65 callersMethodexecute_query

(&self, query: &str)

src/query/service/src/test_kits/fixture.rs:948

↓ 65 callersMethodfilter

Create a filter

src/query/service/tests/it/sql/planner/optimizer/test_utils.rs:527

↓ 65 callersMethodinsert

(&mut self, value: u64)

src/query/functions/src/aggregates/aggregate_bitmap.rs:218

↓ 65 callersMethoditer

(&self)

src/query/expression/src/values.rs:1376

↓ 65 callersMethodmessage

(&self)

src/meta/app/src/app_error.rs:1072

↓ 65 callersMethodpath

(&self)

src/query/storages/common/cache/src/temp_dir.rs:327

↓ 65 callersMethodpush_back

(&mut self, index: usize, block: DataBlock)

src/query/service/src/servers/flight/v1/exchange/exchange_transform_shuffle.rs:101

↓ 64 callersMethodadd_transform

( &mut self, input: Arc<InputPort>, output: Arc<OutputPort>, proc: ProcessorPt

src/query/pipeline/src/core/pipe.rs:134

↓ 64 callersMethodand

Create an AND expression

src/query/service/tests/it/sql/planner/optimizer/test_utils.rs:451

↓ 64 callersMethodflatten

( &mut self, input: &RawJsonb, path: &str, key_builder: &mut Option<NullableCo

src/query/functions/src/srfs/variant.rs:643

↓ 64 callersMethodmetadata

(&self)

src/query/storages/parquet/src/parquet_reader/row_group.rs:402

↓ 63 callersMethodis_empty

(&self)

src/query/functions/src/scalars/obfuscator.rs:61

↓ 63 callersMethodnum_fields

(&self)

src/query/expression/src/schema.rs:219

↓ 62 callersFunctioncast

(expr: ScalarExpr, target_type: DataType)

src/query/sql/src/planner/plans/join.rs:1081

↓ 62 callersFunctionent

Create an entry with a given id and value.

src/meta/plugins/semaphore/src/queue/semaphore_queue.rs:754

↓ 62 callersMethodfinish

(self)

src/query/service/src/servers/http/v1/query/sized_spsc.rs:576

↓ 62 callersMethodinc

(&self)

src/common/base/src/runtime/metrics/gauge.rs:50

↓ 62 callersMethodis_nullable_or_null

(&self)

src/query/expression/src/types.rs:178

↓ 62 callersMethoditer

(&self)

src/query/expression/src/kernels/take_index.rs:45

↓ 62 callersFunctionnew

()

src/common/column/tests/it/buffer/immutable.rs:19

↓ 62 callersMethodreplace_children

Replace children with given new `children`. Note that this method will keep the `applied_rules` of current `SExpr` unchanged.

src/query/sql/src/planner/optimizer/ir/expr/s_expr.rs:199

← previous next →201–300 of 29,332, ranked by callers