lsst.dax.apdb g9290983e33+ffdc83c6f7
 
Loading...
Searching...
No Matches
lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra Member List

This is the complete list of members for lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra, including all inherited members.

__init__(self, ApdbCassandraConfig config) (defined in lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
_add_apdb_part(self, pandas.DataFrame df)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_batch_size(self, ApdbTables|ExtraTables table)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_check_time_partitions(self, Iterable[int] partitions, ApdbCassandraTimePartitionRange time_partitions_range)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_combine_where(self, str prefix, list[tuple[str, tuple]] where1, list[tuple[str, tuple]] where2, tuple[str, tuple]|None where3=None, str|None suffix=None)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_config (defined in lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_connection_context (defined in lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_context(self)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_deleteMovingObjects(self, pandas.DataFrame objs)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_fix_input_timestamps(self, pandas.DataFrame df)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_getSources(self, sphgeom.Region region, Iterable[int]|None object_ids, float mjd_start, float mjd_end, ApdbTables table_name)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_keyspace (defined in lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_make_empty_catalog(self, ApdbTables table_name)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_makeSchema(cls, ApdbConfig config, *, bool drop=False, int|None replication_factor=None, CreateTableOptions|None table_options=None) (defined in lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_queryDiaObjectLastPartitions(self, Iterable[int] ids)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_schema (defined in lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_session_factory (defined in lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_storeDiaObjects(self, pandas.DataFrame objs, astropy.time.Time visit_time, ReplicaChunk|None replica_chunk)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_storeDiaSources(self, ApdbTables table_name, pandas.DataFrame sources, ReplicaChunk|None replica_chunk)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_storeDiaSourcesPartitions(self, pandas.DataFrame sources, astropy.time.Time visit_time, ReplicaChunk|None replica_chunk, int|None subchunk)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_storeObjectsPandas(self, pandas.DataFrame records, ApdbTables|ExtraTables table_name, Mapping|None extra_columns=None, int|None time_part=None)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_storeReplicaChunk(self, ReplicaChunk replica_chunk) (defined in lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_storeUpdateRecords(self, Iterable[ApdbUpdateRecord] records, ReplicaChunk chunk, *, bool store_chunk=False)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_timer(self, str name, *, Mapping[str, str|int]|None tags=None)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
_versionCheck(self, DbVersions current_versions, DbVersions db_versions)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraprotected
admin(self)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
apdbImplementationVersion(cls)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
containsVisitDetector(self, int visit, int detector, sphgeom.Region region, astropy.time.Time visit_time)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
countUnassociatedObjects(self)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
dailyJob(self)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
from_config(cls, ApdbConfig config)lsst.dax.apdb.apdb.Apdb
from_uri(cls, ResourcePathExpression uri)lsst.dax.apdb.apdb.Apdb
get_replica(self)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
getConfig(self)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
getDiaForcedSources(self, sphgeom.Region region, Iterable[int]|None object_ids, astropy.time.Time visit_time, astropy.time.Time|None start_time=None)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
getDiaObjects(self, sphgeom.Region region)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
getDiaSources(self, sphgeom.Region region, Iterable[int]|None object_ids, astropy.time.Time visit_time, astropy.time.Time|None start_time=None)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
init_database(cls, tuple[str,...] hosts, str keyspace, *, str|None schema_file=None, str|None ss_schema_file=None, int|None read_sources_months=None, int|None read_forced_sources_months=None, bool enable_replica=False, bool replica_skips_diaobjects=False, int|None port=None, str|None username=None, str|None prefix=None, str|None part_pixelization=None, int|None part_pix_level=None, bool time_partition_tables=True, str|None time_partition_start=None, str|None time_partition_end=None, str|None read_consistency=None, str|None write_consistency=None, int|None read_timeout=None, int|None write_timeout=None, tuple[str, str]|None ra_dec_columns=None, int|None replication_factor=None, bool drop=False, CreateTableOptions|None table_options=None)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
metadata(self)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
reassignDiaSources(self, Mapping[int, int] idMap)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
store(self, astropy.time.Time visit_time, pandas.DataFrame objects, pandas.DataFrame|None sources=None, pandas.DataFrame|None forced_sources=None)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra
tableDef(self, ApdbTables table)lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandra