Inheritance diagram for lsst.dax.apdb.cassandra_utils.ApdbCassandraTableData:

Public Member Functions
	__init__ (self, list[str] columns, list[tuple] rows)

list[str]	column_names (self)

Iterable[tuple]	rows (self)

None	append (self, ApdbCassandraTableData other)

Iterator[tuple]	__iter__ (self)

Protected Attributes
	_columns

	_rows

Detailed Description

Implementation of ApdbTableData that wraps Cassandra raw data.

Definition at line 92 of file cassandra_utils.py.

Constructor & Destructor Documentation

◆ init()

lsst.dax.apdb.cassandra_utils.ApdbCassandraTableData.__init__	(		self,
		list[str]	columns,
		list[tuple]	rows )

Definition at line 95 of file cassandra_utils.py.

    def __init__(self, columns: list[str], rows: list[tuple]):
        self._columns = columns
        self._rows = rows
 

Member Function Documentation

◆ iter()

Iterator[tuple] lsst.dax.apdb.cassandra_utils.ApdbCassandraTableData.__iter__ ( self )

Make it look like a row iterator, needed for some odd logic.

Definition at line 113 of file cassandra_utils.py.

    def __iter__(self) -> Iterator[tuple]:
        """Make it look like a row iterator, needed for some odd logic."""
        return iter(self._rows)
 
 

◆ append()

None lsst.dax.apdb.cassandra_utils.ApdbCassandraTableData.append	(		self,
		ApdbCassandraTableData	other )

Extend rows in this table with rows in other table

Definition at line 107 of file cassandra_utils.py.

    def append(self, other: ApdbCassandraTableData) -> None:
        """Extend rows in this table with rows in other table"""
        if self._columns != other._columns:
            raise ValueError(f"Different columns returned by queries: {self._columns} and {other._columns}")
        self._rows.extend(other._rows)
 

◆ column_names()

list[str] lsst.dax.apdb.cassandra_utils.ApdbCassandraTableData.column_names ( self )

Return ordered sequence of column names in the table.

Returns
-------
names : `list` [`str`]
    Column names.

Reimplemented from lsst.dax.apdb.apdb.ApdbTableData.

Definition at line 99 of file cassandra_utils.py.

    def column_names(self) -> list[str]:
        # docstring inherited
        return self._columns
 

◆ rows()

Iterable[tuple] lsst.dax.apdb.cassandra_utils.ApdbCassandraTableData.rows ( self )

Return table rows, each row is a tuple of values.

Returns
-------
rows : `iterable` [`tuple`]
    Iterable of tuples.

Reimplemented from lsst.dax.apdb.apdb.ApdbTableData.

Definition at line 103 of file cassandra_utils.py.

    def rows(self) -> Iterable[tuple]:
        # docstring inherited
        return self._rows
 

Member Data Documentation

◆ _columns

lsst.dax.apdb.cassandra_utils.ApdbCassandraTableData._columns

protected

Definition at line 96 of file cassandra_utils.py.

◆ _rows

lsst.dax.apdb.cassandra_utils.ApdbCassandraTableData._rows

protected

Definition at line 97 of file cassandra_utils.py.

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

/j/snowflake/release/lsstsw/stack/lsst-scipipe-8.0.0/Linux64/dax_apdb/gd2a12a3803+f8351bc914/python/lsst/dax/apdb/cassandra_utils.py

Public Member Functions

Protected Attributes