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

↓ 62 callersMethodvalue

(&self, index: Symbol)

src/query/sql/src/planner/plans/constant_table_scan.rs:107

↓ 61 callersMethodbuild

(self)

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

↓ 61 callersMethodcapacity

(&self)

src/query/expression/src/aggregate/hash_index/index.rs:219

↓ 61 callersMethodcolumns

(&self)

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

↓ 61 callersMethodcount

(mut self)

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

↓ 61 callersMethodcreate_default_database

Create database with prefix.

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

↓ 61 callersMethodget_function_context

(&self)

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

↓ 61 callersMethodname

Get the name of this table entry.

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

↓ 60 callersMethodadd_result

(&mut self, result: SExpr)

src/query/sql/src/planner/optimizer/optimizers/rule/transform_result.rs:27

↓ 60 callersMethodget_cluster

(&self)

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

↓ 60 callersMethodlen

(&self)

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

↓ 60 callersMethodsend

(&self, message: TaskMessage)

src/query/management/src/task/task_mgr.rs:263

↓ 59 callersMethodadd_message_back

(self, msg: impl AsRef<str>)

src/common/exception/src/exception.rs:88

↓ 59 callersMethodcolumn_by_name

Create a column by name using function call

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

↓ 59 callersMethodfind

( &self, ctx: &Arc<dyn TableContext>, location: String, pred: P, )

src/query/storages/fuse/src/operations/navigate.rs:172

↓ 59 callersMethodget_license_key

(&self, tenant: &str)

src/query/service/src/clusters/cluster.rs:731

↓ 59 callersMethodis_empty

(&self)

src/query/storages/fuse/src/operations/mutation/mutator/block_compact_mutator.rs:479

↓ 59 callersMethodobserve

Observe the given value.

src/common/base/src/runtime/metrics/histogram.rs:90

↓ 58 callersMethodcolumn

(&self, index: Symbol)

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

↓ 58 callersMethodcontains

(&self, func_name: impl AsRef<str>)

src/query/functions/src/aggregates/aggregate_function_factory.rs:308

↓ 58 callersMethodeq

Create an equality comparison

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

↓ 58 callersMethodgroup

(&self, index: IndexType)

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

↓ 58 callersMethodint

Create an integer constant

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

↓ 58 callersMethodpush_default

(&mut self)

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

↓ 57 callersFunctioncheck_function

( span: Span, name: &str, params: &[Scalar], args: &[Expr<Index>], fn_registry: &FunctionR

src/query/expression/src/type_check.rs:302

↓ 57 callersMethodchunks

Returns an iterator over bits in bit chunks [`BitChunk`]. This iterator is useful to operate over multiple bits via e.g. bitwise.

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

↓ 57 callersMethodcolumns

(&self)

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

↓ 57 callersMethodengine

(&self)

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

↓ 57 callersMethodexists

Create an `exist` meta-service key error.

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

↓ 57 callersMethodis_empty

(&self)

src/query/storages/fuse/src/statistics/accumulator.rs:216

↓ 57 callersMethodpush_back

(&mut self, location: &'static Location<'static>, f: Box<dyn Callback>)

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

↓ 57 callersMethodset_status_info

(&self, _info: &str)

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

↓ 56 callersMethodclone

(&self)

src/meta/app/src/tenant_key/raw.rs:72

↓ 56 callersMethodlen

(&self)

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

↓ 56 callersFunctionnew_constant

()

src/common/column/tests/it/bitmap/immutable.rs:51

↓ 56 callersMethodnum_rows

(&self)

src/query/pipeline/transforms/src/processors/transforms/sorts/core/cursor.rs:68

↓ 56 callersMethodtry_resize

Add a ResizePipe to pipes

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

↓ 56 callersMethodwrite

(&mut self, value: T, bits: u8)

src/query/storages/common/index/src/hnsw_index/common/bitpacking.rs:79

↓ 55 callersMethodconfig

(&self)

src/query/service/src/test_kits/config.rs:184

↓ 55 callersMethodoutput_len

(&self)

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

↓ 55 callersMethodschema

(&self)

src/query/sql/src/planner/plans/plan.rs:561

↓ 54 callersMethodcolumn_id

(&self)

src/query/storages/common/index/src/bloom_index.rs:670

↓ 54 callersMethodindex_unchecked

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

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

↓ 54 callersMethodvalidate_access

( &self, grant_object: &GrantObject, privilege: UserPrivilegeType, check_curre

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

↓ 53 callersMethodbuild_pipeline

(&self, builder: &mut PipelineBuilder)

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

↓ 53 callersMethodgen_expr

(&mut self, ty: &DataType)

src/tests/sqlsmith/src/sql_gen/expr.rs:38

↓ 53 callersMethodget_catalog

(&self, catalog_name: &str)

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

↓ 53 callersMethodjoin_condition

Create a join condition between two columns

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

↓ 53 callersFunctionmerge_span

(lhs: Span, rhs: Span)

src/query/ast/src/span.rs:76

↓ 53 callersMethodset_not_need_data

(&self)

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

↓ 53 callersMethodsql_display

(&self)

src/query/expression/src/utils/display.rs:960

↓ 53 callersMethodto_column

(&self)

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

↓ 53 callersFunctionwrite_dot_separated_list

( f: &mut Formatter, items: impl IntoIterator<Item = impl Display>, )

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

↓ 52 callersMethodcolumns

(&self)

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

↓ 52 callersFunctionconnect

Connect input and output ports. # Safety

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

↓ 52 callersMethodis_empty

(&self)

src/query/storages/fuse/src/io/write/stream/block_builder.rs:251

↓ 52 callersMethodtable_scan

Create a table scan

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

↓ 51 callersMethodas_string

(&self)

src/query/storages/system/src/query_log_table.rs:40

↓ 51 callersFunctionassert_class

(src: DataType, dest: DataType, expected: ConversionClass)

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

↓ 51 callersMethodfield_with_name

Returns an immutable reference of a specific `Field` instance selected by name.

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

↓ 51 callersFunctionfold

(expr: &Expr<usize>)

src/query/expression/tests/it/constant_folder.rs:195

↓ 51 callersMethodget_settings

(&self)

src/query/service/tests/it/sql/exec/get_table_bind_test.rs:700

↓ 51 callersMethodis_finished

(&self)

src/query/pipeline/transforms/src/processors/transforms/sorts/core/merger.rs:154

↓ 51 callersMethodname

(&self)

src/query/storages/stage/src/transform_generating.rs:66

↓ 51 callersMethodput_item

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

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

↓ 51 callersMethodset_max_threads

(&mut self, max_threads: usize)

src/query/service/src/pipelines/pipeline_build_res.rs:84

↓ 51 callersMethodto_pb

(&self)

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

↓ 50 callersMethodadd

(&mut self, other: &Self)

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

↓ 50 callersMethodbuild

(&self)

src/meta/schema-api-tests/tests/it/metasrv_builder.rs:59

↓ 50 callersFunctiongeo_to_ewkb

Convert Geometry object to EWKB format.

src/common/io/src/geometry.rs:219

↓ 50 callersMethodload

()

src/common/exception/src/elf/library_loader.rs:45

↓ 50 callersMethodschema

(&self)

src/query/storages/fuse/src/io/read/block/block_reader.rs:215

↓ 50 callersMethodtake

(&mut self)

src/query/service/src/pipelines/processors/transforms/aggregator/aggregate_spiller.rs:108

↓ 50 callersMethodtake

(self)

src/common/base/tests/it/fixed_heap.rs:193

↓ 49 callersMethodbuild

(self)

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

↓ 49 callersMethodchildren

(&self)

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

↓ 49 callersMethodcollect

In the current implementation, if an aggregation function can be eager, then it needs to satisfy the following constraints: (1) The args.len() must eq

src/query/sql/src/planner/optimizer/optimizers/rule/agg_rules/rule_eager_aggregation.rs:564

↓ 48 callersMethoddispatch

(&self, ctx: &mut FormatContext<'_>)

src/query/service/src/physical_plans/format/physical_format.rs:24

↓ 48 callersMethodget

(&self, num_points: usize)

src/query/storages/common/index/src/hnsw_index/visited_pool.rs:129

↓ 48 callersMethoditer

(&'a self)

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

↓ 48 callersMethodsliced

(self, offset: usize, length: usize)

src/common/column/src/buffer/immutable.rs:148

↓ 48 callersMethodtext

(&self)

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

↓ 48 callersMethodunary_child

(&self)

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

↓ 48 callersMethodvisit

(&mut self, expr: &mut ScalarExpr)

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

↓ 47 callersMethodfinish

(self)

src/query/expression/src/function/function_builder.rs:283

↓ 47 callersMethodsnapshot_loc

(&self)

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

↓ 47 callersFunctionunsupported

(name: &str)

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

↓ 46 callersMethodadd_derived_column

(&mut self, alias: String, data_type: DataType)

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

↓ 46 callersMethodchecked_sub

(self, rhs: Self)

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

↓ 46 callersMethodget_current_session

Get the current session.

src/query/service/src/sessions/query_ctx.rs:461

↓ 46 callersMethodget_db_info

(&self)

src/query/storages/iceberg/src/database.rs:95

↓ 46 callersFunctionmap_condition

(k: &str, seq: MatchSeq)

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

↓ 46 callersMethodtimestamp

(&self)

src/query/storages/common/table_meta/src/readers/snapshot_reader.rs:80

↓ 46 callersMethodto_le_bytes

(&self)

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

↓ 46 callersMethodwith_filter

(&mut self, col_name: impl Into<String>)

src/query/sql/src/planner/binder/builders/select_builder.rs:40

↓ 45 callersMethodfind

(parent: &mut [usize], x: usize)

src/query/sql/src/planner/optimizer/optimizers/operator/filter/infer_filter.rs:635

↓ 45 callersMethodindex

(&self)

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

↓ 45 callersMethodinsert

Inserts a key-value pair into the cache. If the key already existed, the old value is returned. # Examples ```rust,ignore use databend_common_cache:

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

↓ 45 callersMethodinto_inner

(self)

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

↓ 44 callersMethodas_mut

(&mut self)

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

← previous next →301–400 of 29,332, ranked by callers