MCPcopy Create free account

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4
↓ 2 callersMethodcolumn_definition_by_id
(&self, column_id: &ColumnId)
influxdb3_catalog/src/catalog/versions/v2/legacy.rs:69
↓ 2 callersMethodcolumn_name
Column name.
core/data_types/src/partition_template.rs:358
↓ 2 callersFunctioncolumn_projection
Create a projection expression for the given columns.
core/iox_query/src/physical_optimizer/projection_pushdown.rs:406
↓ 2 callersMethodcolumn_values
Reverse a `partition_key` generated from the given `template`, reconstructing the set of tag values and bucket IDs the `partition_key` was generated f
core/data_types/src/partition_template.rs:816
↓ 2 callersFunctioncombine_sort_key
Combines the existing sort key with the sort key of the chunk, returning the new combined compatible sort key that describes both chunks. If it is no
core/iox_query/src/provider/physical.rs:84
↓ 2 callersMethodcomplete
(&mut self)
core/object_store_metrics/src/lib.rs:1500
↓ 2 callersFunctioncompute_batch
( input_batch: &RecordBatch, indices: ColumnarValue, last_batch: bool, )
core/iox_query/src/exec/split.rs:464
↓ 2 callersFunctioncompute_null_mask
(valid_mask: &BitSet)
core/mutable_batch_pb/src/encode.rs:143
↓ 2 callersFunctioncompute_sort_key
Given a `Schema` and an iterator of `RecordBatch`es, compute a sort key based on: - The columns that make up the primary key of the schema - Order th
core/schema/src/sort.rs:306
↓ 2 callersMethodcomputed_size
(&self)
influxdb3_write/src/write_buffer/table_buffer.rs:149
↓ 2 callersMethodconvert_row
Convert a row to row-oriented format for easy comparison.
core/iox_query/src/exec/gapfill/buffered_input.rs:233
↓ 2 callersMethodcopy
(&self, from: &Path, to: &Path)
core/object_store_metrics/src/cache_metrics.rs:394
↓ 2 callersMethodcopy_point
Copies a point at `offset` into the vector that will be used to build an Arrow array.
core/iox_query/src/exec/gapfill/algo/interpolate.rs:282
↓ 2 callersMethodcount_zeros
Returns the number of unset bits in this bitmap.
core/arrow_util/src/bitset.rs:252
↓ 2 callersMethodcreate
()
core/test_helpers_authz/src/authz.rs:38
↓ 2 callersFunctioncreate_db_record
(seq: u64, id: u32, name: &str)
influxdb3_commands/src/debug/catalog/tests.rs:17
↓ 2 callersFunctioncreate_default_index_map
Helper to create default hasher IndexMap (for comparison)
influxdb3_id/benches/serde_vec_map_comparison.rs:19
↓ 2 callersMethodcreate_http_trace_layer
Create an HTTP trace layer for request monitoring and metrics
influxdb3_server/src/lib.rs:187
↓ 2 callersMethodcreate_label
Create a Label
core/influxdb2_client/src/api/label.rs:62
↓ 2 callersMethodcreate_last_cache
( &self, db_name: &str, table_name: &str, node_spec: ApiNodeSpec, cach
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2263
↓ 2 callersMethodcreate_last_cache_committed
( &self, db_name: &str, table_name: &str, node_spec: ApiNodeSpec, cach
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2296
↓ 2 callersFunctioncreate_mock_store
(prefix: Arc<str>)
influxdb3_catalog/src/catalog/migrations/tests.rs:220
↓ 2 callersMethodcreate_named_admin_token_with_permission
( &self, token_name: String, expiry_secs: Option<u64>, )
influxdb3_catalog/src/catalog/versions/v2.rs:1026
↓ 2 callersMethodcreate_new_empty_table
Create a new empty table definition with the given `table_name` in the database.
influxdb3_catalog/src/catalog/versions/v1.rs:1061
↓ 2 callersFunctioncreate_table
(catalog: &mut InnerCatalog, db_name: &str, table_name: &str)
influxdb3_catalog/src/catalog/versions/v3/ops/test_util.rs:46
↓ 2 callersFunctioncreate_test_parquet_file
Helper function to create test ParquetFile
influxdb3_write/src/table_index_cache/tests.rs:14
↓ 2 callersMethodcreate_token_with_permission
Create a resource-scoped token. Returns the stored `TokenInfo` plus the raw token string.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2051
↓ 2 callersMethodcurrent_node
(&self)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:283
↓ 2 callersMethoddata
(&self)
influxdb3_write/src/chunk.rs:48
↓ 2 callersMethoddata
Data attached to the running future.
core/object_store_mem_cache/src/cache_system/loader.rs:262
↓ 2 callersFunctiondata_source_exec_parquet_with_optional_ranges
( files: impl IntoIterator<Item = (&'static str, Option<(i64, i64)>)>, )
core/iox_query/src/physical_optimizer/limits.rs:340
↓ 2 callersMethoddatabase_count
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:1605
↓ 2 callersMethoddatabase_count
(&self)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1366
↓ 2 callersMethoddatabase_count_limit
(&self, _current: &CurrentCatalogUsage)
influxdb3_catalog/src/catalog/versions/v3/usage.rs:86
↓ 2 callersFunctiondatabase_or_deletion_status
( db_schema: Option<Arc<DatabaseSchema>>, time_provider: &Arc<dyn TimeProvider>, )
influxdb3_catalog/src/catalog/versions/v2.rs:4712
↓ 2 callersFunctiondb_1
()
influxdb3_write/src/table_index/test_table_index_operations.rs:157
↓ 2 callersMethoddb_exists
(&self, db_id: DbId)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1241
↓ 2 callersMethoddb_id_to_name
(&self, db_id: &DbId)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1209
↓ 2 callersMethoddb_name_to_id
(&self, db_name: &str)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1205
↓ 2 callersMethoddb_names
List names of databases that have not been deleted
influxdb3_catalog/src/catalog/versions/v2.rs:791
↓ 2 callersMethoddb_or_create
( &self, db_name: &str, retention_period: Option<Duration>, now_time_ns: i64,
influxdb3_catalog/src/catalog/versions/v2.rs:740
↓ 2 callersMethoddb_schema
(&self, db_name: &str)
influxdb3_catalog/src/catalog/versions/v2.rs:782
↓ 2 callersMethoddb_table_and_file_count
(&self)
influxdb3_write/src/lib.rs:244
↓ 2 callersFunctiondecode_already_exists
Returns an iterator over the [`AlreadyExists`] in the provided [`tonic::Status`]
core/generated_types/src/google.rs:353
↓ 2 callersFunctiondecode_not_found
Returns an iterator over the [`NotFound`] in the provided [`tonic::Status`]
core/generated_types/src/google.rs:406
↓ 2 callersFunctiondecode_precondition_violation
Returns an iterator over the [`PreconditionViolation`] in the provided [`tonic::Status`]
core/generated_types/src/google.rs:532
↓ 2 callersFunctiondecode_resource_info
Returns an iterator over the [`rpc::ResourceInfo`] payloads in the provided [`tonic::Status`]
core/generated_types/src/google.rs:276
↓ 2 callersFunctiondecode_timestamp_from_field
( value: Option<pbjson_types::Timestamp>, field: &'static str, )
core/parquet_file/src/metadata.rs:530
↓ 2 callersFunctiondedup_plan_impl
( schema: Schema, chunks: Vec<TestChunk>, use_chunk_order_col: bool, )
core/iox_query/src/physical_optimizer/dedup/test_util.rs:25
↓ 2 callersFunctiondedup_plan_with_chunk_order_col
( schema: Schema, chunks: Vec<TestChunk>, )
core/iox_query/src/physical_optimizer/dedup/test_util.rs:18
↓ 2 callersFunctiondedupe_inner
Actally run the deduplicator
core/iox_query/src/provider/deduplicate.rs:1690
↓ 2 callersFunctiondefault_filter
(table_name: &str)
influxdb3/src/commands/show/system.rs:328
↓ 2 callersFunctiondefault_ordering
(table_name: &str)
influxdb3/src/commands/show/system.rs:316
↓ 2 callersMethoddefault_timestamp
(&self)
core/iox_query_influxql/src/plan/planner.rs:612
↓ 2 callersMethoddelete
(&self, location: &Path)
influxdb3_clap_blocks/src/object_store/tests.rs:522
↓ 2 callersMethoddelete
(&self, location: &Path)
object_store_utils/src/test_object_store.rs:352
↓ 2 callersMethoddelete_database
( &self, db_id: DbId, )
influxdb3_write/src/write_buffer/persisted_files.rs:38
↓ 2 callersMethoddelete_last_cache
( &self, db_name: &str, table_name: &str, cache_name: &str, )
influxdb3_catalog/src/catalog/versions/v2/update.rs:1020
↓ 2 callersMethoddelete_processing_engine_trigger
( &self, db_name: &str, trigger_name: &str, force: bool, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2412
↓ 2 callersMethoddelete_stream
( &'a self, locations: BoxStream<'a, Result<Path>>, )
object_store_utils/src/observed_object_store.rs:140
↓ 2 callersMethoddelete_table
( &self, db_id: DbId, table_id: TableId, )
influxdb3_write/src/write_buffer/persisted_files.rs:64
↓ 2 callersMethoddelete_token
(&self, token_name: &str)
influxdb3_catalog/src/catalog/versions/v2/update.rs:1213
↓ 2 callersMethoddelete_with_retries
( &self, path: &Path, context_message: String, retry_params: RetryParams,
object_store_utils/src/retryable_object_store.rs:360
↓ 2 callersMethoddelta
Adjusts the value of this U64Gauge by the specified delta. # Underflow / Overflow This operation wraps around on over/underflow.
core/metric/src/gauge.rs:40
↓ 2 callersMethodderef
(&self)
influxdb3_write/src/paths.rs:68
↓ 2 callersMethodderef
(&self)
core/linear_buffer/src/linear_buffer.rs:282
↓ 2 callersMethodderef_mut
(&mut self)
core/influxdb_influxql_parser/src/common.rs:308
↓ 2 callersFunctiondetect_children_with_desired_ordering
( plan: &dyn ExecutionPlan, )
core/iox_query/src/physical_optimizer/sort/parquet_sortness.rs:68
↓ 2 callersMethoddf_projection
Returns a DataFusion style "projection" when the selection is applied to this schema. `None` means "all columns" `Some(indicies)` means the subset
core/schema/src/lib.rs:868
↓ 2 callersMethoddisable_processing_engine_trigger
( &self, db_name: &str, trigger_name: &str, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2443
↓ 2 callersMethoddisable_trigger
( &self, db_name: impl Into<String>, trigger_name: impl Into<String>, )
influxdb3/tests/cli/api.rs:807
↓ 2 callersFunctiondo_work_async
Wait for the barrier and then return `result`
core/executor/src/lib.rs:701
↓ 2 callersMethoddowngrade
(&self)
core/object_store_mem_cache/src/cache_system/loader.rs:315
↓ 2 callersMethoddowngrade_storage_mode_to_parquet
Operator-driven revert to `Parquet` from any other storage mode. # Warning Should not be called while nodes in the cluster are running.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2508
↓ 2 callersMethoddrop_val
(self, val: T, barrier: Arc<Barrier>)
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:1195
↓ 2 callersFunctiondump_heap_profile
Trigger a jemalloc heap profile dump and return a streaming reader for the resulting `heap_v2` bytes. Requires jemalloc built with `--enable-prof` (i
core/jemalloc_stats/src/lib.rs:119
↓ 2 callersMethodemit
Emit entry to various systems. You should usually call [`set_and_emit`](Self::set_and_emit), but directly calling this method is OK for new entries (
core/iox_query/src/query_log.rs:515
↓ 2 callersMethodenable_processing_engine_trigger
( &self, db_name: &str, trigger_name: &str, )
influxdb3_catalog/src/catalog/versions/v2/update.rs:1151
↓ 2 callersMethodenable_trigger
( &self, db_name: impl Into<String>, trigger_name: impl Into<String>, )
influxdb3/tests/cli/api.rs:771
↓ 2 callersFunctionencode_bad_request
(violation: Vec<FieldViolation>)
core/generated_types/src/google.rs:165
↓ 2 callersFunctionencode_batch_without_id
Encode the given mutable batch to a [`TableBatchWithoutId`]. Basically same as [`encode_batch`], but when you don't have an id.
core/mutable_batch_pb/src/encode.rs:29
↓ 2 callersFunctionencode_key_part
(s: &str)
core/partition/src/template.rs:190
↓ 2 callersFunctionencode_resource_info
( resource_type: String, resource_name: String, owner: String, description: String, )
core/generated_types/src/google.rs:305
↓ 2 callersFunctionencode_schema
Encodes the schema IPC encoded (schema_bytes)
core/flightsql/src/planner.rs:396
↓ 2 callersMethodendpoint
Get endpoint.
core/catalog_cache/src/api/client.rs:192
↓ 2 callersMethodentries
(&self)
core/iox_query/src/query_log.rs:946
↓ 2 callersFunctionentry_likely_in_use
This arc is shared between the `S3Fifo.entries` and the locked state. Therefore, we want to not consider the arc's ref count in determining in-use sta
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:76
↓ 2 callersMethoderror
(self: Box<Self>, code: GrpcCode)
core/service_grpc_flight/src/observer.rs:177
↓ 2 callersFunctionescape_or_fallback
Parse an unescaped piece of text, interspersed with potentially-escaped characters. If the character *isn't* escaped, treat it as a literal character.
core/influxdb_line_protocol/src/lib.rs:975
↓ 2 callersMethodevaluate
(&mut self)
core/query_functions/src/selectors/internal.rs:309
↓ 2 callersMethodevaluate_all
(&mut self, values: &[ArrayRef], _num_rows: usize)
core/query_functions/src/derivative.rs:191
↓ 2 callersFunctionevaluate_template
Evaluate the partition template against the row indexed by `idx`. # Panics This method panics if `idx` exceeds the number of rows in the batch.
core/partition/src/lib.rs:125
↓ 2 callersMethodevent
(&self)
influxdb3_catalog/src/format/records/role.rs:82
↓ 2 callersMethodevict
(&self, key: CacheKey, _value: &CacheValue)
core/catalog_cache/src/local/mod.rs:239
↓ 2 callersMethodevict_keys
Evict multiple keys from the S3FifoCache, in a blocking manner. This method directly removes entries from the cache without going through the normal
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/mod.rs:310
↓ 2 callersFunctionexec2
()
core/executor/src/lib.rs:710
↓ 2 callersFunctionexec_with_threads
(threads: usize)
core/executor/src/lib.rs:714
↓ 2 callersMethodexecute
Execute a SQL query on the server using [`CommandStatementQuery`] This involves two roundtrips Step 1: send a [`CommandStatementQuery`] message to t
core/influxdb_iox_client/src/client/flightsql.rs:575
↓ 2 callersMethodexecute
( &self, partition: usize, context: Arc<TaskContext>, )
core/iox_query/src/provider/progressive_eval.rs:205
↓ 2 callersMethodexecute_stream_partitioned
Executes a single partition of a physical plan and produces a `SendableRecordBatchStream` to stream over the result that iterates over the results. Th
core/iox_query/src/exec/context.rs:658
← previousnext →2,401–2,500 of 11,906, ranked by callers