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]