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

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

Public Member Functions
tuple[str, str]	check_ra_dec (cls, Iterable[str] v)
Public Member Functions inherited from lsst.dax.apdb.config.ApdbConfig
ApdbConfig	from_uri (cls, ResourcePathExpression uri)
None	save (self, ResourcePathExpression uri)

Static Public Attributes
tuple	contact_points
str	keyspace
ApdbCassandraConnectionConfig	connection_config
ApdbCassandraPartitioningConfig	partitioning
list	dia_object_columns
str	prefix
tuple	ra_dec_columns
bool	replica_skips_diaobjects
int	replica_sub_chunk_count
int	batch_statement_limit
int	batch_size_limit
Static Public Attributes inherited from lsst.dax.apdb.config.ApdbConfig
str	schema_file
str	ss_schema_file
str	schema_name
int	read_sources_months
int	read_forced_sources_months
bool	enable_replica
int	replica_chunk_seconds

Additional Inherited Members
Static Protected Attributes inherited from lsst.dax.apdb.config.ApdbConfig
ClassVar	_implementation_type [str]

Detailed Description

Configuration class for Cassandra-based APDB implementation.

Member Data Documentation

batch_size_limit

int lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.batch_size_limit

static

Initial value:

=  Field(
        default=1_000_000,
        description=(
            "Limit on a size of BatchStatement in bytes. Batch size is estimated approximately. "
            "Set to 0 or negative to disable this limit. "
            "Server-side batch size warning threshold needs to be set to at least this value."
        ),
    )

batch_statement_limit

int lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.batch_statement_limit

static

Initial value:

=  Field(
        default=65_535,
        description=(
            "Limit on a number of rows in a BatchStatement. Default is the same as Cassandra limit of 65535."
        ),
    )

connection_config

ApdbCassandraConnectionConfig lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.connection_config

static

Initial value:

=  Field(
        default_factory=ApdbCassandraConnectionConfig,
        description="Database connection configuration",
    )

contact_points

tuple lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.contact_points

static

Initial value:

=  Field(
        default=("127.0.0.1",),
        description="The list of contact points to try connecting for cluster discovery.",
    )

dia_object_columns

list lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.dia_object_columns

static

Initial value:

=  Field(
        default=[],
        description="List of columns to read from DiaObject[Last], by default read all columns.",
    )

keyspace

str lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.keyspace

static

Initial value:

=  Field(
        default="apdb",
        description="Keyspace name for APDB tables.",
    )

partitioning

ApdbCassandraPartitioningConfig lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.partitioning

static

Initial value:

=  Field(
        default_factory=ApdbCassandraPartitioningConfig,
        description="Configuration for partitioning.",
    )

prefix

str lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.prefix

static

Initial value:

=  Field(
        default="",
        description="Prefix to add to table names.",
    )

ra_dec_columns

tuple lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.ra_dec_columns

static

Initial value:

=  Field(
        default=("ra", "dec"),
        description="Names of ra/dec columns in DiaObject table",
    )

replica_skips_diaobjects

bool lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.replica_skips_diaobjects

static

Initial value:

=  Field(
        default=False,
        description=(
            "If True then do not store DiaObjects when enable_replica is True "
            "(DiaObjectsChunks has the same data)."
        ),
    )

replica_sub_chunk_count

int lsst.dax.apdb.cassandra.config.ApdbCassandraConfig.replica_sub_chunk_count

static

Initial value:

=  Field(
        default=64,
        description="Number of sub-partitions in replica chunk tables.",
    )

---

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

• python/lsst/dax/apdb/cassandra/config.py