Dataframes

flowtask.interfaces.dataframes

ArrowDataframe

Bases: BaseDataframe

ArrowDataframe.

Converts any result into a Arrow DataFrame.

create_dataframe async

create_dataframe(result, *args, **kwargs)

Converts any result into a Arrow DataFrame.

:param result: The result data to be converted into a Arrow DataFrame. :return: A DataFrame containing the result data.

DtDataframe

Bases: BaseDataframe

DtDataframe.

Converts any result into a Datatable DataFrame.

create_dataframe async

create_dataframe(result, *args, **kwargs)

Converts any result into a Datatable DataFrame.

:param result: The result data to be converted into a Datatable DataFrame. :return: A DataFrame containing the result data.

PandasDataframe

Bases: BaseDataframe

PandasDataframe.

Converts any result into a Pandas DataFrame.

column_exists

column_exists(column)

Returns True if the column exists in the DataFrame.

create_dataframe async

create_dataframe(result, *args, **kwargs)

Converts any result into a Pandas DataFrame.

:param result: The result data to be converted into a Pandas DataFrame. :return: A DataFrame containing the result data.

from_csv async

from_csv(result, *args, **kwargs)

Converts a Comma-Separated CSV into a Pandas DataFrame.

:param result: The result data to be converted into a Pandas DataFrame. :return: A DataFrame containing the result data.

PolarsDataframe

Bases: BaseDataframe

PolarsDataframe.

Converts any result into a Polars DataFrame.

create_dataframe async

create_dataframe(result, *args, **kwargs)

Converts any result into a Polars DataFrame.

:param result: The result data to be converted into a Polars DataFrame. :return: A DataFrame containing the result data.

abstract

BaseDataframe

Bases: ABC

create_dataframe abstractmethod async

create_dataframe(result, *args, **kwargs)

Converts any result into a DataFrame.

:param result: The result data to be converted into a DataFrame. :return: A DataFrame containing the result data.

arrow

ArrowDataframe

Bases: BaseDataframe

ArrowDataframe.

Converts any result into a Arrow DataFrame.

create_dataframe async

create_dataframe(result, *args, **kwargs)

Converts any result into a Arrow DataFrame.

:param result: The result data to be converted into a Arrow DataFrame. :return: A DataFrame containing the result data.

is_empty

is_empty(obj)

check_empty. Check if a basic object, a Apache Arrow Table is empty or not.

dt

DtDataframe

Bases: BaseDataframe

DtDataframe.

Converts any result into a Datatable DataFrame.

create_dataframe async

create_dataframe(result, *args, **kwargs)

Converts any result into a Datatable DataFrame.

:param result: The result data to be converted into a Datatable DataFrame. :return: A DataFrame containing the result data.

is_empty

is_empty(obj)

check_empty. Check if a basic object, a Polars DataFrame, an Apache Arrow Table, or a Python DataTable Frame is empty or not.

pandas

PandasDataframe

Bases: BaseDataframe

PandasDataframe.

Converts any result into a Pandas DataFrame.

column_exists

column_exists(column)

Returns True if the column exists in the DataFrame.

create_dataframe async

create_dataframe(result, *args, **kwargs)

Converts any result into a Pandas DataFrame.

:param result: The result data to be converted into a Pandas DataFrame. :return: A DataFrame containing the result data.

from_csv async

from_csv(result, *args, **kwargs)

Converts a Comma-Separated CSV into a Pandas DataFrame.

:param result: The result data to be converted into a Pandas DataFrame. :return: A DataFrame containing the result data.

is_empty

is_empty(obj)

check_empty. Check if a basic object is empty or not.

polars

PolarsDataframe

Bases: BaseDataframe

PolarsDataframe.

Converts any result into a Polars DataFrame.

create_dataframe async

create_dataframe(result, *args, **kwargs)

Converts any result into a Polars DataFrame.

:param result: The result data to be converted into a Polars DataFrame. :return: A DataFrame containing the result data.

is_empty

is_empty(obj)

check_empty. Check if a basic object or a DataFrame (Pandas or Polars) is empty or not.