feast.infra.offline_stores.contrib.trino_offline_store.connectors package

Submodules

feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload module

Connectors can be found in the following doc https://trino.io/docs/current/connector.html

For the hive connector, all file formats are here https://trino.io/docs/current/connector/hive.html#supported-file-types

Example yaml config ```yaml offline_store:

type: trino host: localhost port: 8080 catalog: hive dataset: ci connector:

type: hive file_format: parquet

```

feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.format_datetime(t: datetime) str[source]
feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.format_pandas_row(df: DataFrame) str[source]
feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.pandas_dataframe_fix_batches(df: DataFrame, batch_size: int) Iterator[DataFrame][source]
feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.pyarrow_schema_from_dataframe(df: DataFrame) Dict[str, Any][source]
feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.trino_table_schema_from_dataframe(df: DataFrame) str[source]
feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.upload_pandas_dataframe_to_trino(client: Trino, df: DataFrame, table: str, connector_args: Dict[str, str] | None = None, batch_size: int = 1000000) None[source]

Module contents