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

↓ 164 callersMethodfilter

(mut self, expr: Expr)

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

↓ 162 callersMethodcollect

(&mut self, function: Function)

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

↓ 161 callersFunctionfrom_millis

(millis: u64)

src/meta/api/src/txn/backoff.rs:106

↓ 158 callersMethodget_mut

(&mut self, key: [u8; 2])

src/common/hashtable/src/table1.rs:60

↓ 156 callersMethodwrap_nullable

(self)

src/query/ast/src/ast/expr.rs:1230

↓ 155 callersMethodjoin

(self)

src/common/base/src/runtime/thread.rs:38

↓ 154 callersMethodas_expr

(&self)

src/query/sql/src/planner/semantic/lowering.rs:301

↓ 154 callersMethodcolumn

Create or retrieve a column reference with table context

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

↓ 153 callersMethodscale

(&self)

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

↓ 150 callersMethoddata_type

(&self)

src/query/storages/common/table_meta/src/meta/v2/segment.rs:111

↓ 150 callersMethodfor_each

(&self, mut f: F)

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

↓ 150 callersMethodget

(ctx: Arc<QueryContext>, plan: &Plan)

src/query/service/src/interpreters/interpreter_factory.rs:148

↓ 149 callersMethodget_table_info

(&self)

src/query/service/src/table_functions/udf_table.rs:191

↓ 148 callersMethodget_by_offset

(&self, offset: usize)

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

↓ 148 callersMethodlen

(&self)

src/query/storages/common/index/src/hnsw_index/common/bitpacking_ordered.rs:212

↓ 147 callersMethodclone

(&self)

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

↓ 147 callersMethodnull_count

Returns the number of unset bits on this [`MutableBitmap`].

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

↓ 145 callersMethodpop_front

(&mut self, max_batch_bytes: usize)

src/query/service/src/servers/flight/v1/network/outbound_buffer.rs:70

↓ 144 callersMethodfield

(&self)

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

↓ 142 callersMethodcontains_key

Return `true` if a file with path `key` is in the cache.

src/query/storages/common/cache/src/providers/disk_cache/disk_cache.rs:320

↓ 140 callersMethodinto_iter

(self)

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

↓ 140 callersMethodjoin

Create a join

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

↓ 137 callersMethodcode

(&self)

src/common/exception/src/exception.rs:46

↓ 136 callersMethodformatter

(&self)

src/query/service/src/physical_plans/physical_udf.rs:90

↓ 136 callersMethodget_max_threads

Get max_threads.

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

↓ 136 callersMethodindex_of

Find the index of the column with the given name.

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

↓ 135 callersFunctionnormalize_identifier

Normalize identifier with given `NameResolutionContext`

src/query/sql/src/planner/semantic/name_resolution.rs:108

↓ 135 callersMethodsize

(&self)

src/common/base/src/base/dma.rs:299

↓ 135 callersMethodtake

(&self, indices: &ChunkIndex)

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

↓ 133 callersMethodappend

(&mut self, table_id: u64)

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

↓ 133 callersMethodfilter

(&self, block: &DataBlock, num_rows: usize)

src/query/storages/fuse/src/operations/read/read_state.rs:152

↓ 133 callersMethodlen

(&self)

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

↓ 133 callersMethodused_columns

(&self)

src/query/sql/src/planner/plans/udf.rs:38

↓ 132 callersMethodlen

(&self)

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

↓ 131 callersMethodinc_by

(&self, v: i64)

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

↓ 131 callersMethodtry_into

(self)

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

↓ 129 callersMethodinto_iter

(self)

src/query/expression/src/aggregate/hash_index/bitmask.rs:57

↓ 128 callersMethodload

(span: Span, client: C, code: Vec<ScriptIR>)

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

↓ 128 callersMethodregister

(factory: &mut AggregateFunctionFactory)

src/query/functions/src/aggregates/aggregator.rs:72

↓ 127 callersMethodas_ref

(&self)

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

↓ 127 callersFunctionregister_counter

(name: &str)

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

↓ 126 callersMethodlen

(&self)

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

↓ 125 callersMethodsum

(iter: I)

src/query/pipeline/transforms/src/processors/transforms/sorts/core/list_domain.rs:491

↓ 124 callersMethodcontains

(&self, key: &K)

src/query/storages/common/index/src/filters/xor8/mod.rs:89

↓ 123 callersMethodinsert

(&self, key: K, entry_ptr: *mut RawEntry<K>)

src/query/service/src/pipelines/processors/transforms/hash_join_table/hashjoin_hashtable.rs:110

↓ 122 callersMethodcollect

(&self, py: Python)

src/bendpy/src/dataframe.rs:86

↓ 122 callersMethodpush_data

(&self, data: Result<DataBlock>)

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

↓ 119 callersMethodlen

(&self)

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

↓ 118 callersMethodset_need_data

(&self)

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

↓ 117 callersMethodget_pb

Get protobuf encoded value by kvapi::Key. The key will be converted to string and the returned value is decoded by `FromToProto`. It returns the same

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

↓ 117 callersMethodpop

(&mut self, index: usize)

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

↓ 115 callersMethodis_empty

(&self)

src/query/service/src/pipelines/executor/query_executor_tasks.rs:224

↓ 115 callersMethodis_empty

(&self)

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

↓ 113 callersMethodset_setting

(&self, k: String, v: String)

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

↓ 110 callersMethodas_ref

(&self)

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

↓ 110 callersMethodcontains

Check to see if `self` is a superset of `other` schema. Here are the comparison rules:

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

↓ 109 callersMethodspan

(&self)

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

↓ 108 callersMethodget

(&self, id: &FunctionID)

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

↓ 108 callersMethodis_null

(&self)

src/query/datavalues/src/types/data_type.rs:70

↓ 107 callersMethodpush

(&mut self, _index: usize, item: Reverse<Cursor<Self::Rows>>)

src/query/pipeline/transforms/src/processors/transforms/sorts/core/algorithm.rs:79

↓ 105 callersMethodfunction

(self)

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

↓ 105 callersMethodlen

(&self)

src/common/base/src/containers/ttlhmap.rs:126

↓ 105 callersMethodpassthrough_nullable

(mut self)

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

↓ 105 callersFunctiontransform_span

(tokens: &[Token])

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

↓ 104 callersMethodget_id

(&self)

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

↓ 104 callersFunctionreader_check_msg

(msg_ver: u64, msg_min_reader_ver: u64)

src/meta/proto-conv/src/util.rs:231

↓ 104 callersMethodscalar_builder

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

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

↓ 104 callersFunctionspawn

(future: F)

src/common/base/src/runtime/runtime.rs:380

↓ 104 callersMethodwith_column

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

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

↓ 103 callersMethodget_catalog

(&self, catalog_name: &str)

src/query/service/src/sessions/query_ctx/table.rs:36

↓ 103 callersMethodput_slice

(&mut self, item: &[u8])

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

↓ 102 callersMethodextend

(&mut self, x: f64, y: f64)

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

↓ 102 callersMethodget

(&mut self, ctx: &QueryContext)

src/query/service/src/pipelines/processors/transforms/transform_async_function.rs:211

↓ 102 callersMethodget_settings

(&self)

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

↓ 102 callersFunctioninit

()

src/query/service/src/spillers/test_memory.rs:189

↓ 101 callersMethodcontains

(&self, value: u64)

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

↓ 101 callersMethodfinish

(&self)

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

↓ 100 callersMethodis_empty

(&self)

src/query/storages/fuse/src/operations/analyze/analyze_state_sink.rs:786

↓ 100 callersMethodis_nullable

(&self)

src/query/ast/src/ast/expr.rs:1226

↓ 98 callersMethodinsert

(&mut self, k: K, v: V, max_idle_time: Option<Duration>)

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

↓ 98 callersMethodis_empty

(&self)

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

↓ 98 callersMethodis_finished

(&self)

src/query/service/src/pipelines/executor/pipeline_executor.rs:261

↓ 97 callersMethodget_tenant

(&self)

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

↓ 97 callersMethodwrite

(&mut self, buf: &[u8])

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

↓ 96 callersMethodcalc_domain

( &self, lhs: &SimpleDomain<T>, rhs: &SimpleDomain<T>, precision: u8, )

src/query/functions/src/scalars/decimal/src/arithmetic.rs:62

↓ 95 callersMethodtenant_name

(&self)

src/query/service/src/task_support_context.rs:52

↓ 94 callersMethodsort

( self, select_list: Vec<Expr>, order_by: Vec<(Expr, Option<bool>, Option<bool>)>,

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

↓ 92 callersMethodlen

(&self)

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

↓ 92 callersMethodschema

()

src/query/service/src/table_functions/others/udf.rs:63

↓ 92 callersMethodtable

(&self, index: IndexType)

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

↓ 91 callersMethodnext

(&self, offset: usize)

src/query/expression/src/aggregate/aggregate_function_state.rs:46

↓ 91 callersMethodvectorized

(self, eval: F)

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

↓ 90 callersMethodbuild

(self)

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

↓ 90 callersMethodbuild

(len: usize)

src/query/functions/src/scalars/other.rs:557

↓ 90 callersMethoddata_type

(&self)

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

↓ 88 callersMethodread

(bytes: &mut T)

src/query/service/src/servers/flight/v1/packets/packet_data_progressinfo.rs:79

↓ 87 callersMethodas_ptr

Returns a pointer to the start of this [`Bitmap`] (ignores `offsets`) This pointer is allocated iff `self.len() > 0`.

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

↓ 87 callersMethodprint_message

Print a message to stderr if reporting is enabled.

scripts/databend_test_helper/src/databend_test_helper/progress.py:22

↓ 86 callersMethodadd_source

(&mut self, output_port: Arc<OutputPort>, source: ProcessorPtr)

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

↓ 86 callersMethodcan_push

(&self)

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

← previous next →101–200 of 29,332, ranked by callers