fugue.bag#

fugue.bag.array_bag#

class fugue.bag.array_bag.ArrayBag(data, copy=True)[source]#

Bases: LocalBoundedBag

Parameters
  • data (Any) –

  • copy (bool) –

as_array()[source]#

Convert to a native python array

Returns

the native python array

Return type

List[Any]

count()[source]#

Get number of rows of this dataframe

Return type

int

property empty: bool#

Whether this dataframe is empty

head(n)[source]#

Take the first n elements

Returns

the python array of the first n elements

Parameters

n (int) –

Return type

LocalBoundedBag

property native: List[Any]#

The underlying Python list object

peek()[source]#

Peek the first row of the dataframe as array

Raises

FugueDatasetEmptyError – if it is empty

Return type

Any

fugue.bag.bag#

class fugue.bag.bag.Bag[source]#

Bases: Dataset

The base class of Fugue Bags. Bag contains a collection of unordered objects.

abstract as_array()[source]#

Convert to a native python array

Returns

the native python array

Return type

List[Any]

abstract as_local()[source]#

Convert this bag to a LocalBag

Return type

LocalBag

abstract head(n)[source]#

Take the first n elements

Returns

the python array of the first n elements

Parameters

n (int) –

Return type

LocalBoundedBag

abstract peek()[source]#

Peek the first row of the dataframe as array

Raises

FugueDatasetEmptyError – if it is empty

Return type

Any

class fugue.bag.bag.BagDisplay(ds)[source]#

Bases: DatasetDisplay

Bag plain display class

Parameters

ds (Dataset) –

property bg: Bag#

The target Bag

show(n=10, with_count=False, title=None)[source]#

Show the Dataset

Parameters
  • n (int) – top n items to display, defaults to 10

  • with_count (bool) – whether to display the total count, defaults to False

  • title (Optional[str]) – title to display, defaults to None

Return type

None

class fugue.bag.bag.LocalBag[source]#

Bases: Bag

as_local()[source]#

Convert this bag to a LocalBag

Return type

LocalBag

property is_local: bool#

Whether this dataframe is a local Dataset

property num_partitions: int#

Number of physical partitions of this dataframe. Please read the Partition Tutorial

class fugue.bag.bag.LocalBoundedBag[source]#

Bases: LocalBag

property is_bounded: bool#

Whether this dataframe is bounded