Functions — github.com/influxdata/influxdb

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4

↓ 1 callersMethodparams_mut

(&mut self)

influxdb3_load_generator/src/query_generator.rs:79

↓ 1 callersFunctionparquet_chunk_from_file

( parquet_file: &ParquetFile, table_schema: &Schema, object_store_url: ObjectStoreUrl, object_

influxdb3_write/src/write_buffer/mod.rs:654

↓ 1 callersMethodparquet_file_limit_opt

Get the parquet file limit as an Option.

core/iox_query/src/config.rs:104

↓ 1 callersMethodparquet_file_meta

Return parquet file metadata

core/parquet_file/src/metadata.rs:724

↓ 1 callersMethodparquet_files

( &self, )

influxdb3_write/src/table_index_cache.rs:206

↓ 1 callersMethodparquet_files_filtered

( &self, db_id: DbId, table_id: TableId, filter: &ChunkFilter<'_>, )

influxdb3_write/src/write_buffer/mod.rs:726

↓ 1 callersFunctionparquet_files_schema

()

influxdb3_system_tables/src/parquet_files.rs:30

↓ 1 callersFunctionparse

(s: &str)

core/influxdb_line_protocol/src/v3/mod.rs:292

↓ 1 callersMethodparse

(i: &str)

core/influxdb_influxql_parser/src/simple_from_clause.rs:33

↓ 1 callersFunctionparse_and_recognize

This is a copied version of nom's `recognize` that runs the parser and** returns the entire matched input.

core/influxdb_line_protocol/src/lib.rs:1149

↓ 1 callersFunctionparse_conditional_expression

Parse the input completely and return a [`ConditionalExpression`]. All leading and trailing whitespace is consumed. If any input remains after parsin

core/influxdb_influxql_parser/src/expression/conditional.rs:265

↓ 1 callersFunctionparse_field

Parse the input completely and return a [`Field`]. All leading and trailing whitespace is consumed. If any input remains after parsing, an error is r

core/influxdb_influxql_parser/src/select.rs:553

↓ 1 callersFunctionparse_legacy_series_key

Parse legacy series key format, handling cases where tag names contain '/'. The legacy format uses '/' as a separator, which creates ambiguity when t

core/schema/src/lib.rs:355

↓ 1 callersFunctionparse_legacy_series_key_with_order

Schema-order parser for legacy series keys (ambiguous cases only). This function is called ONLY when the fast path fails due to: - Duplicate parts af

core/schema/src/lib.rs:489

↓ 1 callersFunctionparse_line

(i: &str)

core/influxdb_line_protocol/src/lib.rs:671

↓ 1 callersFunctionparse_line

(i: &str)

core/influxdb_line_protocol/src/v3/mod.rs:176

↓ 1 callersFunctionparse_line

Parse the user-inputted line protocol string NOTE: This is only necessary because clap will not accept a single string for a trailing arg

influxdb3_commands/src/write.rs:255

↓ 1 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/v3/mod.rs:143

↓ 1 callersFunctionparse_part_bucket

(value: &str, num_buckets: u32)

core/data_types/src/partition_template.rs:1302

↓ 1 callersFunctionparse_part_tag_value

(value: &str)

core/data_types/src/partition_template.rs:1264

↓ 1 callersMethodparse_part_time_format

(&self, value: &'t str)

core/data_types/src/partition_template.rs:1394

↓ 1 callersFunctionparse_qualified_field_name

Parse `family::field` to extract the family qualifier. Returns `None` for unqualified names, or for malformed qualifiers (empty family name or empty

influxdb3_catalog/src/catalog/versions/v3/transaction.rs:684

↓ 1 callersFunctionparse_series_key_with_tracker

Helper function that parses series key and returns tags in schema order

core/schema/src/lib.rs:413

↓ 1 callersFunctionparse_single

(input: &str)

core/iox_query_influxql_rewrite/src/lib.rs:220

↓ 1 callersFunctionparse_single_failure

(input: &str)

core/iox_query_influxql_rewrite/src/lib.rs:224

↓ 1 callersFunctionparse_time_offset

(s: &str, now: DateTime<Local>)

influxdb3_load_generator/src/commands/write.rs:223

↓ 1 callersFunctionparse_timestamp_tz

Parse the timestamp string and return a DateTime in the specified timezone.

core/influxdb_influxql_parser/src/timestamp.rs:30

↓ 1 callersFunctionparse_timestamp_utc

Parse the timestamp string and return a DateTime in UTC.

core/influxdb_influxql_parser/src/timestamp.rs:9

↓ 1 callersFunctionparse_trace

(s: &str)

core/trace_http/src/ctx.rs:54

↓ 1 callersFunctionparse_uuid

Parse big-endian UUID from protobuf.

core/parquet_file/src/metadata.rs:521

↓ 1 callersFunctionparse_v1

Parse a V1 write request for single tenant mode.

core/iox_http/src/write/single_tenant/mod.rs:121

↓ 1 callersMethodparse_v1

(&self, _req: &Request)

core/iox_http/src/write.rs:68

↓ 1 callersMethodparse_v1

(&self, _req: &Request)

core/iox_http/src/write/multi_tenant.rs:56

↓ 1 callersFunctionparse_v2

Parse a V2 write request for multi tenant mode.

core/iox_http/src/write/multi_tenant.rs:66

↓ 1 callersFunctionparse_v2

Parse a V2 write request for single tenant mode.

core/iox_http/src/write/single_tenant/mod.rs:150

↓ 1 callersMethodparse_v2

(&self, _req: &Request)

core/iox_http/src/write.rs:74

↓ 1 callersFunctionparsed_implicit_defaults

(mut parsed: format::Parsed)

core/data_types/src/partition_template.rs:1314

↓ 1 callersFunctionparsed_lines_with_input

Create a strategy for parsed lines, using the given input parameters. Used from inside `arbitrary_parsed_lines_same_table`.

core/influxdb_line_protocol/src/test_helpers.rs:233

↓ 1 callersMethodpartial_cmp

(&self, other: &Self)

core/iox_query/src/exec/gapfill/mod.rs:71

↓ 1 callersMethodpartial_cmp

(&self, other: &Self)

influxdb3_catalog/src/log/versions/v2.rs:149

↓ 1 callersFunctionpartition_count

(plan: &Arc<dyn ExecutionPlan>)

core/iox_query/src/physical_optimizer/sort/extract_ranges.rs:170

↓ 1 callersMethodpartition_key

Return the partition key derived for this op.

core/dml/src/lib.rs:213

↓ 1 callersMethodpartition_limit_opt

Get the partition limit as an Option.

core/iox_query/src/config.rs:87

↓ 1 callersFunctionpartition_metrics

(metrics: MetricsSet)

core/iox_query/src/exec/query_tracing.rs:261

↓ 1 callersMethodpartitions

Returns an iterator of the [`PartitionId`] in this table

core/data_types/src/snapshot/table.rs:176

↓ 1 callersFunctionpb_value_type

(column: &str, values: &PbValues)

core/mutable_batch_pb/src/decode.rs:379

↓ 1 callersFunctionper_partition_tracing

()

core/iox_query/src/exec/query_tracing.rs:18

↓ 1 callersFunctionpercentile_idx

Calculate the location in an ordered list of len items where the location of the item at the given percentile would be found. This uses the same algo

core/iox_query_influxql/src/aggregate/percentile.rs:188

↓ 1 callersFunctionperform_routing

( http_server: Arc<HttpApi>, mut req: Request, started_without_auth: bool, paths_without_authz

influxdb3_server/src/http.rs:2677

↓ 1 callersMethodpermits_acquired

return the number of acquired permits

core/tracker/src/async_semaphore.rs:376

↓ 1 callersMethodpersist_catalog_checkpoint

Persist the `CatalogSnapshot` as a checkpoint and ensure that the operation succeeds unless the file already exists. Object Storage should handle the

influxdb3_catalog/src/object_store/versions/v1.rs:72

↓ 1 callersMethodpersist_catalog_sequenced_log

( &self, batch: &OrderedCatalogBatch, )

influxdb3_catalog/src/object_store/versions/v2.rs:176

↓ 1 callersMethodpersist_previous_month_checkpoint_async

Persist the previous month's checkpoint asynchronously when month rolls over. This is called from `update_cached_checkpoint()` when a month boundary

influxdb3_write/src/persister.rs:415

↓ 1 callersFunctionpersist_snapshot

( object_store: &Arc<dyn ObjectStore>, table_id: &TableIndexId, seq: SnapshotSequenceN

influxdb3_write/src/table_index_cache/tests.rs:2803

↓ 1 callersFunctionpersist_table_index_with_time_ranges

( object_store: &Arc<dyn ObjectStore>, table_id: &TableIndexId, file_specs: Vec<(i64,

influxdb3_write/src/table_index_cache/tests.rs:2737

↓ 1 callersMethodpersisted_parquet_files

( &self, db_id: DbId, table_id: TableId, filter: &ChunkFilter<'_>, )

influxdb3_write/src/write_buffer/queryable_buffer.rs:448

↓ 1 callersMethodpersisted_snapshot_notify_rx

( &self, )

influxdb3_write/src/write_buffer/queryable_buffer.rs:458

↓ 1 callersFunctionphys_fill_expr

( records: &TestRecords, fill_strategy: Option<FillStrategy>, )

core/iox_query/src/exec/gapfill/exec_tests.rs:1576

↓ 1 callersMethodphysical_plan

Physically plan a SQL query against the catalogs registered with `ctx`, and return a DataFusion physical execution plan that runs on the query executo

core/iox_query/src/frontend/sql.rs:31

↓ 1 callersMethodping

(&self)

influxdb3_server/src/http.rs:1213

↓ 1 callersMethodping

(&self, _req: Request)

core/iox_v1_query_api/src/handler.rs:164

↓ 1 callersMethodping

Send a `/ping` request to the target `influxdb3` server to check its status and gather `version` and `revision` information

influxdb3_client/src/lib.rs:921

↓ 1 callersMethodplan

( &self, planner: &dyn PhysicalPlanner, logical_inputs: &[&LogicalPlan], physi

core/iox_query/src/exec/sleep.rs:42

↓ 1 callersFunctionplan_for_case

(case: &Case)

core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2230

↓ 1 callersMethodplan_from_data_source

Generate a logical plan for the specified `DataSource`. If the data source is a table then the plan will include a filter to ensure that at least one

core/iox_query_influxql/src/plan/planner.rs:3400

↓ 1 callersFunctionplan_gap_fill

Called by the extension planner to plan a [GapFill] node.

core/iox_query/src/exec/gapfill/mod.rs:331

↓ 1 callersFunctionplan_get_catalogs

Return a list of "catalogs" from the DataFusion catalog

core/flightsql/src/planner.rs:414

↓ 1 callersFunctionplan_get_cross_reference

( ctx: &IOxSessionContext, _pk_catalog: Option<String>, _pk_db_schema: Option<String>, _pk_tab

core/flightsql/src/planner.rs:426

↓ 1 callersFunctionplan_get_db_schemas

Return a list of schema from the DataFusion catalog

core/flightsql/src/planner.rs:440

↓ 1 callersFunctionplan_get_exported_keys

( ctx: &IOxSessionContext, _catalog: Option<String>, _db_schema: Option<String>, _table: Strin

core/flightsql/src/planner.rs:464

↓ 1 callersFunctionplan_get_imported_keys

( ctx: &IOxSessionContext, _catalog: Option<String>, _db_schema: Option<String>, _table: Strin

core/flightsql/src/planner.rs:474

↓ 1 callersFunctionplan_get_primary_keys

( ctx: &IOxSessionContext, _catalog: Option<String>, _db_schema: Option<String>, _table: Strin

core/flightsql/src/planner.rs:484

↓ 1 callersFunctionplan_get_sql_info

Return a `LogicalPlan` for GetSqlInfo

core/flightsql/src/planner.rs:408

↓ 1 callersFunctionplan_get_table_types

Return a `LogicalPlan` for GetTableTypes

core/flightsql/src/planner.rs:574

↓ 1 callersFunctionplan_get_tables

Return a list of tables from the DataFusion catalog

core/flightsql/src/planner.rs:495

↓ 1 callersFunctionplan_get_xdbc_type_info

Return a `LogicalPlan` for GetXdbcTypeInfo

core/flightsql/src/planner.rs:593

↓ 1 callersFunctionplan_has_influxql_metadata

Check if any schema in the plan tree has InfluxQL-specific metadata.

core/iox_query_influxql/src/plan/planner/metadata.rs:158

↓ 1 callersMethodplan_output_batch

Produces a vector of offsets that are the exclusive ends of each series in the buffered input. It will return the ends of only those series that can a

core/iox_query/src/exec/gapfill/algo.rs:167

↓ 1 callersMethodplan_query

( &self, query: String, database: String, params: StatementParams, aut

core/iox_v1_query_api/src/handler.rs:425

↓ 1 callersFunctionplan_series_limit

Plan a SeriesLimit logical node into a physical SeriesLimitExec. This function converts the logical representation of per-series limiting into a phys

core/iox_query/src/exec/series_limit/mod.rs:49

↓ 1 callersMethodplanner

Optional physical planner to configure for the extension. The default implementation returns `None`.

core/iox_query/src/extension.rs:11

↓ 1 callersMethodplugin_trigger_invocations

(&self)

influxdb3_telemetry/src/store/tests.rs:30

↓ 1 callersFunctionplugins_schema

()

influxdb3_system_tables/src/plugins.rs:25

↓ 1 callersMethodpoll

(mut self: Pin<&mut Self>, cx: &mut Context<'_>)

core/executor/src/io.rs:64

↓ 1 callersMethodpoll_next

(self: Pin<&mut Self>, cx: &mut Context<'_>)

core/iox_v1_query_api/src/response/chunked.rs:121

↓ 1 callersMethodpoll_next

(self: Pin<&mut Self>, cx: &mut Context<'_>)

core/iox_v1_query_api/src/response/stream.rs:45

↓ 1 callersMethodpoll_next

(self: Pin<&mut Self>, cx: &mut Context<'_>)

core/iox_v1_query_api/src/response/buffered.rs:115

↓ 1 callersMethodpoll_next

(self: Pin<&mut Self>, cx: &mut Context<'_>)

core/iox_v1_query_api/src/response/json.rs:48

↓ 1 callersMethodpoll_next

(self: Pin<&mut Self>, cx: &mut Context<'_>)

core/iox_v1_query_api/src/response/csv.rs:62

↓ 1 callersMethodpoll_next

(self: Pin<&mut Self>, cx: &mut Context<'_>)

core/iox_v1_query_api/src/response/msgpack.rs:41

↓ 1 callersMethodpoll_next_inner

(&mut self, cx: &mut Context<'_>)

core/iox_v1_query_api/src/response/json.rs:32

↓ 1 callersMethodpoll_next_inner

(&mut self, cx: &mut Context<'_>)

core/iox_v1_query_api/src/response/msgpack.rs:27

↓ 1 callersMethodpost_visit_call

Invoked after all children of a function call are visited.

core/influxdb_influxql_parser/src/visit.rs:564

↓ 1 callersMethodpost_visit_call

Invoked after all children of a function call are visited.

core/influxdb_influxql_parser/src/visit_mut.rs:591

↓ 1 callersMethodpost_visit_conditional_binary

Invoked after all children of a conditional binary expression are visited.

core/influxdb_influxql_parser/src/visit.rs:587

↓ 1 callersMethodpost_visit_conditional_binary

Invoked after all children of a conditional binary expression are visited.

core/influxdb_influxql_parser/src/visit_mut.rs:614

↓ 1 callersMethodpost_visit_conditional_expression

Invoked after all children of the conditional expression are visited.

core/influxdb_influxql_parser/src/visit.rs:285

↓ 1 callersMethodpost_visit_conditional_expression

Invoked after all children of the conditional expression are visited.

core/influxdb_influxql_parser/src/visit_mut.rs:291

↓ 1 callersMethodpost_visit_create_database_statement

Invoked after all children of `n` are visited. Default implementation does nothing.

core/influxdb_influxql_parser/src/visit.rs:92

↓ 1 callersMethodpost_visit_create_database_statement

Invoked after all children of `n` are visited. Default implementation does nothing.

core/influxdb_influxql_parser/src/visit_mut.rs:92

← previous next →4,101–4,200 of 11,906, ranked by callers