BaseChunking

class ctapipe.monitoring.aggregator.BaseChunking(*args: t.Any, **kwargs: t.Any)

Bases: Component

Abstract base class for chunking strategies.

Chunking components divide tables into overlapping or non-overlapping chunks for processing by aggregators.

Attributes Summary

allow_undersized_tables	If True, allow processing tables smaller than chunk size/duration by yielding the entire table as a single chunk.
last_chunk_policy	Policy for handling the last chunk when data doesn't divide evenly.

Methods Summary

__call__(table)

Generate chunks from the input table.

Attributes Documentation

allow_undersized_tables

If True, allow processing tables smaller than chunk size/duration by yielding the entire table as a single chunk. If False, raise an error.

last_chunk_policy

Policy for handling the last chunk when data doesn’t divide evenly. ‘overlap’: Create overlapping chunk with full size (default behavior). ‘truncate’: Yield remaining data as smaller chunk. ‘skip’: Skip the last partial chunk.

Methods Documentation

__call__(table) → Generator[Table, None, None]

Generate chunks from the input table.

Parameters:

tableastropy.table.Table

Input table with ‘time’ column.

Yields:

astropy.table.Table

Chunks of the input table. Each chunk is a view/reference to the original table data, meaning modifications to chunk data will affect the original table.