daft.read_hudi

daft.read_hudi(table_uri: str, io_config: Optional[IOConfig] = None) → DataFrame

Create a DataFrame from a Hudi table.

Example

>>> df = daft.read_hudi("some-table-uri")
>>> df = df.where(df["foo"] > 5)
>>> df.show()

Parameters:

• table_uri – URI to the Hudi table.

• io_config – A custom IOConfig to use when accessing Hudi table object storage data. Defaults to None.

Returns:

A DataFrame with the schema converted from the specified Hudi table.

Return type:

DataFrame

• Get Started
• Documentation
• Github
• Blog
• Community