Package org.elasticsearch.xpack.esql.datasources.cache
package org.elasticsearch.xpack.esql.datasources.cache
-
ClassDescriptionAccumulates per-column null count + min + max across the pages of a single cold scan.Wraps an
InputStreamand counts the bytes successfully read.Coordinator-only, in-memory cache service for external source metadata.Cluster settings for ESQL external source caching.Serialization vocabulary and value types for external-text aggregate metadata.Per-column statistics.Structured per-file statistics captured during a clean whole-file (or summed-chunk) cold scan.Thread-bound sink for captured per-file source statistics.JVM-wide cache for file footer bytes (Parquet footers, ORC postscripts) shared across columnar format readers.Cache key identifying a file by its storage path and total length.Cache key for file listing results.JVM-wide cache for parsed file metadata (e.g.Cache entry for schema inference results.Cache key for schema inference results.Wraps aCloseableIteratorso the iterator'sclose()runs with anExternalStatsCapturesink bound on the current thread.LRU cache forStorageProviderinstances, keyed by(scheme, config).Cache key that combines the URI scheme with the config map.Supplier invoked on cache miss; returns the provider plus the keys it consumed from config.Shared canonical-stripe statistics harvester for the row-format readers (CSV / TSV / NDJSON).One stripe's running stats: row count + per-column min/max/null.Receives one maximal run of consecutive same-stripe positions[from, to)in a page.Builds aSourceStatisticsfrom a cachedExternalStats.Statsfor the line-oriented text-format readers (CSV / TSV / NDJSON).