LSST Applications 27.0.0,g0265f82a02+469cd937ee,g02d81e74bb+21ad69e7e1,g1470d8bcf6+cbe83ee85a,g2079a07aa2+e67c6346a6,g212a7c68fe+04a9158687,g2305ad1205+94392ce272,g295015adf3+81dd352a9d,g2bbee38e9b+469cd937ee,g337abbeb29+469cd937ee,g3939d97d7f+72a9f7b576,g487adcacf7+71499e7cba,g50ff169b8f+5929b3527e,g52b1c1532d+a6fc98d2e7,g591dd9f2cf+df404f777f,g5a732f18d5+be83d3ecdb,g64a986408d+21ad69e7e1,g858d7b2824+21ad69e7e1,g8a8a8dda67+a6fc98d2e7,g99cad8db69+f62e5b0af5,g9ddcbc5298+d4bad12328,ga1e77700b3+9c366c4306,ga8c6da7877+71e4819109,gb0e22166c9+25ba2f69a1,gb6a65358fc+469cd937ee,gbb8dafda3b+69d3c0e320,gc07e1c2157+a98bf949bb,gc120e1dc64+615ec43309,gc28159a63d+469cd937ee,gcf0d15dbbd+72a9f7b576,gdaeeff99f8+a38ce5ea23,ge6526c86ff+3a7c1ac5f1,ge79ae78c31+469cd937ee,gee10cc3b42+a6fc98d2e7,gf1cff7945b+21ad69e7e1,gfbcc870c63+9a11dc8c8f
LSST Data Management Base Package
|
Public Member Functions | |
__init__ (self, ApdbCassandra apdb, ApdbCassandraSchema schema, Any session) | |
VersionTuple | apdbReplicaImplementationVersion (cls) |
list[ReplicaChunk]|None | getReplicaChunks (self) |
None | deleteReplicaChunks (self, Iterable[int] chunks) |
ApdbTableData | getDiaObjectsChunks (self, Iterable[int] chunks) |
ApdbTableData | getDiaSourcesChunks (self, Iterable[int] chunks) |
ApdbTableData | getDiaForcedSourcesChunks (self, Iterable[int] chunks) |
Protected Member Functions | |
ApdbTableData | _get_chunks (self, ExtraTables table, Iterable[int] chunks) |
Protected Attributes | |
_apdb | |
_schema | |
_session | |
_config | |
_preparer | |
Implementation of `ApdbReplica` for Cassandra backend. Parameters ---------- apdb : `ApdbCassandra` Instance of ApbdCassandra for database. schema : `ApdbCassandraSchema` Instance of ApdbCassandraSchema for database. session Instance of cassandra session type.
Definition at line 51 of file apdbCassandraReplica.py.
lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica.__init__ | ( | self, | |
ApdbCassandra | apdb, | ||
ApdbCassandraSchema | schema, | ||
Any | session ) |
Definition at line 64 of file apdbCassandraReplica.py.
|
protected |
Return records from a particular table given set of insert IDs.
Definition at line 165 of file apdbCassandraReplica.py.
VersionTuple lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica.apdbReplicaImplementationVersion | ( | cls | ) |
Return version number for current ApdbReplica implementation. Returns ------- version : `VersionTuple` Version of the code defined in implementation class.
Reimplemented from lsst.dax.apdb.apdbReplica.ApdbReplica.
Definition at line 76 of file apdbCassandraReplica.py.
None lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica.deleteReplicaChunks | ( | self, | |
Iterable[int] | chunks ) |
Remove replication chunks from the database. Parameters ---------- chunks : `~collections.abc.Iterable` [`int`] Chunk identifiers to remove. Notes ----- This method causes Apdb to forget about specified chunks. If there are any auxiliary data associated with the identifiers, it is also removed from database (but data in regular tables is not removed). This method should be called after successful transfer of data from APDB to PPDB to free space used by replicas.
Reimplemented from lsst.dax.apdb.apdbReplica.ApdbReplica.
Definition at line 112 of file apdbCassandraReplica.py.
ApdbTableData lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica.getDiaForcedSourcesChunks | ( | self, | |
Iterable[int] | chunks ) |
Return catalog of DiaForcedSource records from given replica chunks. Parameters ---------- chunks : `~collections.abc.Iterable` [`int`] Chunk identifiers to return. Returns ------- data : `ApdbTableData` Catalog containing DiaForcedSource records. In addition to all regular columns it will contain ``apdb_replica_chunk`` column. Notes ----- This part of API may not be very stable and can change before the implementation finalizes.
Reimplemented from lsst.dax.apdb.apdbReplica.ApdbReplica.
Definition at line 161 of file apdbCassandraReplica.py.
ApdbTableData lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica.getDiaObjectsChunks | ( | self, | |
Iterable[int] | chunks ) |
Return catalog of DiaObject records from given replica chunks. Parameters ---------- chunks : `~collections.abc.Iterable` [`int`] Chunk identifiers to return. Returns ------- data : `ApdbTableData` Catalog containing DiaObject records. In addition to all regular columns it will contain ``apdb_replica_chunk`` column. Notes ----- This part of API may not be very stable and can change before the implementation finalizes.
Reimplemented from lsst.dax.apdb.apdbReplica.ApdbReplica.
Definition at line 153 of file apdbCassandraReplica.py.
ApdbTableData lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica.getDiaSourcesChunks | ( | self, | |
Iterable[int] | chunks ) |
Return catalog of DiaSource records from given replica chunks. Parameters ---------- chunks : `~collections.abc.Iterable` [`int`] Chunk identifiers to return. Returns ------- data : `ApdbTableData` Catalog containing DiaSource records. In addition to all regular columns it will contain ``apdb_replica_chunk`` column. Notes ----- This part of API may not be very stable and can change before the implementation finalizes.
Reimplemented from lsst.dax.apdb.apdbReplica.ApdbReplica.
Definition at line 157 of file apdbCassandraReplica.py.
list[ReplicaChunk] | None lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica.getReplicaChunks | ( | self | ) |
Return collection of replication chunks known to the database. Returns ------- chunks : `list` [`ReplicaChunk`] or `None` List of chunks, they may be time-ordered if database supports ordering. `None` is returned if database is not configured for replication.
Reimplemented from lsst.dax.apdb.apdbReplica.ApdbReplica.
Definition at line 80 of file apdbCassandraReplica.py.
|
protected |
Definition at line 67 of file apdbCassandraReplica.py.
|
protected |
Definition at line 70 of file apdbCassandraReplica.py.
|
protected |
Definition at line 73 of file apdbCassandraReplica.py.
|
protected |
Definition at line 68 of file apdbCassandraReplica.py.
|
protected |
Definition at line 69 of file apdbCassandraReplica.py.