katcbf_vlbi_resample.rechunk module

Split and combine chunks to align in time.

class katcbf_vlbi_resample.rechunk.Rechunk(input_data: Stream[DataArray], samples_per_chunk: int, remainder: int = 0, *, partial: bool = False)

Bases: object

Split and combine chunks to align in time.

Note that this requires the incoming stream to be contiguous in time.

Parameters:

• input_data – Incoming data stream.

• samples_per_chunk – Number of samples per chunk. The time_bias of the first sample index in each chunk will be a multiple of this plus remainder.

• remainder – See samples_per_chunk.

• partial – If set to true, partial chunks at the start and end may be emitted.

classmethod align_utc_seconds(it: Stream[DataArray]) → Self

Create an instance that aligns chunks to UTC seconds.

The alignment is done as closely as possible, rounding to the nearest sample.

The alignment will not be possible if the sample rate is not an integer number of Hz (the alignment will drift over time). In this case, a warning will be printed.