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

↓ 14,555 callersFunctionnew

()

src/common/column/src/binview/builder.rs:424

↓ 6,113 callersMethodto_string

(&self)

src/common/statistics/src/datum.rs:60

↓ 5,612 callersMethodclone

(&self)

src/query/service/src/physical_plans/physical_plan.rs:280

↓ 3,072 callersFunctionrun_ast

(file: &mut impl Write, text: impl AsRef<str>, columns: &[(&str, Column)])

src/query/functions/tests/it/scalars/mod.rs:109

↓ 2,442 callersMethodmap

(&mut self, span: Span, kvs: &'a [(Literal, Expr)])

src/query/sql/src/planner/semantic/type_check/literal.rs:50

↓ 2,347 callersMethodclone

(&self)

src/query/storages/common/cache/src/providers/memory_cache.rs:43

↓ 2,013 callersMethodmap

(self, f: impl Fn(T::Domain) -> U::Domain)

src/query/expression/src/property.rs:140

↓ 1,994 callersMethodpush

Pushes a value into the priority queue. If the queue if full, replaces the smallest value and returns it.

src/query/storages/common/index/src/hnsw_index/common/fixed_length_priority_queue.rs:64

↓ 1,979 callersMethodclone

(&self)

src/query/sql/src/planner/plans/scalar_expr.rs:83

↓ 1,892 callersMethodinto

(self)

src/query/expression/src/filter/select_expr.rs:329

↓ 1,775 callersMethodto_string

(self, hash_value: &[u8])

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

↓ 1,763 callersMethodpush

(&mut self, item: ScalarRef)

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

↓ 1,752 callersMethodclone

(&self)

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

↓ 1,634 callersMethodas_ref

(&self)

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

↓ 1,519 callersFunctionfrom

()

src/common/column/tests/it/binview/mod.rs:127

↓ 1,510 callersMethodlen

Total byte length of the serialized parquet across all chunks.

src/query/storages/common/blocks/src/parquet_writer.rs:62

↓ 1,382 callersMethodmap_err

(err: ErrorCode, expr: &Expr)

src/query/expression/src/evaluator.rs:155

↓ 1,195 callersMethodpush

( &mut self, table: Arc<dyn Table>, condition: Option<ScalarExpr>, source_expr

src/query/service/src/interpreters/interpreter_insert_multi_table.rs:523

↓ 1,161 callersMethoditer

(&self)

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

↓ 1,028 callersMethoditer

(&self)

src/query/service/src/servers/flight/v1/exchange/outbound_send_channels.rs:45

↓ 1,008 callersMethodclone

(&self)

src/meta/app/src/data_id.rs:79

↓ 992 callersMethoditer

(&'a self)

src/query/storages/stage/src/read/row_based/batch.rs:149

↓ 981 callersMethodinto_iter

(self)

src/query/settings/src/settings.rs:323

↓ 965 callersMethoditer

(&self)

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

↓ 964 callersMethodclone

(&self)

src/query/sql/src/planner/optimizer/optimizers/cascades/tasks/task.rs:47

↓ 918 callersMethodlen

(&self)

src/query/functions/src/aggregates/aggregate_distinct_state.rs:152

↓ 792 callersMethodcollect

(&mut self, s_expr: &SExpr)

src/query/sql/src/planner/optimizer/statistics/collect_statistics.rs:57

↓ 752 callersMethodlen

(&self)

src/query/service/src/servers/flight/v1/exchange/outbound_send_channels.rs:37

↓ 729 callersFunctionmap

(key: DataType, value: DataType)

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

↓ 610 callersMethodas_str

(self)

src/query/sql/tests/it/optimizer/normalize_scalar.rs:51

↓ 549 callersMethodextend

(&mut self, other: FinishedCallbackChain)

src/query/pipeline/src/core/finished_chain.rs:194

↓ 549 callersMethodis_empty

(&self)

src/query/storages/stage/src/append/output.rs:45

↓ 533 callersFunctiontry_create

( nested_name: &str, params: Vec<Scalar>, arguments: Vec<DataType>, sort_descs: Vec<AggregateF

src/query/functions/src/aggregates/adaptors/aggregate_combinator_distinct.rs:222

↓ 527 callersMethodto_owned

(&self)

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

↓ 514 callersMethodas_ref

(&self)

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

↓ 496 callersMethodas_slice

(&self)

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

↓ 485 callersMethodinsert

(&mut self, target_group: Option<IndexType>, s_expr: SExpr)

src/query/sql/src/planner/optimizer/ir/memo.rs:79

↓ 478 callersMethodexpect

(self, pattern, timeout=None, escape=False)

tests/helpers/uexpect.py:125

↓ 455 callersMethodto_vec

(&self)

src/query/storages/common/index/src/hnsw_index/quantization/encoded_storage.rs:55

↓ 452 callersMethodclone

(&self)

src/query/storages/stage/src/append/row_based_file/buffers.rs:46

↓ 444 callersMethodinsert

(&mut self, id: CompactVirtualColumnSharedId)

src/query/storages/common/index/src/virtual_column.rs:310

↓ 439 callersMethodget

( &self, name: &str, seq: MatchSeq, )

src/meta/api/src/kv/crud/mod.rs:237

↓ 411 callersMethodget_settings

(&self)

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

↓ 393 callersMethodset_error

(&mut self, err: ErrorCode)

src/query/functions/src/aggregates/aggregate_geographic_agg.rs:137

↓ 375 callersMethodcommit_row

(&mut self)

src/query/expression/src/types/array.rs:446

↓ 371 callersMethodclone

(&self)

src/query/functions/src/scalars/comparison.rs:365

↓ 369 callersMethodas_bytes

(&self)

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

↓ 344 callersMethodfields

(&self)

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

↓ 334 callersMethoddata_type

(&self)

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

↓ 331 callersMethodlen

(&self)

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

↓ 312 callersMethoditer_mut

Returns an iterator over the cache's key-value pairs in least- to most-recently-used order, with mutable references to the values. Accessing the cach

src/common/cache/src/cache/lru.rs:384

↓ 302 callersMethodcollect

(&mut self)

src/query/service/src/pipelines/processors/transforms/hash_join/transform_hash_join_build.rs:174

↓ 296 callersMethodinsert

(&self, db: &str, tbl_ref: Arc<dyn Table>)

src/query/service/src/catalogs/default/table_memory_meta.rs:65

↓ 282 callersMethodgen_range

(&mut self, upper: usize)

src/query/storages/common/index/src/kmeans.rs:75

↓ 277 callersMethodas_slice

(&self)

src/common/column/src/offset.rs:215

↓ 269 callersMethodremove_nullable

(&self)

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

↓ 262 callersMethodclone

(&self)

src/meta/api/src/txn/meta_txn/mod.rs:84

↓ 261 callersMethodget

(&self, schema: &HashableSchema, location: &str)

src/query/storages/orc/src/copy_into_table/projection.rs:48

↓ 260 callersMethodcontains

(&self, id: &RuleID)

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

↓ 259 callersMethodvalues

Note: if the array column has been sliced, the number of values may not match the offsets. Use the `underlying_column` function to get the actual valu

src/query/expression/src/types/array.rs:278

↓ 257 callersMethodmax

(&self)

src/query/storages/common/table_meta/src/meta/v2/statistics.rs:302

↓ 252 callersMethodparse

Get statistics of an iceberg table.

src/query/storages/iceberg/src/statistics.rs:59

↓ 245 callersMethodmin

(&self)

src/query/storages/common/table_meta/src/meta/v2/statistics.rs:298

↓ 241 callersMethodextend_from_slice

(&mut self, slice: &[u8], offset: usize, length: usize)

src/common/column/src/bitmap/mutable.rs:709

↓ 241 callersMethoditer

(&self)

src/query/expression/src/types/map.rs:287

↓ 239 callersMethodnew_query_ctx

returns new QueryContext of default session

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

↓ 233 callersMethodread

(&mut self)

src/query/service/src/spillers/async_buffer.rs:539

↓ 232 callersMethodclone

(&self)

src/common/cache/src/cache/lru.rs:483

↓ 230 callersMethodfield

(&self, i: FieldIndex)

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

↓ 229 callersMethodentry

(&self, key: &K)

src/common/hashtable/src/hashtable.rs:95

↓ 229 callersFunctiontest_load_old

Tests loading old version data. Returns the message version.

src/meta/proto-conv/tests/it/common.rs:52

↓ 227 callersFunctionrun_agg_ast

run ast which is agg expr

src/query/functions/tests/it/aggregates/mod.rs:61

↓ 225 callersMethodindex_unchecked

# Safety Calling this method with an out-of-bounds index is *[undefined behavior]

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

↓ 223 callersMethodok

(writer: InitWriter<'a, W>)

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

↓ 223 callersMethodset_span

Set sql span for this error. Used to pretty print the error when the error is related to a sql statement.

src/common/exception/src/exception.rs:128

↓ 222 callersMethoditer

(&self)

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

↓ 220 callersMethodget_tenant

(&self)

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

↓ 219 callersFunctiontest_pb_from_to

Tests converting rust types from/to protobuf defined types. It also print out encoded protobuf message as data for backward compatibility test.

src/meta/proto-conv/tests/it/common.rs:25

↓ 217 callersFunctionsetup

()

src/query/service/tests/it/storages/fuse/bloom_index_meta_size.rs:388

↓ 215 callersMethodchild

(&self, n: usize)

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

↓ 213 callersFunctionfrom_iter

()

src/common/column/src/binview/builder.rs:433

↓ 212 callersMethodplan

(&self)

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

↓ 211 callersMethodpush

(&mut self, value: bool)

src/common/column/src/bitmap/mutable.rs:137

↓ 202 callersMethodlen

(&self)

src/query/expression/src/types/map.rs:257

↓ 197 callersMethodnum_rows

(&self)

src/query/service/src/pipelines/processors/transforms/new_hash_join/hashtable/mod.rs:70

↓ 196 callersMethodinto

(self)

src/meta/cli-config/src/lib.rs:781

↓ 194 callersMethodget

(&self, id: CoreExprId)

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

↓ 191 callersMethodtry_get_u64

Get u64 value, we don't get from the metasrv.

src/query/settings/src/settings_getter_setter.rs:99

↓ 189 callersMethodas_mut

(&self)

src/query/service/src/pipelines/processors/transforms/new_hash_join/common/cstyle_cell.rs:60

↓ 188 callersMethodexecute_command

(&self, query: &str)

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

↓ 188 callersMethodpush_null

(&mut self)

src/query/expression/src/types/nullable.rs:503

↓ 187 callersMethodget_bit

(&self, i: usize)

src/common/column/src/bitmap/immutable.rs:262

↓ 178 callersMethodpush

(&mut self, item: (K::ScalarRef<'_>, V::ScalarRef<'_>))

src/query/expression/src/types/map.rs:360

↓ 177 callersFunctionget_example

()

src/query/functions/tests/it/aggregates/agg.rs:202

↓ 176 callersMethodis_empty

(&self)

src/query/service/src/pipelines/processors/transforms/new_hash_join/hashtable/basic.rs:45

↓ 172 callersMethoditer

(self)

src/meta/app/src/principal/user_privilege.rs:229

↓ 171 callersMethodjoin

( mut self, from: Vec<(Option<&str>, &str)>, op: JoinOperator, condition: Join

src/query/sql/src/planner/dataframe.rs:401

↓ 170 callersMethodis_empty

(&self)

src/query/service/src/interpreters/access_log/log_entry.rs:36

↓ 170 callersMethodtake

(&mut self)

src/query/service/src/schedulers/fragments/fragmenter.rs:148

↓ 165 callersMethodas_str

(&self)

src/query/users/src/jwt/jwk.rs:51

next →1–100 of 29,332, ranked by callers