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
↓ 3 callersMethodhead
(&self, location: &Path)
object_store_utils/src/test_object_store.rs:342
↓ 3 callersFunctionheader_view
The header view for a parsed file.
influxdb3_catalog/src/format/view.rs:116
↓ 3 callersMethodid
(&self)
core/iox_query/src/test.rs:1206
↓ 3 callersMethodid
(&self)
core/data_types/src/snapshot/list.rs:267
↓ 3 callersMethodid_to_ord_id
(&self, id: &ColumnIdentifier)
influxdb3_catalog/src/catalog/versions/v2.rs:2997
↓ 3 callersMethodids_for_names
Return column ids of the given column names # Panics Panics if any of the names are not found in this set.
core/data_types/src/columns.rs:109
↓ 3 callersMethodin_use
(&mut self)
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:65
↓ 3 callersMethodinc
(&self, count: u64)
core/metric/src/counter.rs:15
↓ 3 callersFunctionindex_exists_in_store
Helper to check if an index exists in object store
influxdb3_write/src/table_index_cache/tests.rs:777
↓ 3 callersMethodindices
Indices that define an ordered list of non overlapping value ranges.
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:217
↓ 3 callersMethodinflux_schema
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3495
↓ 3 callersFunctioninflux_type_to_var_ref_data_type
Maps an [`InfluxFieldType`] to a [`VarRefDataType`].
core/iox_query_influxql/src/plan/var_ref.rs:29
↓ 3 callersMethodinitialize
( self, load_type: LoadType, querier_spec_path: Option<PathBuf>, writer_spec_p
influxdb3_load_generator/src/commands/common.rs:334
↓ 3 callersMethodinsert
(&self, generation: u64, k: &Arc<K>)
core/object_store_mem_cache/src/cache_system/hook/test_utils.rs:97
↓ 3 callersMethodinstall
Install watchdog. # Panic Panics if the sum of [tick duration](Self::with_tick_duration) and [warn duration](Self::with_warn_duration) is zero.
core/tokio_watchdog/src/lib.rs:92
↓ 3 callersMethodinstance_id
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:2181
↓ 3 callersFunctioninterpolate
(arg: Expr)
core/iox_query/src/analyzer/handle_gapfill.rs:735
↓ 3 callersFunctioninterpolate_fill_strategy
(idx: usize)
core/iox_query/src/exec/gapfill/algo/interpolate.rs:593
↓ 3 callersMethodintersected
Return a time range that is the intersection of the receiver and `other`.
core/influxdb_influxql_parser/src/time_range.rs:398
↓ 3 callersMethodinto_arrow
Converts this BitSet to a buffer compatible with arrows boolean encoding, consuming self.
core/arrow_util/src/bitset.rs:187
↓ 3 callersMethodinto_legacy_column_id
(self)
influxdb3_catalog/src/catalog/versions/v2.rs:3727
↓ 3 callersMethodinto_response
(self)
influxdb3_server/src/http.rs:135
↓ 3 callersFunctioniox_session_config
Return a SessionConfig object configured for IOx
core/datafusion_util/src/config.rs:27
↓ 3 callersMethodis_cancelled
Returns if this tracker has been cancelled
core/tracker/src/task.rs:447
↓ 3 callersMethodis_cancelled
(&self)
influxdb3_shutdown/src/lib.rs:224
↓ 3 callersMethodis_empty
Returns `true` if there are NO entries within the set. # Concurrency This method is mostly lockless, except for internal locks within [`DashMap`].
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:462
↓ 3 callersMethodis_empty
(&self)
influxdb3_wal/src/object_store.rs:806
↓ 3 callersMethodis_enterprise
Whether this is an enterprise record ID (bit 15 set).
influxdb3_catalog/src/format/record_id.rs:44
↓ 3 callersFunctionis_lit
(expr: &Expr)
core/predicate/src/rpc_predicate/rewrite.rs:262
↓ 3 callersMethodis_nan
(&self)
core/data_types/src/lib.rs:2013
↓ 3 callersFunctionis_now_function
Returns `true` if `name` is `"now"`.
core/influxdb_influxql_parser/src/functions.rs:75
↓ 3 callersMethodis_restore
Whether this update was produced by a catalog restore. Restores are signalled by a [`CatalogEvent::CatalogFullyRestored`] event in the update; subscr
influxdb3_catalog/src/catalog/versions/v3/events.rs:277
↓ 3 callersFunctionis_scalar_math_function
Returns `true` if `name` is a mathematical scalar function supported by InfluxQL.
core/influxdb_influxql_parser/src/functions.rs:9
↓ 3 callersMethodis_terminated
(&self)
core/catalog_cache/src/api/server.rs:355
↓ 3 callersMethodis_upgrade_safe
Check if UPGRADE_SAFE flag is set.
influxdb3_catalog/src/format/mod.rs:147
↓ 3 callersFunctionis_valid_distinct_cache_type
(def: &ColumnDefinition)
influxdb3_catalog/src/catalog/versions/v3/ops/cache.rs:26
↓ 3 callersFunctionis_valid_last_cache_key_col
(def: &ColumnDefinition)
influxdb3_catalog/src/catalog/versions/v3/ops/cache.rs:33
↓ 3 callersFunctioniter_set_positions_with_offset
Returns an iterator over set bit positions in increasing order starting at the provided bit offset
core/arrow_util/src/bitset.rs:323
↓ 3 callersFunctionlimit_clause
Parse a `LIMIT <n>` clause.
core/influxdb_influxql_parser/src/common.rs:256
↓ 3 callersFunctionlines_to_table_batch
( lines: Vec<ParsedLine<'static>>, )
core/partition/src/lib.rs:1776
↓ 3 callersMethodlist
Returns an iterator over the items in this cache
core/catalog_cache/src/local/mod.rs:140
↓ 3 callersMethodlist
(&self, prefix: Option<&Path>)
core/object_store_mock/src/lib.rs:554
↓ 3 callersMethodlist
(&self, prefix: Option<&Path>)
influxdb3_cache/src/parquet_cache/mod.rs:829
↓ 3 callersMethodlist_with_delimiter
(&self, prefix: Option<&Path>)
object_store_utils/src/test_object_store.rs:388
↓ 3 callersMethodlist_with_offset
( &self, prefix: Option<&Path>, offset: &Path, )
object_store_utils/src/test_object_store.rs:373
↓ 3 callersMethodload_and_update_from_object_store
Load catalog updates from the object store, starting from `sequence_number`, and going until `update_until`, or if None is provided, will update until
influxdb3_catalog/src/catalog/versions/v2/update.rs:1392
↓ 3 callersMethodload_catalog_from_paths
( &self, checkpoint_path: &ObjPath, log_paths: &[ObjPath], )
influxdb3_catalog/src/object_store/versions/v2.rs:91
↓ 3 callersMethodload_checkpoints
Loads checkpoints from the given paths. Use with paths returned from `list_latest_checkpoints_per_month()`. Limits concurrency to avoid overwhelming
influxdb3_write/src/persister.rs:652
↓ 3 callersMethodload_file
(&self, path: &CatalogFilePath)
influxdb3_catalog/src/object_store/versions/v3.rs:109
↓ 3 callersFunctionload_plugin_function
Loads a Python function from either a multi-file plugin module or single-file plugin code. For multi-file plugins (when `plugin_root` is `Some`), imp
influxdb3_py_api/src/system_py.rs:349
↓ 3 callersMethodlog_args_to_string
(&self, args: &Bound<'_, PyTuple>)
influxdb3_py_api/src/system_py.rs:327
↓ 3 callersMethodlog_files_for_backup
Get the list of log files that are after the `after` (`after + 1`) sequence and up to and including the `through` sequence. This is used in the backup
influxdb3_catalog/src/object_store/versions/v2.rs:152
↓ 3 callersFunctionlp_to_mutable_batch
(lp: &str)
core/mutable_batch_pb/benches/write_table_batch.rs:15
↓ 3 callersFunctionmake_single_row_batch
(t1: Option<&str>, t2: Option<&str>, f1: Option<f64>)
core/iox_query/src/provider/deduplicate.rs:862
↓ 3 callersMethodmap_elements
( self, mut f: F, )
core/iox_query/src/exec/series_limit/logical.rs:199
↓ 3 callersFunctionmap_to_py_object
( py: Python<'py>, map: &HashMap<String, String>, )
influxdb3_py_api/src/py_conversion.rs:130
↓ 3 callersMethodmaybe_authorized_client
(&self)
influxdb3/tests/server/mod.rs:878
↓ 3 callersFunctionmeasurement
(i: &str)
core/influxdb_line_protocol/src/lib.rs:730
↓ 3 callersMethodmemory_monitor
(&self)
core/iox_query/src/query_log.rs:983
↓ 3 callersFunctionmemory_pool
make a MemoryPool with the specified max size
core/parquet_file/src/writer.rs:297
↓ 3 callersMethodmerge_from_parquet_file
(&mut self, pf: &ParquetFile)
influxdb3_write/src/table_index.rs:612
↓ 3 callersMethodmetadata_cutoff
(&self)
core/iox_query_influxql/src/plan/planner.rs:4146
↓ 3 callersMethodmetrics
(&self)
core/iox_query/src/query_log.rs:7689
↓ 3 callersFunctionmin_max_for_partitioned_filegroup
Return the min and max value for the specified group of partitioned files.
core/iox_query/src/physical_optimizer/sort/extract_ranges.rs:271
↓ 3 callersMethodmode
(&self)
core/iox_query_influxql/src/aggregate/mode.rs:140
↓ 3 callersMethodmonth
Get the month component (1-12).
influxdb3_write/src/lib.rs:426
↓ 3 callersMethodname
(&self)
core/iox_query/src/analyzer/handle_gapfill.rs:94
↓ 3 callersMethodname
(&self)
influxdb3_cache/src/last_cache/table_function.rs:431
↓ 3 callersMethodname
(&self)
influxdb3_catalog/src/format/records/types.rs:111
↓ 3 callersMethodnext
(&mut self)
core/catalog_cache/src/local/mod.rs:205
↓ 3 callersMethodnext
(&mut self)
core/arrow_util/src/bitset.rs:292
↓ 3 callersMethodnext
Returns the next backoff duration to wait for, if any
core/backoff/src/lib.rs:248
↓ 3 callersMethodnext
(&mut self)
core/mutable_batch_pb/src/decode.rs:262
↓ 3 callersMethodnext_legacy_column_id
(&mut self)
influxdb3_catalog/src/catalog/versions/v2/update.rs:1569
↓ 3 callersMethodnext_legacy_column_id
Allocate the next legacy `ColumnId` PachaTree carries `None` once the `u16` space is exhausted (it addresses columns by `ColumnIdentifier`); Parquet/
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:521
↓ 3 callersMethodnext_timestamp
(&self, ts_ns: i64, tz: &Option<impl AsRef<str>>)
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:122
↓ 3 callersMethodno_sync
Set the `no_sync` parameter to skip WAL durability ACK
influxdb3_client/src/lib.rs:1224
↓ 3 callersMethodnode_identifier_prefix
Get the host identifier prefix
influxdb3_write/src/persister.rs:175
↓ 3 callersMethodnormalize_gen
Fetch normalized generation.
core/object_store_mem_cache/src/cache_system/hook/test_utils.rs:49
↓ 3 callersMethodnotify_and_snapshot
( &self, write: Arc<WalContents>, snapshot_details: SnapshotDetails, )
influxdb3_write/src/write_buffer/queryable_buffer.rs:481
↓ 3 callersMethodnum_columns
Returns the number of columns for the table, including an additional ones added in this transaction.
influxdb3_catalog/src/catalog/versions/v2/update.rs:1514
↓ 3 callersMethodnum_tag_columns
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:362
↓ 3 callersMethodoauth_id_exists
(&self, oauth_id: &str)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:350
↓ 3 callersMethodobject_store
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:589
↓ 3 callersMethodobserver
Retrieves the observer for a given set of attributes If this is the first time this method has been called with this set of attributes, it will initi
core/metric/src/metric.rs:74
↓ 3 callersFunctionoffset_clause
Parse an `OFFSET <n>` clause.
core/influxdb_influxql_parser/src/common.rs:280
↓ 3 callersMethodon_catalog_snapshot_success
(&self, _: u64, _: u64)
influxdb3_wal/src/observer.rs:24
↓ 3 callersFunctionoptimize_dict_col
Optimizes the dictionaries for a column
core/arrow_util/src/optimize.rs:33
↓ 3 callersMethodorder_by
Return the sort order for the `SELECT` statement. The default when no `ORDER BY` clause present is `TIME ASC`.
core/influxdb_influxql_parser/src/select.rs:80
↓ 3 callersMethodoutput_from_ranges
Compute the output record batch that includes the specified ranges
core/iox_query/src/provider/deduplicate/algo.rs:276
↓ 3 callersFunctionparse_header_str
(metadata: &MetadataMap, header_str: &'static str)
core/service_grpc_flight/src/lib.rs:1431
↓ 3 callersFunctionparse_timestamp_expr
Parse s as a timestamp in the specified timezone and return the timestamp as a literal timestamp expression.
core/influxdb_influxql_parser/src/time_range.rs:733
↓ 3 callersFunctionparse_timestamp_nanos
Parse ISO 8601 timestamp to nanoseconds since epoch
core/parquet_file/src/lib.rs:251
↓ 3 callersFunctionparse_timestamp_nanos
Parse ISO 8601 timestamp to nanoseconds since epoch
core/iox_query/src/test.rs:1638
↓ 3 callersFunctionpath_buf_to_string
(path: PathBuf)
influxdb3_load_generator/src/commands/common.rs:302
↓ 3 callersMethodplan
(&self)
core/iox_query/src/query_log.rs:979
↓ 3 callersMethodplan_where_clause
Generate a logical plan that filters the existing plan based on the InfluxQL [`WhereClause`] of a `SHOW` statement.
core/iox_query_influxql/src/plan/planner.rs:3351
↓ 3 callersMethodplugin_dir_str
(&self)
influxdb3/tests/server/plugin_restriction.rs:24
↓ 3 callersMethodplugin_root
(&self)
influxdb3_processing_engine/src/lib.rs:502
↓ 3 callersMethodplugin_type
(&self)
influxdb3_catalog/src/log/versions/v2.rs:874
← previousnext →2,001–2,100 of 11,906, ranked by callers