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 callersMethodresponse
Convert an error into a [`Response`]
core/catalog_cache/src/api/server.rs:61
↓ 1 callersMethodrestore
( time_ns: i64, restore_id: impl Into<Arc<str>>, checkpoint_path: impl Into<String>,
influxdb3_catalog/src/log/versions/v4.rs:158
↓ 1 callersMethodrestore_user
( &self, user_id: UserId, display_name: Option<Arc<str>>, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3150
↓ 1 callersMethodresult
Consumes and returns the result.
core/iox_query/src/statistics/aggregate_per_plan.rs:93
↓ 1 callersMethodresult
Returns the result of the job if it has completed, otherwise None
core/tracker/src/task.rs:324
↓ 1 callersMethodresult_time_range
Calculate the time range of the expected result set. This is the time range of the query, adjusted for any `GROUP BY TIME` interval and offset.
core/iox_query_influxql/src/plan/planner.rs:541
↓ 1 callersMethodresults_for_col_name
Resultant [`ColumnStatistics`] per partition, extracted from the schema [`Statistics`], for the test column. If the schema does not have the resultan
core/iox_query/src/statistics/partition_statistics/mod.rs:647
↓ 1 callersFunctionretention_expr
Retention time expression, "time > retention_time".
core/iox_query/src/pruning.rs:291
↓ 1 callersMethodretention_policy
(&self)
core/iox_query_influxql_rewrite/src/lib.rs:49
↓ 1 callersFunctionretention_policy_rows_to_batch
(rows: &[RetentionPolicyRow])
influxdb3_query_executor/src/lib.rs:449
↓ 1 callersMethodrevision
Get the `revision` from the response
influxdb3_types/src/http.rs:94
↓ 1 callersMethodrevoke
(&mut self, token_hash: &str, revoked_at: i64)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:432
↓ 1 callersMethodrevoke_all_for_user
(&mut self, user_id: &UserId, revoked_at: i64)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:441
↓ 1 callersFunctionrewrite_any_binary_expr
Rewrite conditional operators to `false` and any other operators to `NULL`.
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:538
↓ 1 callersFunctionrewrite_binary_expr
( input_binary_expr: BinaryExpr, schema: &IQLSchema<'_>, )
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:274
↓ 1 callersFunctionrewrite_boolean
Rewrite a binary expression where one of the operands is a [DataType::Boolean]. > **Note > > InfluxQL allows bitwise operations on boolean data types
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:556
↓ 1 callersFunctionrewrite_field_value_references
Rewrites an expression on `_value` as a boolean true literal, pushing any encountered expressions onto `value_exprs` so they can be moved onto column
core/predicate/src/rpc_predicate/value_rewrite.rs:10
↓ 1 callersFunctionrewrite_make_mixed_integer_ops_legal
Rewrites all mixed signed-unsigned operations to make them legal. This is used for comparisons.
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:671
↓ 1 callersFunctionrewrite_measurement_references
Rewrites all references to the [MEASUREMENT_COLUMN_NAME] column with the actual table name
core/predicate/src/rpc_predicate/measurement_rewrite.rs:9
↓ 1 callersMethodrewrite_select_statement
(&self, select: SelectStatement)
core/iox_query_influxql/src/plan/planner.rs:814
↓ 1 callersMethodrewrite_single_conjunct
Rewrites a single predicate. Does not handle AND specially
core/predicate/src/rpc_predicate/field_rewrite.rs:82
↓ 1 callersMethodrewrite_subquery
Rewrite the `SELECT` statement by applying specific rules for subqueries.
core/iox_query_influxql/src/plan/rewriter.rs:206
↓ 1 callersFunctionrewrite_tag_columns
Rewrite tag references into ```sql case when tag0 is null then "" else tag0 end ``` This ensures that we treat tags with the same semantics as OG Infl
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:659
↓ 1 callersMethodrollup_reads_1m
(&mut self)
influxdb3_telemetry/src/store.rs:366
↓ 1 callersMethodrollup_reads_and_writes_1m
(&mut self)
influxdb3_telemetry/src/store.rs:351
↓ 1 callersMethodrollup_writes_1m
(&mut self)
influxdb3_telemetry/src/store.rs:361
↓ 1 callersFunctionroute_request
( http_server: Arc<HttpApi>, req: Request, started_without_auth: bool, paths_without_authz: &'
influxdb3_server/src/http.rs:2606
↓ 1 callersMethodrow_count
Return the number of rows in the parquet file
core/parquet_file/src/metadata.rs:734
↓ 1 callersMethodrow_delete_predicate_version
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:2226
↓ 1 callersMethodrow_delete_predicate_version
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:122
↓ 1 callersMethodrows
Returns the number of rows in the write
core/partition/src/lib.rs:238
↓ 1 callersFunctionrun
(group: &mut BenchmarkGroup<'_, WallTime>, size: usize)
core/catalog_cache/benches/list_encode.rs:31
↓ 1 callersFunctionrun_bench
( params: BenchmarkParams, mut rng: StdRng, t_program_start: Instant, iteration: u64, )
core/object_store_mem_cache/benches/s3_fifo_concurrency.rs:93
↓ 1 callersMethodrun_command
(&self)
influxdb3_commands/src/install.rs:65
↓ 1 callersMethodrun_config
(&self, config: CaseIoStepsConfig)
core/futures_test_utils/benches/buffered_stream.rs:75
↓ 1 callersFunctionrun_dry_run_schedule_plugin
Execute a schedule plugin in dry-run mode for testing purposes. Runs the plugin with real queries but buffers all writes without persisting them. The
influxdb3_processing_engine/src/plugins.rs:1086
↓ 1 callersMethodrun_in_background
This method runs in background, but checks if the process is shutting down by checking the cancellation token and exiting. But this method more import
influxdb3_shutdown/src/lib.rs:364
↓ 1 callersFunctionrun_plan
Run a plan against the following input table as "t" ```text +-----------+-----------+-----------+--------------+------------+------------------------
core/query_functions/src/selectors.rs:1523
↓ 1 callersFunctionrun_querier
( mut querier: Querier, client: Client, database_name: String, end_time: Option<DateTime<Local
influxdb3_load_generator/src/commands/query.rs:129
↓ 1 callersFunctionrun_request_plugin
( db_name: String, plugin_code: Arc<PluginCode>, trigger_definition: Arc<TriggerDefinition>, c
influxdb3_processing_engine/src/plugins.rs:174
↓ 1 callersMethodrun_request_plugin
( &self, mut receiver: Receiver<RequestEvent>, )
influxdb3_processing_engine/src/plugins.rs:669
↓ 1 callersFunctionrun_schedule_plugin
( db_name: String, plugin_code: Arc<PluginCode>, trigger_definition: Arc<TriggerDefinition>, t
influxdb3_processing_engine/src/plugins.rs:137
↓ 1 callersMethodrun_schedule_plugin
( &self, mut receiver: Receiver<ScheduleEvent>, mut runner: ScheduleTriggerRunner,
influxdb3_processing_engine/src/plugins.rs:468
↓ 1 callersFunctionrun_wal_contents_plugin
( db_name: String, plugin_code: Arc<PluginCode>, trigger_definition: Arc<TriggerDefinition>, c
influxdb3_processing_engine/src/plugins.rs:109
↓ 1 callersMethodrun_wal_flush_plugin
( &self, mut receiver: Receiver<WalEvent>, )
influxdb3_processing_engine/src/plugins.rs:280
↓ 1 callersMethodrun_with_memory_limit
(self, limit: usize)
core/iox_query/src/exec/gapfill/exec_tests.rs:1504
↓ 1 callersFunctionruntime_shutdown
(setup: TestSetup)
core/object_store_mem_cache/src/cache_system/test_utils.rs:470
↓ 1 callersMethodsample
(call: &'a Call)
core/iox_query_influxql/src/plan/planner/select.rs:352
↓ 1 callersFunctionsample_metrics
( store: Arc<TelemetryStore>, duration_secs: Duration, )
influxdb3_telemetry/src/sampler.rs:83
↓ 1 callersFunctionscalar
Construct a boolean ColumnarValue::Scalar
core/iox_query/src/exec/split.rs:1075
↓ 1 callersMethodscalar_math_func_to_df_expr
Map the InfluxQL scalar function call to a DataFusion scalar function expression.
core/iox_query_influxql/src/plan/planner.rs:3173
↓ 1 callersMethodscan
( &self, _ctx: &dyn Session, projection: Option<&Vec<usize>>, filters: &[Expr]
core/iox_system_tables/src/system_tables.rs:61
↓ 1 callersMethodschedule_plugin_test
Make a request to the `POST /api/v3/plugin_test/schedule` API
influxdb3_client/src/lib.rs:906
↓ 1 callersFunctionschema
()
core/iox_query/src/physical_optimizer/union/nested_union.rs:203
↓ 1 callersMethodschema
(&self)
influxdb3_system_tables/src/databases.rs:43
↓ 1 callersMethodschema
(&self)
influxdb3_system_tables/src/queries.rs:29
↓ 1 callersMethodschema
(&self)
influxdb3_system_tables/src/influxdb_schema.rs:98
↓ 1 callersMethodschema
(&self)
influxdb3_system_tables/src/distinct_caches.rs:47
↓ 1 callersMethodschema
(&self)
influxdb3_system_tables/src/parquet_files.rs:44
↓ 1 callersMethodschema
(&self)
influxdb3_system_tables/src/tables.rs:46
↓ 1 callersMethodschema
(&self)
influxdb3_system_tables/src/last_caches.rs:57
↓ 1 callersMethodschema
(&self)
core/iox_query_influxql/src/show_retention_policies.rs:134
↓ 1 callersMethodschema
(&self)
core/iox_query_influxql/src/show_databases.rs:69
↓ 1 callersMethodschema
(&self)
core/iox_query/src/exec/query_tracing.rs:62
↓ 1 callersMethodschema
(&self)
core/iox_query/src/provider/reorder_partitions.rs:117
↓ 1 callersMethodschema
(&self)
influxdb3_cache/src/last_cache/table_function.rs:56
↓ 1 callersMethodschema
()
influxdb3_py_api/src/logging.rs:52
↓ 1 callersMethodschema_check
(&self)
core/iox_query/src/physical_optimizer/limits.rs:55
↓ 1 callersFunctionschemas
Return a set of schemas that make up the test database.
core/iox_query_influxql/src/plan/test_utils.rs:35
↓ 1 callersMethodsecond
Returns the second number from 0 to 59.
core/iox_time/src/lib.rs:119
↓ 1 callersMethodsegment
Return the segment being interpolated, if any. # Panics This method will panic if `self` is not [AggrColState::LinearInterpolate].
core/iox_query/src/exec/gapfill/algo.rs:892
↓ 1 callersMethodselect_by_names
Returns a Schema for a given (sub)set of named columns
core/schema/src/lib.rs:903
↓ 1 callersMethodselect_integral_window
INTEGRAL is semantically an aggregate function, but has window-like properties due to the need to calculate adjacent points in a sliding window. To im
core/iox_query_influxql/src/plan/planner.rs:2197
↓ 1 callersMethodselect_query_to_plan
Create a [`LogicalPlan`] from the specified InfluxQL `SELECT` statement.
core/iox_query_influxql/src/plan/planner.rs:819
↓ 1 callersMethodsend
(&self, value: Self::T)
core/datafusion_util/src/sender.rs:21
↓ 1 callersMethodsend_get_bytes_with_headers
Like [`Self::send_get_bytes`] but also returns the response headers.
influxdb3_client/src/lib.rs:1061
↓ 1 callersFunctionsend_telemetry
(store: &Arc<TelemetryStore>, telem_sender: &mut TelemetrySender)
influxdb3_telemetry/src/sender.rs:126
↓ 1 callersFunctionsend_telemetry_in_background
This function runs in the background and if any call fails there is no retrying mechanism and it is ok to lose a few samples
influxdb3_telemetry/src/sender.rs:109
↓ 1 callersMethodsequence
Get the sequence number for this record.
influxdb3_catalog/src/format/record.rs:157
↓ 1 callersMethodsequence_number
(&self)
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:95
↓ 1 callersFunctionserialize_to_parquet
( mem_pool: Arc<dyn MemoryPool>, batches: SendableRecordBatchStream, )
influxdb3_write/src/persister.rs:958
↓ 1 callersMethodseries_arrays
Produces the arrays for the group columns in the input. The first item in the 2-tuple is the arrays offset in the schema.
core/iox_query/src/exec/gapfill/stream.rs:238
↓ 1 callersMethodseries_key_names
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3569
↓ 1 callersMethodseries_key_owned
(&self)
core/schema/src/lib.rs:657
↓ 1 callersFunctionserve_admin_token_recovery_endpoint
( server: Server<'_>, shutdown: CancellationToken, tcp_listener_file_path: Option<PathBuf>, )
influxdb3_server/src/lib.rs:215
↓ 1 callersMethodset
Sets a given bit
core/arrow_util/src/bitset.rs:167
↓ 1 callersMethodset_bit
(&mut self, idx: usize)
core/data_types/src/snapshot/mask.rs:59
↓ 1 callersFunctionset_bloom_filter_sizing
Determine the setting for the bloom2 filter. Given a max anticipated number of items, and an acceptable false positive rate, determine the [`FilterSi
core/object_store_metrics/src/cache_metrics.rs:261
↓ 1 callersMethodset_cache_value_directly
When parquet bytes are in hand this method can be used to update the cache value directly without going through Fetching -> Success lifecycle
influxdb3_cache/src/parquet_cache/mod.rs:483
↓ 1 callersMethodset_duration
(&mut self, level: impl Into<u8>, duration: Duration)
influxdb3_catalog/src/catalog/versions/v2.rs:2120
↓ 1 callersMethodset_duration
(&mut self, level: impl Into<u8>, duration: Duration)
influxdb3_catalog/src/catalog/versions/v1.rs:872
↓ 1 callersMethodset_duration
( &mut self, level: impl Into<u8>, duration: Duration, )
influxdb3_catalog/src/catalog/versions/v3/schema/storage.rs:46
↓ 1 callersMethodset_fetching
Insert a `Fetching` entry to the cache along with the shared future for polling the value being fetched
influxdb3_cache/src/parquet_cache/mod.rs:469
↓ 1 callersMethodset_indices
Returns an iterator of the set indices in this mask
core/data_types/src/snapshot/mask.rs:17
↓ 1 callersMethodset_parquet_file_limit
Set the parquet file limit. If the limit is already set it will not be increased.
core/iox_query/src/config.rs:112
↓ 1 callersMethodset_partition_limit
Set the partition limit. If the limit is already set it will not be increased.
core/iox_query/src/config.rs:95
↓ 1 callersMethodset_processing_engine
Set the processing engine after construction. # Panics Panics if called more than once.
influxdb3_query_executor/src/lib.rs:149
↓ 1 callersMethodset_retention_policy
(&mut self, rp: String)
core/iox_query_influxql_rewrite/src/lib.rs:41
↓ 1 callersMethodset_success
Update a `Fetching` entry to a `Success` entry in the cache
influxdb3_cache/src/parquet_cache/mod.rs:496
↓ 1 callersFunctionsetup
()
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/mod.rs:629
← previousnext →4,501–4,600 of 11,906, ranked by callers