destinations.dataset.ibis_relation

ReadableIbisRelation Objects

class ReadableIbisRelation(BaseReadableDBAPIRelation)

[view_source]

__init__

def __init__(*,
             readable_dataset: ReadableDBAPIDataset,
             ibis_object: Any = None,
             columns_schema: TTableSchemaColumns = None) -> None

[view_source]

Create a lazy evaluated relation to for the dataset of a destination

query

@property
def query() -> Any

[view_source]

build the query

compute_columns_schema

def compute_columns_schema() -> TTableSchemaColumns

[view_source]

provide schema columns for the cursor, may be filtered by selected columns

__getattr__

def __getattr__(name: str) -> Any

[view_source]

Wrap all callable attributes of the expression

limit

def limit(limit: int, **kwargs: Any) -> "ReadableIbisRelation"

[view_source]

limit the result to 'limit' items

head

def head(limit: int = 5) -> "ReadableIbisRelation"

[view_source]

limit the result to 5 items by default

select

def select(*columns: str) -> "ReadableIbisRelation"

[view_source]

set which columns will be selected