empyrean.ADESRadarObservations

class ADESRadarObservations(table, **kwargs)[source]

Bases: Table

ADES radar observations — full schema.

ADES models radar astrometry as its own top-level table, parallel to the optical ADESObservations (not as an optical mode). Each record carries a round-trip time delay or a Doppler shift — the ADES RadarValue is an XSD <choice> — referred to a transmitting (trx) and receiving (rcv) station (equal for a monostatic observation, distinct for a bistatic one).

Units are ADES-native end to end — no conversion is applied in this layer (the single SI normalization happens once downstream):

  • delay — round-trip time delay in seconds

  • rms_delay — its 1σ uncertainty in microseconds (the asymmetry vs delay is intentional in the ADES schema)

  • doppler / rms_doppler — Doppler shift and 1σ in Hz (signed value)

  • frq — transmit carrier reference frequency in MHz

The observable discriminator column ("delay" / "doppler") — not a NaN probe — records which measurement each row carries, so a genuine 0.0-Hz Doppler is never confused with an absent one. The inactive value column is null for that row.

Methods

__init__(table, **kwargs)

apply_mask(mask)

Return a new table with rows filtered to match a boolean mask.

as_column([nullable, metadata])

Embed the Table as a column in another Table.

attributes()

Return a dictionary of the table's attributes.

chunk_counts()

Returns the number of discrete memory chunks that make up each of the Table's underlying arrays.

column(column_name)

Returns the column with the given name as a raw pyarrow ChunkedArray.

delays()

Rows carrying a delay measurement (observable == "delay").

dopplers()

Rows carrying a Doppler measurement (observable == "doppler").

drop_duplicates([subset, keep])

Drop duplicate rows from a ~quivr.Table.

empty(**kwargs)

Create an empty instance of the table.

flattened_table()

Completely flatten the Table's underlying Arrow table, taking into account any nested structure, and return the data table itself.

fragmented()

Returns true if the Table has any fragmented arrays.

from_csv(input_file[, validate])

Read a table from a CSV file.

from_dataframe(df[, validate])

Load a DataFrame into the Table.

from_feather(path[, validate])

Read a table from a Feather file.

from_flat_dataframe(df[, validate])

Load a flattened DataFrame into the Table.

from_kwargs([validate, permit_nulls])

Create a Table instance from keyword arguments.

from_parquet(path[, memory_map, ...])

Read a table from a Parquet file.

from_pyarrow(table[, validate, permit_nulls])

Create a new table from a pyarrow Table.

invalid_mask()

Return a boolean mask indicating which rows are invalid.

is_valid()

Validate the table against the schema.

null_mask()

Return a boolean mask indicating which rows of the entire table are null.

nulls(size, **kwargs)

Create a table with nulls.

select(column_name, value)

Select from the table by exact match, returning a new Table which only contains rows for which the value in column_name equals value.

select_station(codes)

Rows whose receiving station (rcv) is one of codes.

separate_invalid()

Separates rows that have invalid data from those that have valid data.

set_column(name, data)

Return a copy of the table with a particular column replaced with new data.

sort_by(by)

Sorts the Table by the given column name (or multiple columns).

take(row_indices)

Return a new Table with only the rows at the given indices.

to_csv(path[, attribute_columns])

Write the table to a CSV file.

to_dataframe([flatten, attr_handling])

Returns self as a pandas DataFrame.

to_feather(path, **kwargs)

Write the table to a Feather file.

to_parquet(path, **kwargs)

Write the table to a Parquet file.

to_structarray()

Returns self as a StructArray.

unique_indices([subset, keep])

Get the indices of the first or last occurrence of each unique row in the table.

validate()

Validate the table against the schema, raising an exception if invalid.

where(expr)

Return a new table with rows filtered to match an expression.

with_table(table)

Attributes

com

A column for storing booleans.

delay

A column for storing 64-bit floating point numbers.

doppler

A column for storing 64-bit floating point numbers.

frq

A column for storing 64-bit floating point numbers.

log_snr

A column for storing 64-bit floating point numbers.

obs_time

A column for storing large strings (over 231 bytes long).

observable

A column for storing large strings (over 231 bytes long).

perm_id

A column for storing large strings (over 231 bytes long).

prov_id

A column for storing large strings (over 231 bytes long).

rcv

A column for storing large strings (over 231 bytes long).

remarks

A column for storing large strings (over 231 bytes long).

rms_delay

A column for storing 64-bit floating point numbers.

rms_doppler

A column for storing 64-bit floating point numbers.

schema

trk_sub

A column for storing large strings (over 231 bytes long).

trx

A column for storing large strings (over 231 bytes long).

table

Parameters:
  • table (Table)

  • kwargs (AttributeValueType)

perm_id

A column for storing large strings (over 231 bytes long). Large string data is stored in variable-length chunks.

prov_id

A column for storing large strings (over 231 bytes long). Large string data is stored in variable-length chunks.

trk_sub

A column for storing large strings (over 231 bytes long). Large string data is stored in variable-length chunks.

trx

A column for storing large strings (over 231 bytes long). Large string data is stored in variable-length chunks.

rcv

A column for storing large strings (over 231 bytes long). Large string data is stored in variable-length chunks.

obs_time

A column for storing large strings (over 231 bytes long). Large string data is stored in variable-length chunks.

observable

A column for storing large strings (over 231 bytes long). Large string data is stored in variable-length chunks.

delay

A column for storing 64-bit floating point numbers.

rms_delay

A column for storing 64-bit floating point numbers.

doppler

A column for storing 64-bit floating point numbers.

rms_doppler

A column for storing 64-bit floating point numbers.

frq

A column for storing 64-bit floating point numbers.

com

A column for storing booleans.

log_snr

A column for storing 64-bit floating point numbers.

remarks

A column for storing large strings (over 231 bytes long). Large string data is stored in variable-length chunks.

select_station(codes)[source]

Rows whose receiving station (rcv) is one of codes.

Return type:

ADESRadarObservations

Parameters:

codes (str | list[str])

delays()[source]

Rows carrying a delay measurement (observable == "delay").

Return type:

ADESRadarObservations

dopplers()[source]

Rows carrying a Doppler measurement (observable == "doppler").

Return type:

ADESRadarObservations

schema: ClassVar[Schema] = perm_id: large_string prov_id: large_string trk_sub: large_string trx: large_string not null rcv: large_string not null obs_time: large_string not null observable: large_string not null delay: double rms_delay: double doppler: double rms_doppler: double frq: double not null com: bool log_snr: double remarks: large_string