Functions — github.com/influxdata/influxdb

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4

Applies fetch and skip to a num_rows. Fetch is the total num of rows fetched, after the skip is applied. This logic is extracted from [`Statistics::

core/iox_query/src/statistics/partition_statistics/fetch.rs:13

↓ 16 callersMethodas_secs

(&self)

influxdb3_catalog/src/log/versions/v2.rs:558

↓ 16 callersFunctionbuild_col_stats

(values: Vec<(&str, i64, i64, usize)>)

core/iox_query/src/statistics/partition_statistics/project_schema.rs:316

↓ 16 callersFunctionbuild_parquet_files

(prefix: &str, num_files: u32)

influxdb3_write/src/write_buffer/persisted_files/tests.rs:230

↓ 16 callersMethodchecked_add

Adds given [`Duration`] to the current date and time. Returns `None` if it would result in overflow

core/iox_time/src/lib.rs:141

↓ 16 callersMethodclose_line

Closing a line is required before starting a new one or finishing building the batch.

core/influxdb_line_protocol/src/builder.rs:202

↓ 16 callersMethodcmp

(&self, other: &Self)

core/influxdb_line_protocol/src/lib.rs:529

↓ 16 callersMethoddelete_database

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

influxdb3/tests/cli/api.rs:310

↓ 16 callersFunctiondf_physical_expr

Return a `PhysicalExpr` from a logical `Expr`

core/iox_query/src/exec/split.rs:987

↓ 16 callersMethodeq

(&self, other: &Self)

core/iox_query_params/src/params.rs:437

↓ 16 callersMethodexecute

(&self, partition: usize, context: Arc<TaskContext>)

core/iox_query/src/exec/series_limit/physical.rs:504

↓ 16 callersFunctionextract_future_and_state

Helper function to extract future and state from CacheState for tests

core/object_store_mem_cache/src/cache_system/test_utils.rs:25

↓ 16 callersMethodfetch

(store: &DynObjectStore, location: &Path, size_hint: u64)

core/object_store_mem_cache/src/store.rs:67

↓ 16 callersMethodfreeze

(&mut self)

core/object_store_metrics/src/metrics.rs:227

↓ 16 callersMethodinsert

(&mut self, key: String, mut entry: CacheEntry)

influxdb3_py_api/src/cache.rs:72

↓ 16 callersMethodlookup_value_or_insert

Returns the id corresponding to value, adding an entry for the id if it is not yet present in the dictionary.

core/arrow_util/src/dictionary.rs:74

↓ 16 callersFunctionparse_status

(status: Status)

core/influxdb_iox_client/src/client/error.rs:21

↓ 16 callersFunctionprojection_expr_with_2_constants

projection with 2 dictionary constants and an normal column

core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs_for_constants.rs:861

↓ 16 callersMethodread_body_json

(&self, req: Request)

influxdb3_server/src/http.rs:2018

↓ 16 callersFunctionregister_args

(node_id: &str, instance_id: &str)

influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:20

↓ 16 callersMethodreport_observation

(&mut self, attributes: &Attributes, observation: Observation)

core/metric/src/lib.rs:343

↓ 16 callersFunctionselector_min

Returns a DataFusion user defined aggregate function for computing the min(value, time) selector function, returning a struct: min(value, time) -> st

core/query_functions/src/selectors.rs:195

↓ 16 callersMethodsequence_number

Get the sequence number from the file header.

influxdb3_catalog/src/format/reader.rs:76

↓ 16 callersMethodvalue

Get the value in this state, or wait for it if it is still fetching This takes `self` as it is meant to be used on an entry's state that has been clo

influxdb3_cache/src/parquet_cache/mod.rs:383

↓ 16 callersMethodwith_error_config

Configure the error injection behavior

object_store_utils/src/test_object_store.rs:102

↓ 16 callersMethodwith_metadata

Consumes this `TaskTracker` and produces a new one with the provided metadata

core/tracker/src/task.rs:402

↓ 16 callersMethodwith_series_key

(&mut self, columns: I)

core/schema/src/builder.rs:58

↓ 15 callersMethodadd_token

(&mut self, token: RefreshTokenInfo)

influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:421

↓ 15 callersMethodapi_v3_query_sql

(&self, params: &[(&str, &str)])

influxdb3/tests/server/mod.rs:949

↓ 15 callersMethodassert_log_contains

Assert that the captured logs contain a specific string

influxdb3/tests/server/mod.rs:804

↓ 15 callersMethodauthorize

( &self, token: Option<Vec<u8>>, perms: &[IoxPermission], )

influxdb3_authz/src/lib.rs:214

↓ 15 callersFunctionbench

( group: &mut BenchmarkGroup<'_, WallTime>, template_name: &str, partition_template: Vec<proto::Te

core/partition/benches/partitioner.rs:177

↓ 15 callersMethodbuild

Build aggregated statistics.

core/iox_query/src/statistics/aggregate_per_chunk.rs:155

↓ 15 callersFunctionchunk

(id: u128)

core/iox_query/src/physical_optimizer/chunk_extraction.rs:396

↓ 15 callersMethodclone_for_aggr_col

Make a clone of this cursor to be used for creating an aggregate column, if `idx` is `Some`. The resulting `Cursor` will only contain [AggrColState] f

core/iox_query/src/exec/gapfill/algo.rs:333

↓ 15 callersFunctioncollect_stream

Helper to collect all batches from a stream

core/iox_query/src/exec/series_limit/physical.rs:1227

↓ 15 callersMethodcolumn_definition

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

influxdb3_catalog/src/catalog/versions/v2/legacy.rs:54

↓ 15 callersMethodcreate_processing_engine_trigger

( &self, db_name: &str, trigger_name: &str, plugin_filename: ValidPluginFilena

influxdb3_catalog/src/catalog/versions/v2/update.rs:1054

↓ 15 callersFunctionerr

()

core/object_store_mock/src/lib.rs:613

↓ 15 callersFunctioninit_pyo3

()

influxdb3_processing_engine/src/virtualenv.rs:113

↓ 15 callersFunctioninput_plan

( arrs: impl IntoIterator<Item = (impl Into<String>, impl Into<ArrayRef>)>, sort: impl

core/iox_query/src/exec/series_limit/physical.rs:1167

↓ 15 callersFunctionint_array

(vals: impl IntoIterator<Item = impl Into<Option<i64>>>)

core/iox_query/src/exec/series_limit/physical.rs:1159

↓ 15 callersMethodinto_inner

Consume the sharder, returning a type that can be used as an iterator over the owned shards.

core/sharder/src/jumphash.rs:68

↓ 15 callersMethodmerge

(&mut self, lower_precedence: Self)

core/iox_v1_query_api/src/lib.rs:181

↓ 15 callersMethodobject_store

Returns the configured `ObjectStore` that data is loaded from and persisted to.

influxdb3_write/src/persister.rs:953

↓ 15 callersMethodobserve

(&self, result: &Result<T>)

object_store_utils/src/observed_object_store.rs:58

↓ 15 callersMethodparts

Loan out the application-type template parts of the contained partition template for this namespace, as per the behaviour of [`serialization::Wrapper:

core/data_types/src/partition_template.rs:642

↓ 15 callersMethodrecord

(&self, _span: &Id, _values: &Record<'_>)

core/test_helpers/src/tracing.rs:197

↓ 15 callersMethodregister

(&self, request: CacheRequest)

influxdb3_cache/src/parquet_cache/mod.rs:212

↓ 15 callersMethodremove

Remove an entry from the cache, as well as its associated size from the used capacity

influxdb3_cache/src/parquet_cache/mod.rs:523

↓ 15 callersFunctionserialize_log_file

Serialize a log file which represents a single atomic change to the catalog.

influxdb3_catalog/src/format/apply.rs:110

↓ 15 callersMethodsleep

(&self, d: Duration)

core/iox_time/src/lib.rs:325

↓ 15 callersFunctionsnapshot

()

influxdb3_wal/src/snapshot_tracker/tests.rs:4

↓ 15 callersFunctiontest_input_plan

( tag: I, time: impl IntoIterator<Item = impl Into<Option<i64>>>, value: i

core/iox_query/src/exec/series_limit/physical.rs:1206

↓ 15 callersMethodtry_push

Add a new batch of buffered records from the input stream. Returns an error if the memory reservation cannot be grown to accommodate the batch.

core/iox_query/src/exec/gapfill/buffered_input.rs:77

↓ 15 callersFunctionusage

(dbs: u32, tables: u32, columns: u32)

influxdb3_catalog/src/catalog/versions/v3/usage/tests.rs:3

↓ 14 callersMethodadd

Add the specified [`SequenceNumber`] to the set. Returns `true` if this call added `n` to the set, or `false` if `n` was already present in the set.

core/data_types/src/sequence_number_set.rs:16

↓ 14 callersMethodadd_wal_period

Add a wal period to the tracker. This should be called when a new wal file is created. # Panics This will panic if the new period overlaps with the l

influxdb3_wal/src/snapshot_tracker.rs:43

↓ 14 callersMethodapi_v1_query

( &self, params: &[(&str, &str)], headers: Option<&[(&str, &str)]>, )

influxdb3/tests/server/mod.rs:973

↓ 14 callersMethodas_str

(self)

influxdb3_processing_engine/src/plugin_telemetry.rs:30

↓ 14 callersFunctionassert_cursor_end_state

( cursor: &Cursor, input_times: &TimestampNanosecondArray, params: &GapFillParams,

core/iox_query/src/exec/gapfill/algo.rs:1626

↓ 14 callersFunctionassert_histogram_not_hit

( metrics: &metric::Registry, name: &'static str, attr: [(&'static str, &'static str); N], )

core/object_store_metrics/src/test_utils.rs:26

↓ 14 callersFunctionassert_utf8_strings_eq

(left: &[u8], right: &[u8])

core/influxdb2_client/src/models/data_point.rs:347

↓ 14 callersMethodbuffer_chunk

(&mut self, chunk_time: i64, rows: &[Row])

influxdb3_write/src/write_buffer/table_buffer.rs:45

↓ 14 callersMethodbuild_time_vec

Builds a vector that can be used to produce a timestamp array.

core/iox_query/src/exec/gapfill/algo.rs:446

↓ 14 callersMethodcall

Parse the `now()` & `date_part()` function calls

core/influxdb_influxql_parser/src/expression/conditional.rs:350

↓ 14 callersMethodcatalog

(&self)

influxdb3_write/src/write_buffer/mod.rs:718

↓ 14 callersMethodchild

Creates a new child of the Span described by this TraceContext

core/trace/src/ctx.rs:87

↓ 14 callersMethodcommit_catalog_changes

( self, )

influxdb3_write/src/write_buffer/validator.rs:295

↓ 14 callersMethodcreate_distinct_cache

( &self, db_name: &str, table_name: &str, node_spec: ApiNodeSpec, cach

influxdb3_catalog/src/catalog/versions/v2/update.rs:652

↓ 14 callersMethoddb_schema

(&self)

influxdb3_write/src/write_buffer/table_buffer/tests.rs:47

↓ 14 callersMethoddb_schema

(&self, db_name: &str)

influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1213

↓ 14 callersFunctiondedupe

Run the input through a `DeduplicateExec` and return results This function also verifies that splitting the record batches along different boundaries

core/iox_query/src/provider/deduplicate.rs:1668

↓ 14 callersMethoddeduplicate

Deduplicate the output of this plan with the specified sort expressions

core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2403

↓ 14 callersMethodextensions

(&self)

core/object_store_mem_cache/src/store.rs:442

↓ 14 callersMethodinto_iter

(self)

core/iox_v1_query_api/src/response.rs:277

↓ 14 callersMethodis_empty

The set is empty or not

core/data_types/src/columns.rs:628

↓ 14 callersFunctionmake_chunks

(params: TestParams)

core/iox_v1_query_api/src/response/stream.rs:964

↓ 14 callersMethodmeasurement

Provide the measurement name. It returns a new builder whose type allows only setting tags and fields.

core/influxdb_line_protocol/src/builder.rs:135

↓ 14 callersFunctionmin

(current_min: T, new_value: T)

influxdb3_telemetry/src/stats.rs:177

↓ 14 callersMethodname

(&self)

influxdb3_catalog/src/catalog/versions/v2.rs:2291

↓ 14 callersMethodnode_catalog_id

(&self)

influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:67

↓ 14 callersMethodnum_rows

Check how many values/rows are currently being stored in this builder (including both nulls and nonnulls)

core/table_batch/src/builder/column_writer/mod.rs:112

↓ 14 callersMethodnum_rows

Get the total number of rows in this SeriesChunk.

core/iox_v1_query_api/src/response.rs:115

↓ 14 callersFunctionparse_statements

Parse the input into a set of InfluxQL statements.

core/influxdb_influxql_parser/src/lib.rs:51

↓ 14 callersMethodpersist_snapshot

Persists the snapshot file. After successful persistence, this will: 1. Update the cached checkpoint incrementally (if checkpointing enabled) 2. Pers

influxdb3_write/src/persister.rs:309

↓ 14 callersFunctionpretty_format_batches

custom version of [pretty_format_batches](arrow::util::pretty::pretty_format_batches) that displays timestamps using RFC3339 format (e.g. `2021-07-20T

core/arrow_util/src/display.rs:16

↓ 14 callersMethodput

Upsert the given key-value pair Returns Ok if able to replicate the write to a quorum

core/catalog_cache/src/api/quorum.rs:265

↓ 14 callersMethodreset_call_count

Reset the operation counter

object_store_utils/src/test_object_store.rs:153

↓ 14 callersMethodresource_iter

(&self)

influxdb3_catalog/src/catalog/versions/v3/legacy.rs:163

↓ 14 callersMethodset_token

Set the token for the server

influxdb3/tests/server/mod.rs:715

↓ 14 callersFunctionstatistics_by_partition

Handle downcasting of the `dyn ExecutionPlan` to the specific execution nodes which have implemented [`PartitionStatistics`].

core/iox_query/src/statistics/partition_statistics/mod.rs:338

↓ 14 callersMethodsubscribe_to_updates

(&self, name: &'static str)

influxdb3_catalog/src/catalog/versions/v2.rs:577

↓ 14 callersMethodto_record_batches

Produce a set of [`RecordBatch`]es from the cache, using the given set of [`Predicate`]s

influxdb3_cache/src/last_cache/cache.rs:340

↓ 14 callersMethodwith_timeout

(mut self, d: Duration)

core/test_helpers/src/timeout.rs:29

↓ 14 callersMethodwrite

Push a `RecordBatch` into the underlying writer, updating the tracked allocation

core/parquet_file/src/writer.rs:73

↓ 13 callersMethodacquire

Acquire a permit.

object_store_limit/src/lib.rs:74

↓ 13 callersMethodappend_unset

Appends `count` unset bits

core/arrow_util/src/bitset.rs:48

↓ 13 callersFunctionassert_display_expr

(input: &str, expected: &str)

core/influxdb_influxql_parser/src/expression/arithmetic.rs:918

↓ 13 callersMethodcatalog

(&self)

influxdb3_cache/src/test_helpers.rs:74

← previous next →501–600 of 11,906, ranked by callers