MCPcopy Index your code

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4
↓ 39 callersMethodpush_str
(&mut self, s: &str)
core/table_batch/src/builder/column_writer/string.rs:26
↓ 39 callersMethodsoft_delete_table
( &self, db_name: &str, table_name: &str, hard_delete_time: HardDeletionTime,
influxdb3_catalog/src/catalog/versions/v2/update.rs:525
↓ 39 callersMethodtable_definition
(&self, table_name: impl AsRef<str>)
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:100
↓ 38 callersMethodinc
(&self, duration: Duration)
core/iox_time/src/lib.rs:268
↓ 38 callersFunctionpredicates
( preds: impl IntoIterator<Item = (ColumnId, Predicate)>, )
influxdb3_cache/src/last_cache/tests.rs:22
↓ 38 callersMethodrecv
(&mut self)
influxdb3_catalog/src/catalog/versions/v3/events.rs:343
↓ 38 callersMethodschema
return the schema of the inner plan
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2522
↓ 38 callersMethodwith_tag_column_with_stats
Register a tag column with stats with the test chunk
core/iox_query/src/test.rs:623
↓ 38 callersMethodwith_time_column_with_stats
Register a timestamp column with the test chunk
core/iox_query/src/test.rs:702
↓ 37 callersMethodbegin
(&self, db_name: &str)
influxdb3_catalog/src/catalog/versions/v2/update.rs:113
↓ 37 callersMethodcancel
Trigger graceful termination of any futures tracked by this tracker Note: If the future is currently executing, termination will only occur when the
core/tracker/src/task.rs:426
↓ 37 callersMethoddb_schema_by_id
(&self, db_id: &DbId)
influxdb3_catalog/src/catalog/versions/v2.rs:786
↓ 37 callersMethodget
Returns the element at index `idx`
core/data_types/src/snapshot/list.rs:136
↓ 37 callersMethodget
(&self, config: TableConfig)
influxdb3/src/commands/show/system.rs:187
↓ 37 callersMethodget_by_name
(&self, name: &str)
influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:50
↓ 37 callersMethodinsert
Insert the given `value` into the cache Skips insertion and returns false iff an entry already exists with the same or greater generation
core/catalog_cache/src/local/mod.rs:87
↓ 37 callersMethoditer_mut
An iterator visiting all name-value pairs with mutable references to the values. Currently this will iterate in an arbitrary order, but specific order
core/iox_query_params/src/params.rs:127
↓ 37 callersFunctionpath
(key_idx: u64)
core/object_store_mem_cache/benches/s3_fifo_concurrency.rs:182
↓ 37 callersMethodto_bytes
Serialize header to bytes.
influxdb3_catalog/src/format/header.rs:147
↓ 36 callersMethodassert_pending
(&mut self)
core/futures_test_utils/src/lib.rs:39
↓ 36 callersMethodcatalog_update_with_retry
Perform a catalog update and retry if the catalog has been updated elsewhere until the operation succeeds or fails
influxdb3_catalog/src/catalog/versions/v2/update.rs:1307
↓ 36 callersMethodget
(&self)
core/data_types/src/lib.rs:143
↓ 36 callersMethodis_empty
Returns true when there are no parameters defined in the collection.
core/iox_query_params/src/params.rs:137
↓ 36 callersMethoditer
Returns an iterator of `(Option<InfluxColumnType>, &Field)` for all the columns of this schema, in order
core/schema/src/lib.rs:752
↓ 36 callersMethodlen
Returns the total number of elements. Note that `len` ≥ 1.
core/influxdb_influxql_parser/src/common.rs:464
↓ 36 callersMethodlt
Return `self < other`
core/influxdb_influxql_parser/src/expression/conditional.rs:130
↓ 36 callersMethodnum_rows
Return the number of partitions (rows) in the converted rows.
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:312
↓ 36 callersMethodput
(&self, location: &Path, bytes: PutPayload)
influxdb3_cache/src/parquet_cache/mod.rs:703
↓ 36 callersMethodrequest
Consolidate common request building code
core/influxdb2_client/src/lib.rs:170
↓ 36 callersMethodschema
(&self)
core/iox_query/src/exec.rs:611
↓ 35 callersMethodbuild
Create an ExecutionContext suitable for executing DataFusion plans
core/iox_query/src/exec/context.rs:282
↓ 35 callersFunctioncapture
()
core/object_store_metrics/src/lib.rs:3308
↓ 35 callersMethodcolumn
Column (w/o table name).
core/data_types/src/lib.rs:1573
↓ 35 callersMethoddb_schema_by_id
(&self, db_id: &DbId)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1217
↓ 34 callersFunction_test_progressive_eval
( partitions: &[Vec<RecordBatch>], fetch: Option<usize>, expected_result: &[&str],
core/iox_query/src/provider/progressive_eval.rs:1629
↓ 34 callersMethodappend
(&mut self, row: &RetentionPolicyRow)
influxdb3_query_executor/src/lib.rs:417
↓ 34 callersMethodas_ref
(&self)
core/object_store_metrics/src/metrics.rs:175
↓ 34 callersMethodbegin_database_transaction
Open a [`DatabaseCatalogTransaction`] for the given database. If the database does not exist, it is auto-created and a [`crate::format::records::Crea
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2637
↓ 34 callersMethoddb_id
Get the db_id
influxdb3_id/src/lib.rs:170
↓ 34 callersMethodget
(&self, phase: QueryPhase)
core/iox_query/src/query_log.rs:1513
↓ 34 callersMethodnode_id
Get the node_id
influxdb3_id/src/lib.rs:165
↓ 34 callersMethodpush
(&mut self, val: T)
influxdb3_sys_events/src/lib.rs:147
↓ 34 callersMethodunion
Create a union of this plan with another plan
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2368
↓ 34 callersMethodwith_col_opts
Helper to insert col with specified sort options into sort key
core/schema/src/sort.rs:37
↓ 33 callersMethodget
Get an entry in the cache or `None` if there is not an entry This updates the hit time of the entry and returns a cloned copy of the entry state so t
influxdb3_cache/src/parquet_cache/mod.rs:443
↓ 33 callersMethoditer
Returns a value [`Iterator`] that yields boolean values encoded in the bitmap.
core/arrow_util/src/bitset.rs:263
↓ 33 callersMethodmin
(call: &'a Call)
core/iox_query_influxql/src/plan/planner/select.rs:327
↓ 33 callersMethodnext
(&mut self)
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:714
↓ 33 callersMethodrecord
(&self, value: Duration)
core/metric/src/duration.rs:116
↓ 33 callersMethodregister
Register a task that needs to perform work before the process may exit Provides a [`ShutdownToken`] which the caller is responsible for handling. The
influxdb3_shutdown/src/lib.rs:102
↓ 33 callersMethodtable_id
Get the table_id
influxdb3_id/src/lib.rs:175
↓ 32 callersMethodbuild
Returns the schema that was built, the columns are always sorted in lexicographic order
core/schema/src/merge.rs:244
↓ 32 callersMethodclone
(&self)
core/metric/src/metric.rs:28
↓ 32 callersMethodexpr_to_df_expr
Map an InfluxQL [`IQLExpr`] to a DataFusion [`Expr`].
core/iox_query_influxql/src/plan/planner.rs:2472
↓ 32 callersMethodfield
Add a field (key + value). Field keys will be escaped according to the rules defined in [the special characters documentation]. Field values will en
core/influxdb_line_protocol/src/builder.rs:171
↓ 32 callersMethodinto_inner
Consume self and return the inner [`FlightClient`]
core/influxdb_iox_client/src/client/flightsql.rs:87
↓ 32 callersMethodkeys
Returns an iterator of all keys currently in the cache.
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:467
↓ 32 callersMethodresource_iter
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3085
↓ 31 callersFunctioncollect_stream
(stream: FlightRecordBatchStream)
influxdb3/tests/server/mod.rs:1203
↓ 31 callersFunctioncreate_plugin_in_temp_dir
(code: &str)
influxdb3/tests/cli/mod.rs:42
↓ 31 callersMethodextend
(&mut self, iter: T)
influxdb3_query_executor/src/lib.rs:444
↓ 31 callersFunctionfrom_timestamp
Take a scalar timestamptz, and return a UTC nanoseconds. Nanoseconds provided should always be in UTC, even if TZ differs. The offset information is
core/iox_query_influxql/src/aggregate/mode.rs:263
↓ 31 callersMethodgt
Return `self > other`
core/influxdb_influxql_parser/src/expression/conditional.rs:120
↓ 31 callersMethodinner
returns a reference to the inner datafusion execution context
core/iox_query/src/exec/context.rs:493
↓ 31 callersFunctionlog
(level: &str, color: &str, target: &str, message: &str)
influxdb3_startup/src/early_logging.rs:16
↓ 31 callersMethodmetadata
Returns a reference to the metadata stored within this Tracker
core/tracker/src/task.rs:416
↓ 31 callersMethodschema
(&self)
core/iox_query/src/exec/sleep.rs:67
↓ 31 callersMethodspawn
Runs the specified [`Future`] (and any tasks it spawns) on the thread pool managed by this `DedicatedExecutor`. # Notes UNLIKE [`tokio::task::spawn`
core/executor/src/lib.rs:299
↓ 31 callersFunctionto_string_array
(strs: &[&str])
core/parquet_file/src/storage.rs:1054
↓ 30 callersFunctionTIME_DATA_TIMEZONE
()
core/schema/src/lib.rs:72
↓ 30 callersMethodadd_chunk
(&mut self, chunk: Arc<dyn QueryChunk>)
core/iox_query/src/physical_optimizer/chunk_extraction.rs:64
↓ 30 callersMethodis_ok
True if the most recent known state is a success. Returns `false` when no success has ever been recorded, or when the most recent error is at or afte
object_store_utils/src/object_store_health.rs:188
↓ 30 callersMethodmeasurement
Provides the InfluxDB data model measurement name for this schema, if any
core/schema/src/lib.rs:736
↓ 30 callersMethodnext
(&mut self)
core/iox_v1_query_api/src/response.rs:293
↓ 30 callersMethodput
(&self, location: &Path, payload: PutPayload)
object_store_utils/src/test_object_store.rs:245
↓ 30 callersMethodremove
(&mut self, id: &I)
influxdb3_catalog/src/repository.rs:268
↓ 30 callersFunctionserialize_catalog_file
(file: &T)
influxdb3_catalog/src/serialize/versions/v2.rs:227
↓ 30 callersFunctiontest_collect_partition
Execute the specified partition of the [ExecutionPlan] with a default [SessionContext] and collect the results in memory. # Panics If an an error occ
core/datafusion_util/src/lib.rs:388
↓ 29 callersMethodchild_ctx
Returns a IOxSessionContext with a SpanRecorder that is a child of the current
core/iox_query/src/exec/context.rs:709
↓ 29 callersFunctionconditional_expression
Parse an InfluxQL conditional expression.
core/influxdb_influxql_parser/src/expression/conditional.rs:257
↓ 29 callersMethodcontains
(&self, mode: &NodeMode)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:1014
↓ 29 callersMethodcount
Specify the size, or number of new entries a cache will hold before evicting old ones
influxdb3_client/src/lib.rs:1626
↓ 29 callersFunctiondedup_plan
(schema: Schema, chunks: Vec<TestChunk>)
core/iox_query/src/physical_optimizer/dedup/test_util.rs:14
↓ 29 callersFunctionexplain_statement
Parse an `EXPLAIN` statement.
core/influxdb_influxql_parser/src/explain.rs:62
↓ 29 callersMethodextend
(&mut self, iter: T)
core/iox_query_params/src/params.rs:381
↓ 29 callersMethodinsert
Insert a column name and its bucket info
core/iox_query/src/pruning_oracle.rs:110
↓ 29 callersMethodis_empty
Returns true if the container has no elements.
core/influxdb_influxql_parser/src/common.rs:535
↓ 29 callersMethodis_empty
Returns `true` if the schema contains no fields.
core/schema/src/lib.rs:746
↓ 29 callersMethoditer
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:68
↓ 29 callersMethodlast
(call: &'a Call)
core/iox_query_influxql/src/plan/planner/select.rs:303
↓ 29 callersMethodobject_store
(mut self, object_store: Arc<dyn ObjectStore>)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:231
↓ 29 callersFunctionparse_lines
Parses a new line-delimited string into an iterator of [`ParsedLine`]. See the [crate-level documentation](self) for more information and examples.
core/influxdb_line_protocol/src/lib.rs:570
↓ 29 callersMethodpush
Add data `l` to the current chunk being created, returning the current chunk if complete.
core/influxdb_iox_client/src/client/write.rs:323
↓ 29 callersMethodpush
Adds a min and max to the end of the in-progress ranges
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:107
↓ 29 callersMethodput
( &mut self, cache_id: &CacheId, key: &str, value: Py<PyAny>, ttl: Opt
influxdb3_py_api/src/cache.rs:185
↓ 29 callersMethodtrack
(self, registration: TaskRegistration)
core/tracker/src/task/future.rs:15
↓ 29 callersMethodwith_row_count
(mut self, count: u64)
core/iox_query/src/test.rs:650
↓ 28 callersMethodadd_permission
( &mut self, resource_type: ResourceType, resource_id: TokenPermissionResourceIdentifi
influxdb3_authz/src/permissions.rs:551
↓ 28 callersFunctionchunks_to_physical_nodes
Place [chunk](QueryChunk)s into physical nodes. This will group chunks into [record batch](QueryChunkData::RecordBatches) and [parquet file](QueryChu
core/iox_query/src/provider/physical.rs:147
↓ 28 callersFunctiondata_source_exec_parquet
(files: &[&'static str])
core/iox_query/src/physical_optimizer/limits.rs:330
← previousnext →201–300 of 11,906, ranked by callers