HdkWorker#
Public API#
- class modin.experimental.core.execution.native.implementations.hdk_on_native.hdk_worker.HdkWorker#
PyHDK based wrapper class for HDK storage format.
- classmethod dropTable(name)#
Drops table with the specified name.
- Parameters
name (str) – A table to drop.
- classmethod executeDML(query)#
Execute DML SQL query.
- Parameters
query (str) – SQL query.
- Returns
Execution result.
- Return type
pyarrow.Table
- classmethod executeRA(query)#
Execute calcite query.
- Parameters
query (str) – Serialized calcite query.
- Returns
Execution result.
- Return type
pyarrow.Table
- classmethod import_arrow_table(table, name=None)#
Import Arrow table to the worker.
- Parameters
table (pyarrow.Table) – A table to import.
name (str, optional) – A table name to use. None to generate a unique name.
- Returns
Imported table name.
- Return type
str
- classmethod setup_engine()#
Initialize PyHDK.
Do nothing if it is initiliazed already.