Index

B

BasicDataLoader (class in dds.core.partition_generators)

C

collect() (dds.api.DDS method) collect_as_dict() (dds.api.DDS method) combine_by_key() (dds.api.DDS method)

count() (dds.api.DDS method) count_by_key() (dds.api.DDS method) count_by_value() (dds.api.DDS method)

D

dds module DDS (class in dds.api) dds.api module dds.core module dds.core.partition_generators module

dds.core.tasks module dds.core.utils module DDSException default_hash() (in module dds.core.utils) distinct() (dds.api.DDS method) distribute_partition() (in module dds.core.tasks)

F

filter() (dds.api.DDS method) flat_map() (dds.api.DDS method)

flatten_by_key() (dds.api.DDS method) foreach() (dds.api.DDS method)

G

group_by_key() (dds.api.DDS method)

I

IPartitionGenerator (class in dds.core.partition_generators)

IteratorLoader (class in dds.core.partition_generators)

J

join() (dds.api.DDS method)

K

key_by() (dds.api.DDS method)

keys() (dds.api.DDS method)

L

load() (dds.api.DDS method) load_file() (dds.api.DDS method)

load_files_from_dir() (dds.api.DDS method) load_pickle_files() (dds.api.DDS method) load_text_file() (dds.api.DDS method)

M

map() (dds.api.DDS method) map_and_save_pickle() (in module dds.core.tasks) map_and_save_text_file() (in module dds.core.tasks) map_partition() (in module dds.core.tasks) map_partitions() (dds.api.DDS method) map_values() (dds.api.DDS method)

module dds dds.api dds.core dds.core.partition_generators dds.core.tasks dds.core.utils

N

num_of_partitions() (dds.api.DDS method)

P

partition_by() (dds.api.DDS method)

PickleLoader (class in dds.core.partition_generators)

R

read_in_chunks() (in module dds.core.partition_generators) read_lines() (in module dds.core.partition_generators) reduce() (dds.api.DDS method) reduce_by_key() (dds.api.DDS method) reduce_dicts() (in module dds.core.tasks)

reduce_multiple() (in module dds.core.tasks) retrieve_data() (dds.core.partition_generators.BasicDataLoader method) (dds.core.partition_generators.IPartitionGenerator method) (dds.core.partition_generators.IteratorLoader method) (dds.core.partition_generators.PickleLoader method) (dds.core.partition_generators.WorkerFileLoader method)

S

save_as_pickle() (dds.api.DDS method) save_as_text_file() (dds.api.DDS method)

sort_by_key() (dds.api.DDS method) sum() (dds.api.DDS method) synchronization

T

take() (dds.api.DDS method) task

task_collect_samples() (in module dds.core.tasks) task_dict_to_list() (in module dds.core.tasks)

U

union() (dds.api.DDS method)

V

values() (dds.api.DDS method)

W

WorkerFileLoader (class in dds.core.partition_generators)