LSST Applications: /j/snowflake/release/lsstsw/stack/lsst-scipipe-12.2.0/Linux64/dax_apdb/g9290983e33+ffdc83c6f7/python/lsst/dax/apdb/cassandra/cassandra_utils.py File Reference

LSST Applications 30.0.7,g0e76e35be5+e8e946ae08,g19811a7679+138f7293ba,g199a45376c+5e234f8357,g1fd858c14a+2f48dbc4c4,g262e1987ae+fb36cac54d,g29ae962dfc+d9108a0941,g2c21b0017a+4f59a27f16,g31e44d4a5c+b0138be388,g33ac35c1f1+28b9f72785,g35bb328faa+b0138be388,g40c9b15c53+823ad735c1,g47891489e3+bcc48a0b46,g53246c7159+b0138be388,g64539dfbff+e8e946ae08,g67b6fd64d1+bcc48a0b46,g74acd417e5+422380537a,g76965917b2+a5ca99c4d9,g786e29fd12+796b79145d,g7aefaa3e3d+dc0c200193,g86b635cae8+734fe384f0,g87389fa792+d8b5378923,g89139ef638+bcc48a0b46,g8bbb235e95+3f4f7f9447,g8ea07a8fe4+78a4c88802,g9290983e33+ffdc83c6f7,g92c671f44c+e8e946ae08,gaa753fd333+03f406da14,gbf99507273+b0138be388,gc49b57b85e+8df26ee1f0,gca7fc764a6+bcc48a0b46,gd7ef33dd92+bcc48a0b46,gdab6d2f7ff+422380537a,ge1c02a5578+b0138be388,ge410e46f29+bcc48a0b46,ge80df9fc40+e6db5413d1,geaed405ab2+1de65a85c6,gf5dcc679e7+35a0ce2edd,gf5f1c85443+e8e946ae08

LSST Data Management Base Package

Loading...

Searching...

No Matches

Go to the source code of this file.

Classes
class	lsst.dax.apdb.cassandra.cassandra_utils.ApdbCassandraTableData

class	lsst.dax.apdb.cassandra.cassandra_utils.PreparedStatementCache

Namespaces
namespace	lsst

namespace	lsst.dax

namespace	lsst.dax.apdb

namespace	lsst.dax.apdb.cassandra

namespace	lsst.dax.apdb.cassandra.cassandra_utils

Functions
pandas.DataFrame	lsst.dax.apdb.cassandra.cassandra_utils.pandas_dataframe_factory (list[str] colnames, list[tuple] rows)

ApdbCassandraTableData	lsst.dax.apdb.cassandra.cassandra_utils.raw_data_factory (list[str] colnames, list[tuple] rows)

None	lsst.dax.apdb.cassandra.cassandra_utils.execute_concurrent (Session session, list[tuple] statements, *, object execution_profile=EXEC_PROFILE_DEFAULT, int concurrency=100)

pandas.DataFrame\|ApdbCassandraTableData\|list	lsst.dax.apdb.cassandra.cassandra_utils.select_concurrent (Session session, list[tuple] statements, str execution_profile, int concurrency)

Any	lsst.dax.apdb.cassandra.cassandra_utils.literal (Any v)

str	lsst.dax.apdb.cassandra.cassandra_utils.quote_id (str columnName)

Variables
bool	lsst.dax.apdb.cassandra.cassandra_utils.CASSANDRA_IMPORTED = True

	lsst.dax.apdb.cassandra.cassandra_utils.EXEC_PROFILE_DEFAULT = object()

	lsst.dax.apdb.cassandra.cassandra_utils._LOG = logging.getLogger(__name__)