lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig Class Reference

Inheritance diagram for lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig:

Public Member Functions
str	check_pixelization (cls, str v)

Static Public Attributes
str	part_pixelization
int	part_pix_level
int	part_pix_max_ranges
bool	time_partition_tables
int	time_partition_days
str	time_partition_start
str	time_partition_end
bool	query_per_time_part
bool	query_per_spatial_part

Detailed Description

Partitioning configuration for Cassandra APDB.

Definition at line 112 of file config.py.

Member Function Documentation

check_pixelization()

str lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.check_pixelization	(		cls,
		str	v )

Definition at line 174 of file config.py.

    def check_pixelization(cls, v: str) -> str:
        allowed = {"htm", "q3c", "mq3c", "healpix"}
        if v not in allowed:
            raise ValueError(f"Unexpected value for part_pixelization: {v}, allowed values: {allowed}")
        return v
 
 

Member Data Documentation

part_pix_level

int lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.part_pix_level

static

Initial value:

=  Field(
        default=11,
        description="Pixelization level used for partitioning index.",
    )

Definition at line 120 of file config.py.

part_pix_max_ranges

int lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.part_pix_max_ranges

static

Initial value:

=  Field(
        default=128,
        description="Max number of ranges in pixelization envelope",
    )

Definition at line 125 of file config.py.

part_pixelization

str lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.part_pixelization

static

Initial value:

=  Field(
        default="mq3c",
        description="Pixelization used for partitioning index.",
    )

Definition at line 115 of file config.py.

query_per_spatial_part

bool lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.query_per_spatial_part

static

Initial value:

=  Field(
        default=False,
        description="If True then build one query per spatial partition, otherwise build single query.",
    )

Definition at line 167 of file config.py.

query_per_time_part

bool lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.query_per_time_part

static

Initial value:

=  Field(
        default=False,
        description=(
            "If True then build separate query for each time partition, otherwise build one single query. "
            "This is only used when time_partition_tables is False in schema config."
        ),
    )

Definition at line 159 of file config.py.

time_partition_days

int lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.time_partition_days

static

Initial value:

=  Field(
        default=30,
        description=(
            "Time partitioning granularity in days, this value must not be changed after database is "
            "initialized"
        ),
    )

Definition at line 135 of file config.py.

time_partition_end

str lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.time_partition_end

static

Initial value:

=  Field(
        default="2030-01-01T00:00:00",
        description=(
            "Ending time for per-partition tables, in yyyy-mm-ddThh:mm:ss format, in TAI. "
            "This is used only when time_partition_tables is True."
        ),
    )

Definition at line 151 of file config.py.

time_partition_start

str lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.time_partition_start

static

Initial value:

=  Field(
        default="2018-12-01T00:00:00",
        description=(
            "Starting time for per-partition tables, in yyyy-mm-ddThh:mm:ss format, in TAI. "
            "This is used only when time_partition_tables is True."
        ),
    )

Definition at line 143 of file config.py.

time_partition_tables

bool lsst.dax.apdb.cassandra.config.ApdbCassandraPartitioningConfig.time_partition_tables

static

Initial value:

=  Field(
        default=False,
        description="Use per-partition tables for sources instead of partitioning by time",
    )

Definition at line 130 of file config.py.

---

The documentation for this class was generated from the following file:

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-12.1.0/Linux/dax_apdb/gb88ae4c679+7dec8f19df/python/lsst/dax/apdb/cassandra/config.py