OmnisciServer#
Public API#
- class modin.experimental.core.execution.native.implementations.omnisci_on_native.omnisci_worker.OmnisciServer#
Wrapper class for OmniSci storage format.
- static cast_to_compatible_types(table)#
Cast PyArrow table to be fully compatible with OmniSci.
- Parameters
table (pyarrow.Table) – Source table.
- Returns
Table with fully compatible types with OmniSci.
- Return type
pyarrow.Table
- classmethod executeDDL(query)#
Execute DDL SQL query.
- Parameters
query (str) – SQL query.
- 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 put_arrow_to_omnisci(table, name=None)#
Import Arrow table to OmniSci engine.
- 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 put_pandas_to_omnisci(df, name=None)#
Import
pandas.DataFrameto OmniSci storage format.- Parameters
df (pandas.DataFrame) – A frame to import.
name (str, optional) – A table name to use. None to generate a unique name.
- Returns
Imported table name.
- Return type
str
- classmethod start_server()#
Initialize OmniSci server.
Do nothing if it is initiliazed already.
- classmethod stop_server()#
Destroy OmniSci server if any.