PandasOnDaskDataframePartition

The class is the specific implementation of PandasDataframePartition, providing the API to perform operations on a block partition, namely, pandas.DataFrame, using Dask as the execution engine.

In addition to wrapping a pandas.DataFrame, the class also holds the following metadata:

• length - length of pandas.DataFrame wrapped

• width - width of pandas.DataFrame wrapped

• ip - node IP address that holds pandas.DataFrame wrapped

An operation on a block partition can be performed in two modes:

• asynchronously_ - via apply()

• lazily_ - via add_to_apply_calls()

Public API