Functions — github.com/GreptimeTeam/greptimedb

hub / github.com/GreptimeTeam/greptimedb / functions

Functions24,685 in github.com/GreptimeTeam/greptimedb

⨍ Functions 24,685◇ Types & classes 4,103

clone a collection, require a mutable reference to the hydroflow instance Note: need to be the same hydroflow instance that this collection is create

src/flow/src/compute/types.rs:49

↓ 3,423 callersMethodmap

Append the result of evaluating expressions to each row. simply append `expressions` to `self.expressions` while paying attention to column referenc

src/flow/src/expr/linear.rs:291

↓ 3,303 callersMethodclone

(&self)

src/mito2/src/wal.rs:69

↓ 2,429 callersMethodclone

(&self)

src/common/meta/src/key.rs:518

↓ 1,544 callersMethodinto

(self)

src/standalone/src/options.rs:128

↓ 1,319 callersMethodcollect

(repository: Option<&Repository>)

src/common/version/build.rs:78

↓ 1,190 callersMethodas_ref

(&self)

src/session/src/context.rs:653

↓ 1,062 callersMethoditer

Returns an iterator over the slice.

src/flow/src/repr.rs:176

↓ 996 callersMethodmap

(&self, mapper: F)

src/common/base/src/plugins.rs:68

↓ 886 callersMethodinto_iter

Creates a consuming iterator, that is, one that moves each value out of the `Row` (from start to end). The `Row` cannot be used after calling this

src/flow/src/repr.rs:171

↓ 676 callersMethodpush

Pushes a stalled request to the buffer.

src/mito2/src/worker.rs:789

↓ 594 callersMethodto_vec

(&self)

src/servers/src/repeated_field.rs:367

↓ 572 callersMethoditer

(&self)

src/common/recordbatch/src/lib.rs:283

↓ 552 callersMethoditer

(&self)

src/mito2/src/test_util/bench_util.rs:138

↓ 528 callersFunctioninit_default_ut_logging

Init tracing for unittest. Write logs to file `unittest`.

src/common/telemetry/src/logging.rs:393

↓ 489 callersMethodlen

Returns the number of elements in the row, also known as its 'length'.

src/flow/src/repr.rs:181

↓ 482 callersMethodclone

(&self)

src/servers/src/repeated_field.rs:374

↓ 471 callersMethodclone

(&self)

src/datatypes/src/json/value.rs:566

↓ 470 callersMethodsend

Sends the `result`.

src/mito2/src/request.rs:484

↓ 467 callersMethodand_then

(mut self, operations: impl Into<Vec<TxnOp>>)

src/common/meta/src/kv_backend/txn.rs:209

↓ 433 callersMethodlen

Returns the number of in-progress rows in this [`BatchBuilder`]

src/mito2/src/read/flat_merge.rs:235

↓ 415 callersMethodvalue

(&self)

src/common/meta/src/rpc.rs:122

↓ 413 callersMethodlen

(&self)

src/common/base/src/bytes.rs:103

↓ 409 callersMethodhandle_request

Handles [RegionRequest] and return its executed result.

src/mito2/src/engine.rs:1005

↓ 399 callersMethodbuild

(&self, opts: LoggingOptions)

src/cmd/src/cli.rs:73

↓ 380 callersMethodpush

(&self, event: ProgressEvent)

src/cli/src/data/progress.rs:435

↓ 365 callersMethodpush

(&mut self, key: String, value: Vec<u8>)

src/common/procedure/src/store/util.rs:94

↓ 340 callersFunctioncol

(column_name: impl Into<String>)

src/partition/src/expr.rs:54

↓ 333 callersMethoditer

(&self)

src/servers/src/repeated_field.rs:284

↓ 322 callersMethodinsert

Inserts a [ServerHandler] **before** the [ServerHandlers] is started.

src/servers/src/server.rs:58

↓ 313 callersMethodcloned

(&self)

src/query/src/options.rs:360

↓ 308 callersMethodget

(&self, pid: Pid)

tests-fuzz/src/utils/process.rs:63

↓ 307 callersFunctionlit

(v: impl Into<Value>)

src/flow/src/utils.rs:723

↓ 294 callersMethodinto_iter

Returns an iterator over the key-value pairs.

src/common/meta/src/snapshot/file.rs:112

↓ 284 callersMethodpath

Returns the path of the directory.

src/puffin/src/puffin_manager.rs:167

↓ 270 callersMethoditer

Returns a [FailureDetectorEntry] iterator.

src/meta-srv/src/region/failure_detector.rs:90

↓ 261 callersMethodclone

(&self)

src/object-store/src/layers/mock.rs:48

↓ 252 callersMethodpush_column_metadata

Pushes a new column metadata to this region's metadata.

src/store-api/src/metadata.rs:641

↓ 250 callersFunctionexecute_sql

(instance: &Arc<Instance>, sql: &str)

tests-integration/src/tests/instance_test.rs:2743

↓ 244 callersMethodbuild

Builds a new [Version] from the builder. It overwrites the window size by compaction option.

src/mito2/src/region/version.rs:507

↓ 237 callersMethodlen

(&self)

src/promql/src/range_array.rs:142

↓ 236 callersFunctionto_string

(result: either::Either<MySqlQueryResult, MySqlRow>)

tests-integration/tests/mysql.rs:35

↓ 232 callersMethodas_bytes

Converts [FileId] as byte slice.

src/store-api/src/storage/file.rs:51

↓ 232 callersMethodcolumn

Get the column name

src/partition/src/collider.rs:98

↓ 221 callersMethodis_none

(&self)

src/servers/src/http/prometheus.rs:176

↓ 210 callersMethodtable_id

(&self)

src/table/src/metadata.rs:1234

↓ 209 callersMethodfield

(&self, field_args: WindowUDFFieldArgs)

src/common/function/src/scalars/anomaly/mad.rs:72

↓ 206 callersMethodvalues

(&self)

src/promql/src/range_array.rs:213

↓ 202 callersMethodtake

(self)

src/common/recordbatch/src/lib.rs:316

↓ 197 callersMethodpush

Pushes a value into builder.

src/mito2/src/memtable/builder.rs:47

↓ 188 callersMethodinsert

(&self, key: VectorIndexCacheKey, value: Arc<CachedVectorIndex>)

src/mito2/src/cache/index/vector_index.rs:122

↓ 188 callersMethodinto_iter

(self)

src/servers/src/repeated_field.rs:393

↓ 187 callersMethodinc

(&self, _delta: u64)

src/cli/src/data/progress.rs:127

↓ 184 callersFunctionput_rows

Put rows into the engine.

src/mito2/src/test_util.rs:1226

↓ 181 callersMethodbody

Set the request body.

src/servers/src/http/test_helpers.rs:157

↓ 179 callersMethoditer

Returns an iterator over the columns in this relation.

src/flow/src/repr/relation.rs:514

↓ 178 callersMethodas_str

(&self)

src/mito2/src/region.rs:119

↓ 172 callersMethodcreate_engine

Creates a new engine with specific config under this env.

src/mito2/src/test_util.rs:340

↓ 171 callersMethodfields

Returns fields in the batch.

src/mito2/src/read.rs:183

↓ 169 callersMethodpost

Create a POST request.

src/servers/src/http/test_helpers.rs:97

↓ 164 callersMethodcontains

Returns true if `timestamp` is contained in the range.

src/common/time/src/range.rs:178

↓ 164 callersMethodextend

extend the row with values from an iterator

src/flow/src/repr.rs:163

↓ 163 callersMethodbuild

(&self, start_frontend_servers: bool)

tests-integration/src/cluster.rs:327

↓ 162 callersMethodpop

(&mut self)

src/servers/src/repeated_field.rs:217

↓ 158 callersMethodheader

(&self)

src/meta-srv/src/handler.rs:234

↓ 156 callersMethodclone

(&self)

src/session/src/context.rs:683

↓ 155 callersMethodproject

Retain only the indicated columns in the presented order. i.e. before: `self.projection = [1, 2, 0], columns = [1, 0]` ```mermaid flowchart TD col-0

src/flow/src/expr/linear.rs:172

↓ 155 callersMethodpush

(&self, res: HeartbeatResponse)

src/meta-srv/src/handler.rs:224

↓ 154 callersFunctioncreate_temp_dir

(prefix: &str)

src/common/test-util/src/temp_dir.rs:17

↓ 151 callersMethodremove

Removes stalled requests of specific region.

src/mito2/src/worker.rs:807

↓ 149 callersMethodas_bytes

(self)

src/common/base/src/readable_size.rs:42

↓ 149 callersFunctioncol

(name: &str, dt: ColumnDataType, st: SemanticType)

src/mito2/src/wal/encoder.rs:327

↓ 148 callersMethodinsert

(&mut self, column: ColumnRef, value: impl ToString)

src/servers/src/http/prometheus.rs:778

↓ 147 callersMethodlen

Returns the length of `kvs`

src/common/meta/src/kv_backend/memory.rs:72

↓ 146 callersMethodas_slice

(&self)

src/servers/src/repeated_field.rs:139

↓ 146 callersMethoditer

Returns an iterator over the row groups in the selection.

src/mito2/src/sst/parquet/row_selection.rs:449

↓ 146 callersMethodwrite

write lock the arrangement

src/flow/src/utils.rs:664

↓ 145 callersMethodget

Retrieves the value associated with the given key in the specified region. Returns `Ok(None)` if the key is not found.

src/metric-engine/src/metadata_region.rs:678

↓ 143 callersMethodpush

(&mut self, ch: char)

src/pipeline/src/etl/processor/dissect.rs:181

↓ 138 callersMethodwrite

(&self, _kvs: &KeyValues)

src/mito2/src/memtable/bulk.rs:415

↓ 135 callersMethodget

Gets a single tombstoned value by its original key.

src/common/meta/src/key/tombstone.rs:102

↓ 135 callersMethodinto_iter

(self)

src/pipeline/src/etl/field.rs:113

↓ 133 callersMethodas_u64

Cast Value to u64. Return None if value is not a valid uint64 data type.

src/datatypes/src/value.rs:345

↓ 130 callersMethodinto_inner

(self)

src/common/meta/src/key.rs:540

↓ 128 callersMethodget_region

(&self, id: RegionId)

src/mito2/src/engine.rs:481

↓ 127 callersMethodfilter

Add a new filter to the plan, will filter out the records that do not satisfy the filter

src/flow/src/plan.rs:99

↓ 127 callersMethodpush

(&mut self, value: serde_json::Value)

src/servers/src/http/result.rs:90

↓ 126 callersMethodfile_id

Gets the file id.

src/mito2/src/sst/file.rs:138

↓ 126 callersFunctionrows_schema

Get column schemas for rows.

src/mito2/src/test_util.rs:1207

↓ 126 callersFunctionvalidate_data

(test_name: &str, client: &TestClient, sql: &str, expected: &str)

tests-integration/tests/http.rs:9210

↓ 125 callersMethodfrontend

(&self)

tests-integration/src/tests/test_util.rs:62

↓ 125 callersMethodread

( &self, context: BulkIterContextRef, sequence: Option<SequenceRange>, mem_sca

src/mito2/src/memtable/bulk/part.rs:1072

↓ 123 callersMethodas_str

(&self)

src/servers/src/http.rs:329

↓ 121 callersFunctioncheck_output_stream

(output: OutputData, expected: &str)

src/common/test-util/src/recordbatch.rs:24

↓ 121 callersMethodlt

(self, rhs: impl Into<Self>)

src/partition/src/expr.rs:111

↓ 120 callersMethodinsert

(&self, value: T)

src/common/base/src/plugins.rs:33

↓ 119 callersMethodexecute

( &mut self, db: &crate::env::bare::GreptimeDB, namespace: &str, )

tests/runner/src/cmd/compat.rs:768

↓ 119 callersMethodget

Get the value at the given index

src/flow/src/repr.rs:130

↓ 119 callersFunctionparse

(input: &Content)

src/pipeline/src/etl.rs:60

↓ 119 callersFunctionquery

(instance: &Instance, request: Request)

tests-integration/src/grpc.rs:132

next →1–100 of 24,685, ranked by callers