Index

A

add_parallel_options() (in module parfun.entry_point) all_arguments() (in module parfun.partition.api) allows_nested_tasks() (parfun.backend.dask.DaskBaseBackend method) (parfun.backend.local_multiprocessing.LocalMultiprocessingBackend method) (parfun.backend.local_single_process.LocalSingleProcessBackend method) (parfun.backend.mixins.BackendEngine method) (parfun.backend.scaler.ScalerRemoteBackend method)

B

BackendEngine (class in parfun.backend.mixins)

BackendSession (class in parfun.backend.mixins)

D

DaskBaseBackend (class in parfun.backend.dask) DaskCurrentBackend (class in parfun.backend.dask) DaskLocalClusterBackend (class in parfun.backend.dask) DaskRemoteClusterBackend (class in parfun.backend.dask)

DaskSession (class in parfun.backend.dask) df_by_group() (in module parfun.partition.dataframe) df_by_row() (in module parfun.partition.dataframe) df_concat() (in module parfun.combine.dataframe)

G

get_parallel_backend() (in module parfun.entry_point)

L

list_by_chunk() (in module parfun.partition.collection) list_concat() (in module parfun.combine.collection) LocalMultiprocessingBackend (class in parfun.backend.local_multiprocessing)

LocalMultiprocessingSession (class in parfun.backend.local_multiprocessing) LocalSingleProcessBackend (class in parfun.backend.local_single_process) LocalSingleProcessSession (class in parfun.backend.local_single_process)

M

module parfun parfun.backend.dask parfun.backend.local_multiprocessing parfun.backend.local_single_process parfun.backend.mixins parfun.backend.scaler parfun.combine parfun.combine.collection parfun.combine.dataframe parfun.entry_point parfun.functions parfun.partition parfun.partition.api parfun.partition.collection parfun.partition.dataframe parfun.partition.object parfun.partition.utility

multiple_arguments() (in module parfun.partition.api)

P

parallel_map() (in module parfun.functions) parallel_starmap() (in module parfun.functions) parallel_timed_map() (in module parfun.functions) parfun module parfun() (in module parfun) parfun.backend.dask module parfun.backend.local_multiprocessing module parfun.backend.local_single_process module parfun.backend.mixins module parfun.backend.scaler module parfun.combine module parfun.combine.collection module parfun.combine.dataframe module

parfun.entry_point module parfun.functions module parfun.partition module parfun.partition.api module parfun.partition.collection module parfun.partition.dataframe module parfun.partition.object module parfun.partition.utility module PartitionGenerator (in module parfun.partition.object) per_argument() (in module parfun.partition.api) preload_value() (parfun.backend.mixins.BackendSession method) (parfun.backend.scaler.ScalerSession method)

S

ScalerLocalBackend (class in parfun.backend.scaler) ScalerRemoteBackend (class in parfun.backend.scaler) ScalerSession (class in parfun.backend.scaler) session() (parfun.backend.dask.DaskBaseBackend method) (parfun.backend.local_multiprocessing.LocalMultiprocessingBackend method) (parfun.backend.local_single_process.LocalSingleProcessBackend method) (parfun.backend.mixins.BackendEngine method) (parfun.backend.scaler.ScalerRemoteBackend method) set_parallel_backend() (in module parfun.entry_point) set_parallel_backend_context() (in module parfun.entry_point) shutdown() (parfun.backend.dask.DaskCurrentBackend method) (parfun.backend.dask.DaskLocalClusterBackend method) (parfun.backend.dask.DaskRemoteClusterBackend method) (parfun.backend.local_multiprocessing.LocalMultiprocessingBackend method) (parfun.backend.local_single_process.LocalSingleProcessBackend method) (parfun.backend.mixins.BackendEngine method) (parfun.backend.scaler.ScalerLocalBackend method) (parfun.backend.scaler.ScalerRemoteBackend method)

submit() (parfun.backend.dask.DaskSession method) (parfun.backend.local_multiprocessing.LocalMultiprocessingSession method) (parfun.backend.local_single_process.LocalSingleProcessSession method) (parfun.backend.mixins.BackendSession method) (parfun.backend.scaler.ScalerSession method)

W

with_partition_size() (in module parfun.partition.utility)