lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables Class Reference

Inheritance diagram for lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables:

Public Member Functions
str	table_name (self, str prefix="", int|None time_partition=None)
Mapping[ApdbTables, ExtraTables]	replica_chunk_tables (cls, bool has_subchunks)

Static Public Attributes
str	ApdbReplicaChunks = "ApdbReplicaChunks"
str	DiaObjectChunks = "DiaObjectChunks"
str	DiaSourceChunks = "DiaSourceChunks"
str	DiaForcedSourceChunks = "DiaForcedSourceChunks"
str	DiaObjectChunks2 = "DiaObjectChunks2"
str	DiaSourceChunks2 = "DiaSourceChunks2"
str	DiaForcedSourceChunks2 = "DiaForcedSourceChunks2"
str	ApdbUpdateRecordChunks = "ApdbUpdateRecordChunks"
str	DiaSourceToPartition = "DiaSourceToPartition"
str	DiaObjectLastToPartition = "DiaObjectLastToPartition"
str	ApdbVisitDetector = "ApdbVisitDetector"

Detailed Description

Names of the extra tables used by Cassandra implementation.

Chunk tables exist in two versions now to support both old and new schema.
Eventually we will drop support for old tables.

Definition at line 82 of file apdbCassandraSchema.py.

Member Function Documentation

replica_chunk_tables()

Mapping[ApdbTables, ExtraTables] lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.replica_chunk_tables	(		cls,
		bool	has_subchunks )

Return mapping of APDB tables to corresponding replica chunks
tables.

Definition at line 136 of file apdbCassandraSchema.py.

    def replica_chunk_tables(cls, has_subchunks: bool) -> Mapping[ApdbTables, ExtraTables]:
        """Return mapping of APDB tables to corresponding replica chunks
        tables.
        """
        if has_subchunks:
            return {
                ApdbTables.DiaObject: cls.DiaObjectChunks2,
                ApdbTables.DiaSource: cls.DiaSourceChunks2,
                ApdbTables.DiaForcedSource: cls.DiaForcedSourceChunks2,
            }
        else:
            return {
                ApdbTables.DiaObject: cls.DiaObjectChunks,
                ApdbTables.DiaSource: cls.DiaSourceChunks,
                ApdbTables.DiaForcedSource: cls.DiaForcedSourceChunks,
            }
 
 

table_name()

str lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.table_name	(		self,
		str	prefix = "",
		int | None	time_partition = None )

Return full table name.

Parameters
----------
prefix : `str`, optional
    Optional prefix for table name.
time_partition : `int`, optional
    Optional time partition, only used for tables that support time
    patitioning.

Definition at line 122 of file apdbCassandraSchema.py.

    def table_name(self, prefix: str = "", time_partition: int | None = None) -> str:
        """Return full table name.
 
        Parameters
        ----------
        prefix : `str`, optional
            Optional prefix for table name.
        time_partition : `int`, optional
            Optional time partition, only used for tables that support time
            patitioning.
        """
        return f"{prefix}{self.value}"
 

Member Data Documentation

ApdbReplicaChunks

str lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.ApdbReplicaChunks = "ApdbReplicaChunks"

static

Definition at line 89 of file apdbCassandraSchema.py.

ApdbUpdateRecordChunks

str lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.ApdbUpdateRecordChunks = "ApdbUpdateRecordChunks"

static

Definition at line 110 of file apdbCassandraSchema.py.

ApdbVisitDetector

str lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.ApdbVisitDetector = "ApdbVisitDetector"

static

Definition at line 119 of file apdbCassandraSchema.py.

DiaForcedSourceChunks

lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.DiaForcedSourceChunks = "DiaForcedSourceChunks"

static

Definition at line 98 of file apdbCassandraSchema.py.

DiaForcedSourceChunks2

lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.DiaForcedSourceChunks2 = "DiaForcedSourceChunks2"

static

Definition at line 107 of file apdbCassandraSchema.py.

DiaObjectChunks

lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.DiaObjectChunks = "DiaObjectChunks"

static

Definition at line 92 of file apdbCassandraSchema.py.

DiaObjectChunks2

lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.DiaObjectChunks2 = "DiaObjectChunks2"

static

Definition at line 101 of file apdbCassandraSchema.py.

DiaObjectLastToPartition

str lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.DiaObjectLastToPartition = "DiaObjectLastToPartition"

static

Definition at line 116 of file apdbCassandraSchema.py.

DiaSourceChunks

lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.DiaSourceChunks = "DiaSourceChunks"

static

Definition at line 95 of file apdbCassandraSchema.py.

DiaSourceChunks2

lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.DiaSourceChunks2 = "DiaSourceChunks2"

static

Definition at line 104 of file apdbCassandraSchema.py.

DiaSourceToPartition

str lsst.dax.apdb.cassandra.apdbCassandraSchema.ExtraTables.DiaSourceToPartition = "DiaSourceToPartition"

static

Definition at line 113 of file apdbCassandraSchema.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/apdbCassandraSchema.py