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

Functionsingle_chunk

()

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

Functionsingle_chunk

()

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

Functionsingle_chunk

()

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

Functionsingle_chunk_exponential_value

()

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

Functionsingle_chunk_infinite_value

()

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

Functionsingle_chunk_pretty

()

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

Functionsingle_statement_infinite_value

()

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

Functionsingle_statement_multi_series

()

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

Functionsingle_statement_no_group

()

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

Functionsingle_statement_single_series

()

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

Functionsingle_statement_tag_group

()

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

Functionsingle_statement_tag_group_multiple_tags

()

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

Functionsingle_statement_tag_group_projected

()

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

Methodsize

(&self)

core/iox_query_influxql/src/aggregate/spread.rs:146

Methodsize

(&self)

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

Methodsize

(&self)

core/iox_query_influxql/src/aggregate/mode.rs:231

Methodsize

(&self)

core/object_store_mem_cache/src/cache_system/mod.rs:48

Methodsize

Estimate the memory consumption of this object and its contents

core/parquet_file/src/metadata.rs:502

Methodsize

(&self)

core/query_functions/src/selectors/internal.rs:317

Methodsize

Return the amount of memory in bytes taken up by this array

core/arrow_util/src/string.rs:146

Methodsize

(&self)

core/arrow_util/src/dictionary.rs:116

Methodsize

Size in bytes including `Self`.

core/data_types/src/partition.rs:425

Methodsize

Estimated Size in bytes including `self`.

core/data_types/src/lib.rs:674

Methodsize

Estimate the memory consumption of this object and its contents

core/data_types/src/columns.rs:623

Methodsize

Size in bytes, including `self`. This accounts for the entire allocation of this object, even when it shared (via an internal [`Arc`]).

core/data_types/src/partition_template.rs:765

Methodsize

Return the approximate memory size of the span, in bytes. This includes `Self`.

core/trace/src/ctx.rs:102

Methodsize

Return the approximate memory size of the batch, in bytes. This includes `Self`.

core/mutable_batch/src/lib.rs:248

Methodsize

(&self)

influxdb3_cache/src/last_cache/provider.rs:374

Methodsize_data

Return the approximate memory size of the data in the batch, in bytes.

core/mutable_batch/src/lib.rs:259

Methodsize_data

The approximate memory size of the data in the column, not counting for stats or self or whatever extra space has been allocated for the vecs

core/mutable_batch/src/column.rs:217

Functionsize_data_with_nulls

()

core/mutable_batch/src/lib.rs:308

Functionsize_data_without_nulls

()

core/mutable_batch/src/lib.rs:286

Methodsize_hint

(&self)

core/catalog_cache/src/api/list/v2.rs:75

Methodsize_hint

(&self)

core/catalog_cache/src/local/mod.rs:210

Methodsize_hint

(&self)

core/arrow_util/src/bitset.rs:308

Methodsize_hint

(&self)

core/arrow_util/src/string.rs:225

Methodsize_hint

(&self)

core/service_grpc_flight/src/observer.rs:128

Methodsize_hint

(&self)

core/object_store_metrics/src/stream.rs:204

Methodsize_hint

(&self)

core/datafusion_util/src/lib.rs:210

Methodsize_hint

(&self)

core/iox_v1_query_api/src/response.rs:301

Methodsize_hint

(&self)

core/data_types/src/snapshot/list.rs:256

Methodsize_hint

(&self)

core/trace_http/src/tower.rs:371

Methodsize_hint

(&self)

core/tower_trailer/src/lib.rs:126

Methodsize_hint

(&self)

object_store_limit/src/lib.rs:264

Methodskipped_compaction

Return skipped compaction for this partition, if any.

core/data_types/src/snapshot/partition.rs:258

Methodskipped_compactions

List all skipped compactions

core/influxdb_iox_client/src/client/compactor.rs:26

Functionskips_below_threshold

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1014

Functionskips_when_no_records

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1039

Methodsleep

Sleep for the given duration.

core/iox_time/src/lib.rs:179

Functionslice_clone

()

core/linear_buffer/src/linear_buffer.rs:411

Functionslice_debug

()

core/linear_buffer/src/linear_buffer.rs:438

Functionslice_lines_and_check

(lines: Vec<ParsedLine<'static>>, ranges: &[Range<usize>])

core/partition/src/lib.rs:1792

Methodslice_record_batch

Create a new record batch from offset --> len

core/iox_query/src/provider/deduplicate/algo.rs:373

Functionslice_values

This is the core partitioning function that pulls values from `original`, based on the ranges in `ranges`, and produces a [`Builder::Output`] from the

core/table_batch/src/builder/mod.rs:159

Functionslice_values_with_temporary_nonnulls

()

core/table_batch/src/builder/mod.rs:333

Functionslice_values_works

()

core/table_batch/src/builder/mod.rs:292

Functionslices_are_zero_copy

()

core/linear_buffer/src/linear_buffer.rs:376

Functionslimit_clause

Parse a series limit (`SLIMIT <n>`) clause. ```text slimit_clause ::= "SLIMIT" unsigned_integer ```

core/influxdb_influxql_parser/src/select.rs:742

Functionsmall_payload_takes_single_part_branch

()

object_store_utils/src/adaptive_put.rs:149

Methodsnapshot

Create a snapshot of the locked state. This function serializes the [`S3Fifo`] inner state using bincode, allowing for persistence and recovery of th

core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:511

Methodsnapshot

(&self)

influxdb3_catalog/src/catalog/versions/v1.rs:178

Functionsnapshot_checkpoint_path_new

()

influxdb3_write/src/paths/test.rs:358

Functionsnapshot_checkpoint_path_parse_sequence_number

()

influxdb3_write/src/paths/test.rs:387

Functionsnapshot_checkpoint_path_parse_year_month

()

influxdb3_write/src/paths/test.rs:367

Functionsnapshot_full_decodes_records

()

influxdb3_commands/src/debug/catalog/tests.rs:129

Functionsnapshot_future_data_forces_snapshot

()

influxdb3_wal/src/snapshot_tracker/tests.rs:85

Functionsnapshot_header_round_trip

()

influxdb3_catalog/src/format/header/tests.rs:31

Functionsnapshot_info_file_path_new

()

influxdb3_write/src/paths.rs:568

Functionsnapshot_payload_parses_like_log

()

influxdb3_catalog/src/format/reader/tests.rs:198

Functionsnapshot_rejects_corrupt_payload_crc

()

influxdb3_catalog/src/format/reader/tests.rs:278

Functionsnapshot_rejects_record_count_exceeding_payload

()

influxdb3_catalog/src/format/reader/tests.rs:291

Functionsnapshot_rejects_truncated_payload

()

influxdb3_catalog/src/format/reader/tests.rs:265

Functionsnapshot_round_trip_preserves_application_order_and_sequences

()

influxdb3_catalog/src/format/apply/tests.rs:345

Functionsnapshot_round_trip_replays_into_fresh_catalog

()

influxdb3_catalog/src/format/apply/tests.rs:381

Functionsnapshot_skips_deleted_table

()

influxdb3_write/src/write_buffer/queryable_buffer/tests.rs:218

Functionsnapshot_summary_has_histogram

()

influxdb3_commands/src/debug/catalog/tests.rs:112

Functionsnapshot_works_with_not_all_columns_in_buffer

()

influxdb3_write/src/write_buffer/queryable_buffer/tests.rs:20

Functionsoffset_clause

Parse a series offset (`SOFFSET <n>`) clause. ```text soffset_clause ::= "SOFFSET" unsigned_integer ```

core/influxdb_influxql_parser/src/select.rs:770

Methodsoft_delete_database

( &self, db_name: &str, hard_delete_time: HardDeletionTime, )

influxdb3_catalog/src/catalog/versions/v1/update.rs:263

Functionsoft_delete_database_cascade_table_name_collision_keeps_repo_consistent

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3050

Functionsoft_delete_database_round_trip

()

influxdb3_catalog/src/format/records/database/tests.rs:43

Functionsoft_delete_internal_database_is_rejected

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2864

Functionsoft_delete_missing_table_returns_table_not_found

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3080

Functionsoft_delete_same_second_collision_survives_reload

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3065

Functionsoft_delete_same_second_db_name_collision_keeps_repo_consistent

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2791

Functionsoft_delete_same_second_name_collision_keeps_repo_consistent

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3036

Methodsoft_delete_table

Soft delete a table

core/influxdb_iox_client/src/client/table.rs:89

Methodsoft_delete_table

( &self, db_name: &str, table_name: &str, hard_delete_time: HardDeletionTime,

influxdb3_catalog/src/catalog/versions/v1/update.rs:354

Functionsoft_delete_table_round_trip

()

influxdb3_catalog/src/format/records/table/tests.rs:49

Functionsoft_delete_then_hard_delete

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2804

Functionsoft_deleted_database_emits_soft_delete_after_create

()

influxdb3_catalog/src/catalog/migrations/v3/tests.rs:389

Functionsoft_deleted_database_recovers_name_and_timestamp_from_suffix

()

influxdb3_catalog/src/catalog/migrations/v3/tests.rs:416

Functionsoft_deleted_table_emits_soft_delete_with_recovered_deletion_timestamp

()

influxdb3_catalog/src/catalog/migrations/v3/tests.rs:835

Functionsome_columns_not_defined

()

core/predicate/src/rpc_predicate/column_rewrite.rs:68

Methodsort_deterministically_for_testing

Purely for testing. sort the columns deterministically, so that we can compare two created through different methods.

core/mutable_batch/src/lib.rs:265

Functionsort_key

(col_name: &str, schema: &Schema)

core/iox_query/benches/deduplicate.rs:210

Methodsort_key

(&self)

influxdb3_write/src/chunk.rs:36

Methodsort_key

(&self)

core/iox_query/src/ingester.rs:231

Methodsort_key

The sort key containing the column names found in the specified column map. # Panics Will panic if an ID isn't found in the column map.

core/data_types/src/partition.rs:602

Functionsort_record_batch

sort a record batch by all columns (to provide a stable output order for test comparison)

core/arrow_util/src/test_util.rs:112

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