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

Public Member Functions
config.ApdbCassandraConfig	to_model (self)

Public Member Functions inherited from lsst.dax.apdb.config.ApdbConfig
ApdbConfig	from_uri (cls, ResourcePathExpression uri)

None	save (self, ResourcePathExpression uri)

Static Public Attributes
	contact_points

	private_ips = ListField[str](doc="List of internal IP addresses for contact_points.", default=[])

	port = Field[int](doc="Port number to connect to.", default=9042)

	keyspace = Field[str](doc="Default keyspace for operations.", default="apdb")

	username

	read_consistency

	write_consistency

	read_timeout = Field[float](doc="Timeout in seconds for read operations.", default=120.0)

	write_timeout = Field[float](doc="Timeout in seconds for write operations.", default=60.0)

	remove_timeout = Field[float](doc="Timeout in seconds for remove operations.", default=600.0)

	read_concurrency = Field[int](doc="Concurrency level for read operations.", default=500)

	protocol_version

	dia_object_columns

	prefix = Field[str](doc="Prefix to add to table names", default="")

	part_pixelization

	part_pix_level = Field[int](doc="Pixelization level used for partitioning index.", default=11)

	part_pix_max_ranges = Field[int](doc="Max number of ranges in pixelization envelope", default=128)

	ra_dec_columns = ListField[str](default=["ra", "dec"], doc="Names of ra/dec columns in DiaObject table")

	timer = Field[bool](doc="If True then print/log timing information", default=False)

	time_partition_tables

	time_partition_days

	time_partition_start

	time_partition_end

	query_per_time_part

	query_per_spatial_part

	use_insert_id_skips_diaobjects

	idle_heartbeat_interval

	idle_heartbeat_timeout

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

◆ contact_points

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.contact_points

static

Initial value:

=  ListField[str](
        doc="The list of contact points to try connecting for cluster discovery.", default=["127.0.0.1"]
    )

◆ dia_object_columns

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.dia_object_columns

static

Initial value:

=  ListField[str](
        doc="List of columns to read from DiaObject[Last], by default read all columns", default=[]
    )

◆ idle_heartbeat_interval

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.idle_heartbeat_interval

static

Initial value:

=  Field[int](
        doc=(
            "Interval, in seconds, on which to heartbeat idle connections. "
            "Zero (default) disables heartbeats."
        ),
        default=0,
    )

◆ idle_heartbeat_timeout

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.idle_heartbeat_timeout

static

Initial value:

=  Field[int](
        doc="Timeout, in seconds, on which the heartbeat wait for idle connection responses.",
        default=30,
    )

◆ part_pixelization

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.part_pixelization

static

Initial value:

=  ChoiceField[str](
        allowed={"htm": "HTM pixelization", "q3c": "Q3C pixelization", "mq3c": "MQ3C pixelization"},
        doc="Pixelization used for partitioning index.",
        default="mq3c",
    )

◆ protocol_version

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.protocol_version

static

Initial value:

=  Field[int](
        doc="Cassandra protocol version to use, default is V4",
        default=cassandra.ProtocolVersion.V4 if CASSANDRA_IMPORTED else 4,
    )

◆ query_per_spatial_part

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.query_per_spatial_part

static

Initial value:

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

◆ query_per_time_part

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.query_per_time_part

static

Initial value:

=  Field[bool](
        default=False,
        doc=(
            "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."
        ),
    )

◆ read_consistency

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.read_consistency

static

Initial value:

=  Field[str](
        doc="Name for consistency level of read operations, default: QUORUM, can be ONE.", default="QUORUM"
    )

◆ time_partition_days

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.time_partition_days

static

Initial value:

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

◆ time_partition_end

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.time_partition_end

static

Initial value:

=  Field[str](
        doc=(
            "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."
        ),
        default="2030-01-01T00:00:00",
    )

◆ time_partition_start

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.time_partition_start

static

Initial value:

=  Field[str](
        doc=(
            "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."
        ),
        default="2018-12-01T00:00:00",
    )

◆ time_partition_tables

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.time_partition_tables

static

Initial value:

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

◆ use_insert_id_skips_diaobjects

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.use_insert_id_skips_diaobjects

static

Initial value:

=  Field[bool](
        default=False,
        doc=(
            "If True then do not store DiaObjects when use_insert_id is True "
            "(DiaObjectsChunks has the same data)."
        ),
    )

◆ username

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.username

static

Initial value:

=  Field[str](
        doc="Cassandra user name, if empty then db-auth.yaml has to provide it with password.",
        default="",
    )

◆ write_consistency

lsst.dax.apdb.cassandra.legacy_config.ApdbCassandraConfig.write_consistency

static

Initial value:

=  Field[str](
        doc="Name for consistency level of write operations, default: QUORUM, can be ONE.", default="QUORUM"
    )

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

python/lsst/dax/apdb/cassandra/legacy_config.py

Public Member Functions

Static Public Attributes

Additional Inherited Members

Detailed Description

Member Data Documentation

◆ contact_points

◆ dia_object_columns

◆ idle_heartbeat_interval

◆ idle_heartbeat_timeout

◆ part_pixelization

◆ protocol_version

◆ query_per_spatial_part

◆ query_per_time_part

◆ read_consistency

◆ time_partition_days

◆ time_partition_end

◆ time_partition_start

◆ time_partition_tables

◆ use_insert_id_skips_diaobjects

◆ username

◆ write_consistency