PandasOnPythonDataframeAxisPartition#

The class is specific implementation of PandasDataframeAxisPartition, providing the API to perform operations on an axis partition, using Python as the execution engine. The axis partition is made up of list of block partitions that are stored in this class.

Public API#

class modin.core.execution.python.implementations.pandas_on_python.partitioning.virtual_partition.PandasOnPythonDataframeAxisPartition(list_of_partitions, get_ip=False, full_axis=True, call_queue=None, length=None, width=None)#

Class defines axis partition interface with pandas storage format and Python engine.

Inherits functionality from PandasDataframeAxisPartition class.

Parameters:

  • list_of_partitions (Union[list, PandasOnPythonDataframePartition]) – List of PandasOnPythonDataframePartition and PandasOnPythonDataframeVirtualPartition objects, or a single PandasOnPythonDataframePartition.

  • get_ip (bool, default: False) – Whether to get node IP addresses to conforming partitions or not.

  • full_axis (bool, default: True) – Whether or not the virtual partition encompasses the whole axis.

  • call_queue (list, optional) – A list of tuples (callable, args, kwargs) that contains deferred calls.

  • length (int, optional) – Length, or reference to length, of wrapped pandas.DataFrame.

  • width (int, optional) – Width, or reference to width, of wrapped pandas.DataFrame.

PandasOnPythonFrameColumnPartition#

Public API#

class modin.core.execution.python.implementations.pandas_on_python.partitioning.virtual_partition.PandasOnPythonDataframeColumnPartition(list_of_partitions, get_ip=False, full_axis=True, call_queue=None, length=None, width=None)#

Class defines axis partition interface with pandas storage format and Python engine.

Inherits functionality from PandasDataframeAxisPartition class.

Parameters:

  • list_of_partitions (Union[list, PandasOnPythonDataframePartition]) – List of PandasOnPythonDataframePartition and PandasOnPythonDataframeVirtualPartition objects, or a single PandasOnPythonDataframePartition.

  • get_ip (bool, default: False) – Whether to get node IP addresses to conforming partitions or not.

  • full_axis (bool, default: True) – Whether or not the virtual partition encompasses the whole axis.

  • call_queue (list, optional) – A list of tuples (callable, args, kwargs) that contains deferred calls.

  • length (int, optional) – Length, or reference to length, of wrapped pandas.DataFrame.

  • width (int, optional) – Width, or reference to width, of wrapped pandas.DataFrame.

PandasOnPythonFrameRowPartition#

Public API#

class modin.core.execution.python.implementations.pandas_on_python.partitioning.virtual_partition.PandasOnPythonDataframeRowPartition(list_of_partitions, get_ip=False, full_axis=True, call_queue=None, length=None, width=None)#

Class defines axis partition interface with pandas storage format and Python engine.

Inherits functionality from PandasDataframeAxisPartition class.

Parameters:

  • list_of_partitions (Union[list, PandasOnPythonDataframePartition]) – List of PandasOnPythonDataframePartition and PandasOnPythonDataframeVirtualPartition objects, or a single PandasOnPythonDataframePartition.

  • get_ip (bool, default: False) – Whether to get node IP addresses to conforming partitions or not.

  • full_axis (bool, default: True) – Whether or not the virtual partition encompasses the whole axis.

  • call_queue (list, optional) – A list of tuples (callable, args, kwargs) that contains deferred calls.

  • length (int, optional) – Length, or reference to length, of wrapped pandas.DataFrame.

  • width (int, optional) – Width, or reference to width, of wrapped pandas.DataFrame.

On this page
Show Source