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.datetime) str [source]
- feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.format_pandas_row(df: pandas.core.frame.DataFrame) str [source]
- feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.pandas_dataframe_fix_batches(df: pandas.core.frame.DataFrame, batch_size: int) Iterator[pandas.core.frame.DataFrame] [source]
- feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.pyarrow_schema_from_dataframe(df: pandas.core.frame.DataFrame) Dict[str, Any] [source]
- feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.trino_table_schema_from_dataframe(df: pandas.core.frame.DataFrame) str [source]
- feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload.upload_pandas_dataframe_to_trino(client: feast.infra.offline_stores.contrib.trino_offline_store.trino_queries.Trino, df: pandas.core.frame.DataFrame, table: str, connector_args: Optional[Dict[str, str]] = None, batch_size: int = 1000000) None [source]