ops.execute

LakeOps provides methods for user management including creation, read and write dataset from/to a datalake through a storage path or schema/table name.

execute(sql, **kwargs)

Execute a SQL query and return the result.

Parameters:

Name	Type	Description	Default
sql	str	SQL query to execute	required
**kwargs		Additional arguments to pass to the underlying engine	{}

Returns:

Type	Description
Any	pyspark.sql.DataFrame: If using SparkEngine
Any	polars.DataFrame: If using PolarsEngine (default) or TrinoEngine