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
↓ 1 callersMethodbuild_output
Helper method that produces gap-filled record batches. This method works by producing each array in the output completely, for all series that have e
core/iox_query/src/exec/gapfill/algo.rs:215
↓ 1 callersFunctionbuild_provider_for_case
(case: &Case)
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2189
↓ 1 callersFunctionbuild_schema
(col_names: Vec<&str>)
core/iox_query/src/statistics/partition_statistics/project_schema.rs:304
↓ 1 callersFunctionbuild_test_case_two_unions_and_dedupe
Build test case for: Union DeduplicateExec SPM Union DataSourceExec (ranges_per_partition_for_DataSourceExec_1) DataSourceExec (ranges_per_partition_
core/iox_query/src/statistics/partition_statistics/mod.rs:1532
↓ 1 callersFunctionbuild_version_string
Build a version string with a product name, version, and git hash.
influxdb3_process/src/lib.rs:26
↓ 1 callersFunctionbuilt_in_spec_names
()
influxdb3_load_generator/src/specs/mod.rs:14
↓ 1 callersMethodbytes_scanned
Hook for `RecordBatchesExec` to emit a `bytes_scanned` metric on behalf of this chunk. Only consumed by record-batch-backed chunks; parquet chunks ret
core/iox_query/src/lib.rs:113
↓ 1 callersMethodbytes_written
(&self)
influxdb3_load_generator/src/line_protocol_generator.rs:554
↓ 1 callersMethodca_certificate_pem
Add a custom CA certificate (PEM-encoded) for TLS connections. The certificate is applied to both gRPC (tonic) and HTTP (reqwest) clients. Native roo
core/client_util/src/connection.rs:244
↓ 1 callersFunctioncache_parquet_files
( parquet_cache: Option<Arc<dyn ParquetCacheOracle>>, parquet_files: &[T], )
influxdb3_write/src/write_buffer/mod.rs:627
↓ 1 callersFunctioncalc_linear
Given an input `time` value and two known points `prev_point` and `next_point` in a time series, computes the value at input `time` using linear inter
core/iox_query_influxql/src/window/integral.rs:255
↓ 1 callersMethodcall_to_df_expr
Map an InfluxQL function call to a DataFusion expression. A full list of supported functions available via the [InfluxQL documentation][docs]. > **N
core/iox_query_influxql/src/plan/planner.rs:2629
↓ 1 callersFunctioncardinality_range
( cardinality: usize, querier_id: QuerierId, querier_count: usize, )
influxdb3_load_generator/src/query_generator.rs:117
↓ 1 callersFunctioncatalog_batch
( db_id: DbId, db_name: impl Into<Arc<str>>, time_ns: i64, ops: impl IntoIterator<Item = Datab
influxdb3_catalog/src/catalog/versions/v2/create.rs:9
↓ 1 callersMethodcatalog_batch
(&mut self)
influxdb3_catalog/src/catalog/versions/v1/update.rs:816
↓ 1 callersMethodcatalog_id
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:908
↓ 1 callersMethodcatalog_uuid
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:573
↓ 1 callersFunctioncatalog_with_store_and_time
( store: Arc<dyn ObjectStore>, time: Arc<dyn TimeProvider>, )
influxdb3_catalog/src/catalog/versions/v2/update/enterprise/tests.rs:18
↓ 1 callersMethodcheck
Returns `Ok(true)` if the corresponding service is serving
core/influxdb_iox_client/src/client/health.rs:25
↓ 1 callersMethodcheck_aggregate_function
Validate `c` is an aggregate, window aggregate or selector function.
core/iox_query_influxql/src/plan/rewriter.rs:1230
↓ 1 callersMethodcheck_and_add_new_fields
( &self, table_definition: &CreateTableLog, )
influxdb3_catalog/src/catalog/versions/v1.rs:1608
↓ 1 callersMethodcheck_and_enforce_retention
Check all tables for retention policies and enforce them.
influxdb3_write/src/retention_period_handler.rs:63
↓ 1 callersMethodcheck_chande_momentum_oscillator
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1500
↓ 1 callersMethodcheck_count_hll
(&mut self, _args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1539
↓ 1 callersMethodcheck_cumulative_sum
(&mut self, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1418
↓ 1 callersMethodcheck_date_part_function
(&mut self, c: &Call)
core/iox_query_influxql/src/plan/rewriter.rs:1213
↓ 1 callersMethodcheck_derivative
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1386
↓ 1 callersMethodcheck_difference
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1409
↓ 1 callersMethodcheck_elapsed
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1398
↓ 1 callersMethodcheck_exponential_moving_average
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1440
↓ 1 callersFunctioncheck_features
Asserts that the `SELECT` statement does not use any unimplemented features. The list of unimplemented or unsupported features are listed below. # `
core/iox_query_influxql/src/plan/rewriter.rs:87
↓ 1 callersMethodcheck_fields
( &mut self, fields: &[Field], fill: Option<FillClause>, )
core/iox_query_influxql/src/plan/rewriter.rs:1023
↓ 1 callersMethodcheck_holt_winters
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1550
↓ 1 callersMethodcheck_integral
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1530
↓ 1 callersMethodcheck_kaufmans
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1480
↓ 1 callersMethodcheck_math_function
(&mut self, c: &Call)
core/iox_query_influxql/src/plan/rewriter.rs:1185
↓ 1 callersFunctioncheck_mem_and_force_snapshot_loop
( write_buffer: Arc<WriteBufferImpl>, memory_threshold_bytes: usize, check_interval: Duration, )
influxdb3_write/src/write_buffer/mod.rs:769
↓ 1 callersMethodcheck_moving_average
(&mut self, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1424
↓ 1 callersMethodcheck_percentile
(&mut self, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1287
↓ 1 callersFunctioncheck_preconditions
( value: &CacheValue, headers: &HeaderMap, )
core/catalog_cache/src/api/server.rs:235
↓ 1 callersFunctioncheck_qualified_measurements
(stmt: &SelectStatement)
core/iox_query_influxql/src/plan/rewriter.rs:95
↓ 1 callersMethodcheck_sample
(&mut self, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1303
↓ 1 callersFunctioncheck_schema
Check that the [`Schema`] that we've [decoded](decode_schema) is sensible. Returns `true` if the [`Schema`] is OK. Will log a warning and return `fal
core/service_grpc_flight/src/keep_alive.rs:286
↓ 1 callersMethodcheck_top_bottom
(&mut self, name: &str, args: &[Expr])
core/iox_query_influxql/src/plan/rewriter.rs:1334
↓ 1 callersMethodchildren
(&self)
core/iox_query/src/exec/gapfill/mod.rs:573
↓ 1 callersFunctionchildren_partition_count
(plan: &dyn ExecutionPlan)
core/iox_query/src/statistics/partition_statistics/util.rs:14
↓ 1 callersMethodchunk_time_for_timestamp
Returns the time of the chunk the given timestamp belongs to based on the duration
influxdb3_wal/src/lib.rs:188
↓ 1 callersMethodclassify
(panic_info: &PanicHookInfo<'_>)
core/panic_logging/src/lib.rs:151
↓ 1 callersFunctionclassify_response
( response: &http::Response<B>, )
core/trace_http/src/classify.rs:34
↓ 1 callersMethodcleanup
(&mut self)
influxdb3_py_api/src/cache.rs:116
↓ 1 callersMethodcleanup_expired
(&mut self, now_ms: i64)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:451
↓ 1 callersMethodclear
Clears the map, removing all name-value pairs.
core/iox_query_params/src/params.rs:142
↓ 1 callersMethodclear
Clear all thread local state
core/logfmt/tests/logging.rs:343
↓ 1 callersMethodclear_retention_period_for_database
( &self, db_name: &str, )
influxdb3_catalog/src/catalog/versions/v2/update.rs:1266
↓ 1 callersMethodclear_retention_period_for_table
Remove the per-table retention policy.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1925
↓ 1 callersMethodclear_snapshots
(&mut self)
influxdb3_write/src/write_buffer/table_buffer.rs:195
↓ 1 callersMethodcli_params
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:2222
↓ 1 callersMethodclient
Return a reference to the underyling http client
core/client_util/src/connection.rs:58
↓ 1 callersMethodclone_cancellation_token
Get a clone of the cancellation token for triggering shutdown
influxdb3_shutdown/src/lib.rs:215
↓ 1 callersMethodclone_with_no_metrics
(&self)
core/iox_query/src/physical_optimizer/cached_parquet_data.rs:189
↓ 1 callersMethodclose
(self)
core/authz/src/iox_authorizer.rs:375
↓ 1 callersFunctioncmd_from_descriptor
Extracts an encoded Protobuf message from a [`FlightDescriptor`], as used in FlightSQL.
core/service_grpc_flight/src/lib.rs:1329
↓ 1 callersMethodcmp
(&self, other: &Self)
influxdb3_write/src/async_collections.rs:111
↓ 1 callersMethodcmp
(&self, other: &Self)
influxdb3_catalog/src/log/versions/v3.rs:239
↓ 1 callersMethodcmp
(&self, other: &Self)
influxdb3_catalog/src/log/versions/v4.rs:374
↓ 1 callersFunctioncoalesce_exec
(input: &Arc<dyn ExecutionPlan>)
core/iox_query/src/test.rs:1487
↓ 1 callersFunctioncoalesce_struct
Create logical `coalesce_struct` expression. See [module-level docs](self) for more information.
core/query_functions/src/coalesce_struct.rs:222
↓ 1 callersFunctioncoerce_union_schema
Infalliable function that tries to get a common schema that is compatible with all inputs of UNION. Fallback to using the first schema provided (leftm
core/iox_query_influxql/src/plan/planner/union.rs:34
↓ 1 callersFunctioncollect_compute_duration
Collect compute duration from [`ExecutionPlan`].
core/iox_query/src/query_log.rs:1361
↓ 1 callersMethodcollect_compute_time
(&self, state: &mut QueryLogEntryState)
core/iox_query/src/query_log.rs:1089
↓ 1 callersMethodcollect_for_plan
This could be implemented via a visitor pattern, specifically ExecutionPlanVisitor, but that doesn't have lifetime bounds, so the visitor can't borrow
core/iox_query/src/physical_optimizer/limits.rs:97
↓ 1 callersFunctioncollect_ingester_metrics
(plan: &dyn ExecutionPlan)
core/iox_query/src/query_log.rs:1379
↓ 1 callersMethodcollect_ingester_metrics
(&self, state: &mut QueryLogEntryState)
core/iox_query/src/query_log.rs:1103
↓ 1 callersMethodcollect_memory_usage
(&self, state: &mut QueryLogEntryState)
core/iox_query/src/query_log.rs:1097
↓ 1 callersFunctioncollect_new_statistics
This function ensures that all bounds in the `ExprBoundaries` vector are converted to closed bounds. If a lower/upper bound is initially open, it is a
core/iox_query/src/statistics/partition_statistics/filter.rs:58
↓ 1 callersFunctioncollect_num_rows
Collect the number of rows from an [`ExecutionPlan`]. ## Note This function returns returns an [`Option`] to distinguish between no metrics being ava
core/iox_query/src/query_log.rs:1461
↓ 1 callersMethodcollect_num_rows
(&self, state: &mut QueryLogEntryState)
core/iox_query/src/query_log.rs:1109
↓ 1 callersFunctioncollect_output_epoch
( stream: impl Stream<Item = Response> + Send, epoch: Option<Precision>, )
core/iox_v1_query_api/src/response/chunked.rs:449
↓ 1 callersFunctioncollect_output_epoch
( stream: impl Stream<Item = Response> + Send, epoch: Option<Precision>, )
core/iox_v1_query_api/src/response/buffered.rs:386
↓ 1 callersFunctioncollect_parquet_json_files
(dir: &Path, results: &mut Vec<(PathBuf, SystemTime)>)
influxdb3/tests/server/gen1_lookback_guard.rs:41
↓ 1 callersFunctioncollect_stream
(mut stream: SendableRecordBatchStream)
influxdb3_internal_api/src/query_executor/show_databases_tests.rs:61
↓ 1 callersFunctioncollect_stream
(mut stream: SendableRecordBatchStream)
influxdb3_internal_api/src/query_executor/show_retention_policies_tests.rs:90
↓ 1 callersMethodcolumn
(&self, column: &str)
core/partition/src/traits/mutable_batch.rs:47
↓ 1 callersMethodcolumn
Returns the column by index
core/data_types/src/snapshot/table.rs:158
↓ 1 callersMethodcolumn_count
Return number of columns of the table
core/data_types/src/lib.rs:906
↓ 1 callersMethodcolumn_definition_by_id
TODO(trevor): remove thid API in favour of the Repository APIs
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:416
↓ 1 callersMethodcolumn_id
(&self)
influxdb3_catalog/src/log/versions/v4.rs:582
↓ 1 callersFunctioncolumn_ids_for_names
Convert a list of column names to their respective [`ColumnId`]s in the given [`TableDefinition`]
influxdb3_cache/src/test_helpers.rs:86
↓ 1 callersMethodcolumn_per_table_limit
(&self, _current: &CurrentCatalogUsage)
influxdb3_catalog/src/catalog/versions/v2.rs:414
↓ 1 callersMethodcolumn_per_table_limit
(&self, _current: &CurrentCatalogUsage)
influxdb3_catalog/src/catalog/versions/v3/usage.rs:94
↓ 1 callersMethodcolumn_type
(&self)
influxdb3_catalog/src/log/versions/v4.rs:598
↓ 1 callersFunctioncolumn_type_to_influxdb_type
Converts an InfluxDB column type to its string representation. This function maps the internal InfluxDB column types to user-friendly string represen
influxdb3_system_tables/src/influxdb_schema.rs:82
↓ 1 callersMethodcolumn_values_builder
Creates a [`ColumnValuesBuilder`] that can be used to reverse partition keys generated from this template by calling the method [`ColumnValuesBuilder:
core/data_types/src/partition_template.rs:831
↓ 1 callersFunctioncombine_column_summaries
(total: &mut Vec<ColumnSummary>, other: Vec<ColumnSummary>)
core/parquet_file/src/metadata.rs:857
↓ 1 callersMethodcompare_config
Compare the configuration of a given cache, producing a helpful error message if they differ
influxdb3_cache/src/distinct_cache/cache.rs:253
↓ 1 callersMethodcompare_config
Compare this cache's configuration with that of another
influxdb3_cache/src/last_cache/cache.rs:229
↓ 1 callersMethodcomplete
Returns a complete tracker
core/tracker/src/task/registry.rs:37
↓ 1 callersMethodcompose_middleware
(self, channel: Channel, endpoint: Endpoint)
core/client_util/src/connection.rs:174
↓ 1 callersMethodcompute_field_indices
Returns an array of indices, one for each input range that return the first non-null value of `input_array` in that range (aka it will pick the index
core/iox_query/src/provider/deduplicate/algo.rs:353
↓ 1 callersMethodcompute_sort_key_indices
Returns an array of indices, one for each input range (which index is arbitrary as all the values are the same for the sort column in each pk group)
core/iox_query/src/provider/deduplicate/algo.rs:341
← previousnext →3,301–3,400 of 11,906, ranked by callers