API¶
Top level user functions:
Bag |
|
Bag.all |
|
Bag.any |
|
Bag.compute |
|
Bag.count |
|
Bag.distinct |
|
Bag.filter |
|
Bag.flatten |
|
Bag.fold |
|
Bag.foldby |
|
Bag.frequencies |
|
Bag.groupby |
|
Bag.join |
|
Bag.map |
|
Bag.map_partitions |
|
Bag.max |
|
Bag.mean |
|
Bag.min |
|
Bag.pluck |
|
Bag.product |
|
Bag.reduction |
|
Bag.random_sample |
|
Bag.remove |
|
Bag.repartition |
|
Bag.starmap |
|
Bag.std |
|
Bag.sum |
|
Bag.take |
|
Bag.to_dataframe |
|
Bag.to_delayed |
|
Bag.to_textfiles |
|
Bag.to_avro |
|
Bag.topk |
|
Bag.var |
|
Bag.visualize |
Create Bags¶
from_sequence |
|
from_delayed |
|
read_text |
|
from_url |
|
read_avro |
|
range |
Top-level functions¶
concat |
|
map |
|
map_partitions |
|
zip |
Turn Bags into other things¶
Bag.to_textfiles |
|
Bag.to_dataframe |
|
Bag.to_delayed |
|
Bag.to_avro |