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

↓ 44 callersMethodas_mut_ptr

(&mut self)

src/query/expression/src/aggregate/row_ptr.rs:107

↓ 44 callersMethodas_ptr

(&self)

src/query/expression/src/aggregate/row_ptr.rs:34

↓ 44 callersMethodderive_relational_prop

(&self)

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

↓ 44 callersMethodget_db_info

(&self)

src/query/service/src/databases/system/system_database.rs:239

↓ 44 callersMethodor

Create an OR expression

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

↓ 44 callersMethodpull_data

(&mut self)

src/query/service/src/pipelines/executor/pipeline_pulling_executor.rs:205

↓ 44 callersMethodremove

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

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

↓ 44 callersMethodschema_with_stream

(&self)

src/query/catalog/src/table.rs:184

↓ 43 callersMethodas_str

(self)

src/meta/process/src/filter_tenant.rs:60

↓ 43 callersMethodclone

(&self)

src/common/exception/src/exception.rs:318

↓ 43 callersMethodcmp

(&self, other: &Self)

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

↓ 43 callersMethodfold

(mut self, mut acc: Acc, mut f: F)

src/query/storages/common/index/src/hnsw_index/common/bitpacking_links.rs:165

↓ 43 callersMethodlen

(&self)

src/query/expression/src/aggregate/payload.rs:250

↓ 43 callersMethodmessage

(&self)

src/common/exception/src/exception.rs:62

↓ 43 callersMethodmeta_location_generator

(&self)

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

↓ 43 callersMethodnum_rows

(&self)

src/query/storages/basic/src/result_cache/write/writer.rs:96

↓ 43 callersFunctiontxn_del

Build a txn operation that deletes a record.

src/meta/api/src/txn/op_builder.rs:47

↓ 43 callersMethodvalidate_table_access

( &self, catalog_name: &str, db_name: &str, table_name: &str, privileg

src/query/service/src/interpreters/access/privilege_access.rs:378

↓ 42 callersMethodconnect

( func_name: &str, endpoint: Arc<Endpoint>, conn_timeout: u64, batch_rows: usi

src/query/expression/src/utils/udf_client.rs:132

↓ 42 callersFunctiondeserialize

( deserializer: D, )

src/query/storages/common/table_meta/src/meta/histogram_serde.rs:40

↓ 42 callersMethodfinish

(self, stats: &Arc<FusePruningStatistics>)

src/query/storages/fuse/src/pruning/pruning_statistics.rs:416

↓ 42 callersMethodgt

Create a greater than comparison

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

↓ 42 callersMethodinto_inner

Get the inner distribution

src/query/sql/src/planner/optimizer/ir/property/enforcer.rs:53

↓ 42 callersMethodis_empty

(&self)

src/query/catalog/src/table_args.rs:30

↓ 42 callersMethodmemory_size

(&self)

src/query/storages/stage/src/read/block_builder_state.rs:164

↓ 42 callersMethodparse

(req: &Request)

src/query/service/src/servers/http/v1/stage.rs:52

↓ 42 callersFunctionsend_txn

Send a transaction to the KV API and return success status and responses. This is the core transaction sending function used throughout the meta API.

src/meta/api/src/txn/core.rs:31

↓ 42 callersMethodtenant

(&self)

src/meta/api/src/api_impl/auto_increment_api_test_suite.rs:229

↓ 41 callersMethodadd

(&self, other: &ProgressValues)

src/common/base/src/base/progress.rs:28

↓ 41 callersMethodas_bytes

(&self)

src/common/hashtable/src/traits.rs:150

↓ 41 callersFunctiondecimal

(precision: u8, scale: u8)

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

↓ 41 callersMethoddefault_table_name

(&self)

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

↓ 41 callersMethoddefault_tenant

(&self)

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

↓ 41 callersMethodget

(&self, scalar: &Scalar)

src/query/storages/common/table_meta/src/meta/statistics.rs:108

↓ 41 callersMethodget_current_tenant

(&self)

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

↓ 41 callersMethodget_meta_store_client

(&self)

src/query/users/src/user_api.rs:220

↓ 41 callersMethodinsert

(&mut self, lower_bound: BoundValue, upper_bound: BoundValue)

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

↓ 41 callersMethodis_empty

(&self, index: usize)

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

↓ 41 callersMethodnormalize_object_identifier_triple

Normalize [[<catalog>].<database>].<object> object like table, view ...

src/query/sql/src/planner/binder/binder.rs:1051

↓ 41 callersMethodreduce

(&self, n: usize)

src/query/pipeline/transforms/src/processors/transforms/sorts/core/bounds.rs:103

↓ 41 callersFunctionregister_histogram_in_milliseconds

(name: &str)

src/common/base/src/runtime/metrics/registry.rs:277

↓ 41 callersFunctionrun_script

(file: &mut dyn Write, src: &str)

src/query/script/tests/it/main.rs:42

↓ 41 callersMethodschema

()

src/query/storages/system/src/locks_table.rs:163

↓ 41 callersMethodto_timestamp

(&self, tz: &TimeZone)

src/query/expression/src/utils/date_helper.rs:61

↓ 41 callersMethodwrite

(&mut self, offset: usize, value: &T)

src/query/expression/src/aggregate/row_ptr.rs:119

↓ 40 callersMethodget_database

(&self, tenant: &Tenant, db_name: &str)

src/query/service/src/catalogs/default/mutable_catalog.rs:295

↓ 40 callersMethodinsert

(&mut self, id: RuleID)

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

↓ 40 callersMethodis_finite

(self)

src/common/base/src/base/ordered_float.rs:843

↓ 40 callersMethodmemory_size

(&self)

src/query/service/src/spillers/partition_buffer.rs:76

↓ 40 callersMethodresolve_scalar_function_call

( &self, span: Span, func_name: &str, mut params: Vec<Scalar>, mut arg

src/query/sql/src/planner/semantic/type_check/scalar_function.rs:411

↓ 40 callersMethodrole_api

(&self, tenant: &Tenant)

src/query/users/src/user_api.rs:173

↓ 39 callersMethodbuild_unary

(self, plan: impl Into<Arc<RelOperator>>)

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

↓ 39 callersMethodclear

(&self)

src/query/ast/src/parser/error.rs:78

↓ 39 callersFunctionget_kv_data

Get existing value by key. Panic if key is absent.

src/meta/schema-api-test-suite/src/testing.rs:31

↓ 39 callersFunctioninit_stage_operator

(stage_info: &StageInfo)

src/common/storage/src/stage.rs:90

↓ 39 callersFunctionregister_counter_family

(name: &str)

src/common/base/src/runtime/metrics/registry.rs:285

↓ 39 callersMethodrun

( self, sql: str, label: str, output: str = "csv", echo_stdout: bool = True )

scripts/bench_common/bendsql.py:30

↓ 38 callersMethodarity

(&self)

src/query/sql/src/planner/optimizer/ir/expr/m_expr.rs:62

↓ 38 callersMethodas_scalar

(&self)

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

↓ 38 callersMethodcreate_table_with

Create table but let user customize the table meta

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

↓ 38 callersMethodextend_constant

(&mut self, additional: usize)

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

↓ 38 callersMethodfinish

(self)

src/query/storages/stage/src/append/arrow_file/writer_processor.rs:71

↓ 38 callersMethodfinish

(self)

src/query/catalog/src/sbbf.rs:389

↓ 38 callersFunctionscalar_evaluator

(f: F)

src/query/expression/src/function/function_factory.rs:86

↓ 38 callersMethodupsert_pb

Update or insert a protobuf encoded value by kvapi::Key. The key will be converted to string and the value is encoded by `FromToProto`. It returns th

src/meta/api/src/kv/pb_api/mod.rs:69

↓ 38 callersMethodwith

(f: F)

src/common/base/src/runtime/runtime_tracker.rs:427

↓ 38 callersFunctionwrite_case_title

(file: &mut impl Write, name: &str, description: &str)

src/query/sql/tests/it/framework/golden.rs:83

↓ 37 callersMethodborrow

(&self)

src/common/base/src/base/ordered_float.rs:1174

↓ 37 callersMethodcreate_warehouse

( &self, warehouse: String, nodes: Vec<SelectedNode>, )

src/query/management/src/warehouse/warehouse_mgr.rs:1173

↓ 37 callersFunctiondecode

(encoding: &MetaEncoding, data: &'a [u8])

src/query/storages/common/table_meta/src/meta/format.rs:148

↓ 37 callersMethodget_operator

(&self)

src/query/storages/fuse/src/io/snapshots.rs:73

↓ 37 callersMethodincr

(&self, progress_values: &ProgressValues)

src/common/base/src/base/progress.rs:50

↓ 37 callersMethodis_empty

(&self)

src/query/pipeline/transforms/src/processors/transforms/sorts/core/bounds.rs:98

↓ 37 callersMethodnotified

(&self)

src/common/base/src/base/watch_notify.rs:37

↓ 37 callersMethodnum_rows

(&self)

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

↓ 37 callersFunctiontable_meta

()

src/meta/api/src/testing.rs:48

↓ 37 callersMethodtxn_mgr

(&self)

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

↓ 36 callersMethodas_ref

(&self)

src/query/storages/common/cache/src/providers/disk_cache_builder.rs:59

↓ 36 callersFunctioncheck_function_arity

( span: Span, func_name: &str, len: usize, min: usize, max: Option<usize>, )

src/query/sql/src/planner/semantic/type_check/rewrite_function.rs:165

↓ 36 callersMethodclear

(&mut self, max_rows: usize)

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

↓ 36 callersMethoddatabase_name

(&self)

src/query/sql/src/planner/binder/util.rs:193

↓ 36 callersMethoddb_id

(&self)

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

↓ 36 callersMethodfetchall

(self)

src/bendpy/python/databend/__init__.py:58

↓ 36 callersMethodget_bit_unchecked

(&self, i: usize)

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

↓ 36 callersMethodget_scan_progress

(&self)

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

↓ 36 callersMethodget_visibility_checker

( &self, ignore_ownership: bool, object: Object, )

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

↓ 36 callersFunctionkill_databend_meta

Kill all running databend-meta processes

tests/metactl/utils.py:57

↓ 36 callersMethodlen

(&self)

src/common/hashtable/src/short_string_hashtable.rs:130

↓ 36 callersMethodneq

Create a not equal comparison

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

↓ 36 callersMethodplan_sql

( &self, session: &Arc<Session>, query: &str, )

src/query/service/src/servers/flight_sql/flight_sql_service/query.rs:143

↓ 36 callersMethodrequired

(key: impl Into<String>)

src/meta/process/src/filter_tenant.rs:81

↓ 36 callersMethodresponse_when

(mut self, query: &str, block: MockSet)

src/query/script/tests/it/main.rs:645

↓ 36 callersMethodrun

(&mut self, max_steps: usize)

src/query/script/src/executor.rs:93

↓ 36 callersMethodset_applied_rule

Record the applied rule id in current SExpr

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

↓ 36 callersMethodto_bytes

Serializes the Segment struct to a byte vector. The byte vector contains the format version, encoding, compression, and compressed block data and sum

src/query/storages/common/table_meta/src/meta/v4/segment.rs:149

↓ 36 callersMethodto_pb_opt

(&self)

src/meta/proto-conv/src/traits.rs:92

↓ 36 callersMethodtransaction

(&self, txn: TxnRequest)

src/meta/store/src/lib.rs:296

↓ 36 callersMethodupgrade

(&self)

src/query/script_udf_support/src/transform_udf_script.rs:957

↓ 36 callersMethodupsert_kv

(&self, req: UpsertKV)

src/meta/store/src/lib.rs:247

↓ 35 callersMethodadd_block

When adding a [`DataBlock`], we compute the aggregations to the end. For each row in the input block, compute the aggregation result of its window fr

src/query/pipeline/transforms/src/processors/transforms/window/transform_window.rs:1003

← previous next →401–500 of 29,332, ranked by callers