Struct CompactionTaskEntry 

pub struct CompactionTaskEntry {

    pub task_id: Arc<str>,
    pub region_id: RegionId,
    pub table_id: TableId,
    pub node_id: Option<u64>,
    pub trigger_type: Arc<str>,
    pub state: Arc<str>,
    pub phase: Arc<str>,
    pub submitted_at: i64,
    pub elapsed_millis: u64,
    pub input_files: Option<u64>,
    pub input_bytes: Option<u64>,
    pub total_units: Option<u64>,
    pub completed_units: Option<u64>,
    pub request_options: Arc<str>,
    pub effective_options: Option<Arc<str>>,
    pub input_time_start: Option<Timestamp>,
    pub input_time_end: Option<Timestamp>,
    pub output_time_start: Option<Timestamp>,
    pub output_time_end: Option<Timestamp>,
}

A live region-level compaction cycle. Completed cycles are not retained.

String fields are shared so cloning a snapshot does not copy parameter payloads. Time ranges are envelopes and may contain holes. SQL endpoints are NULL when unknown, unbounded, or outside the representable nanosecond timestamp range.

Fields

task_id: Arc<str>

UUID retained from acceptance until this cycle leaves the scheduler.

region_id: RegionId

Physical region whose scheduler owns this cycle.

table_id: TableId

Physical table ID derived from the region ID.

node_id: Option<u64>

Reporting datanode ID (0 in standalone), not the remote executor ID.

trigger_type: Arc<str>

Whether this cycle was triggered automatically or manually.

state: Arc<str>

Queued, running, or cancelling, aggregated across the cycle.

phase: Arc<str>

Phase label: waiting, planning, executing, committing, or remote.

submitted_at: i64

Acceptance time in milliseconds since the Unix epoch.

elapsed_millis: u64

Monotonic elapsed time since acceptance, including waiting.

input_files: Option<u64>

Distinct plan input files, including expired SSTs; unknown before plan acceptance.

input_bytes: Option<u64>

Total size of plan inputs, including expired SSTs; not bytes processed.

total_units: Option<u64>

Number of local atomic units; unavailable for remote execution.

completed_units: Option<u64>

Local units with a terminal result, including failures.

request_options: Arc<str>

JSON snapshot of request arguments, including requested parallelism.

effective_options: Option<Arc<str>>

JSON snapshot of resolved settings and picker output, if available.

input_time_start: Option<Timestamp>

Inclusive earliest timestamp in plan input SSTs, including expired SSTs.

input_time_end: Option<Timestamp>

Inclusive latest timestamp in plan input SSTs, including expired SSTs.

output_time_start: Option<Timestamp>

Inclusive start of the planned output envelope, not actual output SST bounds.

output_time_end: Option<Timestamp>

Exclusive end of the planned output envelope, not actual output SST bounds.

Implementations

impl CompactionTaskEntry

pub fn schema() -> SchemaRef

Returns the public inspection schema.

pub fn matches(&self, filters: &MetadataFilter) -> bool

Prunes using known values, leaving unsupported predicates to DataFusion.

pub fn to_record_batch(entries: &[Self]) -> Result<DfRecordBatch, ArrowError>

Converts compaction task entries to a record batch.

fn to_projected_record_batch( entries: &[Self], projection: Option<&[usize]>, ) -> Result<DfRecordBatch, ArrowError>

Builds only the requested columns, including empty and repeated projections.

pub fn reserved_table_name_for_inspection() -> &'static str

Internal name, inaccessible through user table resolution.

pub fn build_plan(request: ScanRequest) -> Result<LogicalPlan, DataFusionError>

Builds a remote scan with filtering before projection and limit.

Trait Implementations

impl Clone for CompactionTaskEntry

fn clone(&self) -> CompactionTaskEntry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CompactionTaskEntry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.