dlt.destinations.impl.lancedb.sql_client
Query LanceDB over the Arrow Flight SQL endpoint of a managed cluster.
LanceDBCursorImpl Objects
class LanceDBCursorImpl(DBApiCursorImpl)
Reads Flight SQL results as arrow, so df() and arrow() skip the row tuple round trip.
native_cursor
type: ignore[assignment]
LanceDBSqlClient Objects
class LanceDBSqlClient(SqlClientBase[pyflightsql.FlightSqlConnection],
WithReadonlyClient)
make_qualified_table_name_path
def make_qualified_table_name_path(table_name: Optional[str],
quote: bool = True,
casefold: bool = True,
dataset_name: Optional[str] = None,
catalog: Optional[str] = None) -> List[str]
Returns [database, "public", table] for a table of dataset_name or of this dataset.
Arguments:
table_name- Table to address, optional.quote- Whether to escape each component.casefold- Whether to case-fold each component.dataset_name- Dataset to address instead of this one, which is how references to another dataset are qualified.catalog- Catalog to address instead of the dataset. A dataset is a database here, so it already is the catalog and this replaces it.
Returns:
List[str]- Path components from catalog to table.