Index

_

__add__() (functional.pipeline.Sequence method) __bool__() (functional.pipeline.Sequence method) __call__() (functional.streams.ParallelStream method) (functional.streams.Stream method) __contains__() (functional.pipeline.Sequence method) __dict__ (functional.lineage.Lineage attribute) (functional.pipeline.Sequence attribute) (functional.streams.Stream attribute) __eq__() (functional.pipeline.Sequence method) __getitem__() (functional.lineage.Lineage method) (functional.pipeline.Sequence method) __getnewargs__() (functional.transformations.Transformation method) __hash__() (functional.pipeline.Sequence method) __init__() (functional.lineage.Lineage method) (functional.pipeline.Sequence method) (functional.streams.ParallelStream method) (functional.streams.Stream method) __iter__() (functional.pipeline.Sequence method) __len__() (functional.lineage.Lineage method) __module__ (functional.lineage.Lineage attribute) (functional.pipeline.Sequence attribute) (functional.streams.ParallelStream attribute) (functional.streams.Stream attribute) (functional.transformations.Transformation attribute)

__ne__() (functional.pipeline.Sequence method) __new__() (functional.transformations.Transformation static method) __nonzero__() (functional.pipeline.Sequence method) __repr__() (functional.lineage.Lineage method) (functional.pipeline.Sequence method) (functional.transformations.Transformation method) __reversed__() (functional.pipeline.Sequence method) __slots__ (functional.transformations.Transformation attribute) __str__() (functional.pipeline.Sequence method) __weakref__ (functional.lineage.Lineage attribute) (functional.pipeline.Sequence attribute) (functional.streams.Stream attribute) _accumulate() (in module functional.transformations) _asdict() (functional.transformations.Transformation method) _evaluate() (functional.pipeline.Sequence method) _fields (functional.transformations.Transformation attribute) _make() (functional.transformations.Transformation class method) _parse_args() (functional.streams.Stream method) _replace() (functional.transformations.Transformation method) _repr_html_() (functional.pipeline.Sequence method) _source (functional.transformations.Transformation attribute) _to_sqlite3_by_query() (functional.pipeline.Sequence method) _to_sqlite3_by_table() (functional.pipeline.Sequence method) _transform() (functional.pipeline.Sequence method) _wrap() (in module functional.pipeline)

A

accumulate() (functional.pipeline.Sequence method), [1] accumulate_impl() (in module functional.transformations) accumulate_t() (in module functional.transformations) aggregate() (functional.pipeline.Sequence method), [1]

all() (functional.pipeline.Sequence method), [1] any() (functional.pipeline.Sequence method), [1] apply() (functional.lineage.Lineage method) average() (functional.pipeline.Sequence method), [1]

C

cache() (functional.pipeline.Sequence method), [1] cache_scan() (functional.lineage.Lineage method) cartesian() (functional.pipeline.Sequence method), [1] cartesian_t() (in module functional.transformations) compose() (in module functional.util) compute_partition_size() (in module functional.util) count() (functional.pipeline.Sequence method), [1]

count_by_key() (functional.pipeline.Sequence method), [1] count_by_key_impl() (in module functional.transformations) count_by_key_t() (in module functional.transformations) count_by_value() (functional.pipeline.Sequence method), [1] count_by_value_impl() (in module functional.transformations) count_by_value_t() (in module functional.transformations) csv() (functional.streams.Stream method), [1] csv_dict_reader() (functional.streams.Stream method), [1]

D

dict() (functional.pipeline.Sequence method), [1] difference() (functional.pipeline.Sequence method), [1] difference_t() (in module functional.transformations) distinct() (functional.pipeline.Sequence method), [1] distinct_by() (functional.pipeline.Sequence method), [1] distinct_by_t() (in module functional.transformations)

distinct_t() (in module functional.transformations) drop() (functional.pipeline.Sequence method), [1] drop_right() (functional.pipeline.Sequence method), [1] drop_right_t() (in module functional.transformations) drop_t() (in module functional.transformations) drop_while() (functional.pipeline.Sequence method), [1] drop_while_t() (in module functional.transformations)

E

empty() (functional.pipeline.Sequence method), [1] enumerate() (functional.pipeline.Sequence method), [1] enumerate_t() (in module functional.transformations)

evaluate() (functional.lineage.Lineage method) execution_strategies (functional.transformations.Transformation attribute) exists() (functional.pipeline.Sequence method), [1]

F

filter() (functional.pipeline.Sequence method), [1] filter_not() (functional.pipeline.Sequence method), [1] filter_not_t() (in module functional.transformations) filter_t() (in module functional.transformations) find() (functional.pipeline.Sequence method), [1] first() (functional.pipeline.Sequence method), [1] flat_map() (functional.pipeline.Sequence method), [1] flat_map_impl() (in module functional.transformations) flat_map_t() (in module functional.transformations) flatten() (functional.pipeline.Sequence method), [1]

flatten_t() (in module functional.transformations) fold_left() (functional.pipeline.Sequence method), [1] fold_right() (functional.pipeline.Sequence method), [1] for_all() (functional.pipeline.Sequence method), [1] for_each() (functional.pipeline.Sequence method), [1] function (functional.transformations.Transformation attribute) functional.lineage (module) functional.pipeline (module), [1] functional.streams (module), [1] functional.transformations (module) functional.util (module)

G

group_by() (functional.pipeline.Sequence method), [1] group_by_impl() (in module functional.transformations) group_by_key() (functional.pipeline.Sequence method), [1] group_by_key_impl() (in module functional.transformations)

group_by_key_t() (in module functional.transformations) group_by_t() (in module functional.transformations) grouped() (functional.pipeline.Sequence method), [1] grouped_impl() (in module functional.transformations) grouped_t() (in module functional.transformations)

H

head() (functional.pipeline.Sequence method), [1]

head_option() (functional.pipeline.Sequence method), [1]

I

identity() (in module functional.util) init() (functional.pipeline.Sequence method), [1] init_t() (in module functional.transformations) inits() (functional.pipeline.Sequence method), [1] inits_t() (in module functional.transformations) inner_join() (functional.pipeline.Sequence method), [1]

inner_join_impl() (in module functional.transformations) intersection() (functional.pipeline.Sequence method), [1] intersection_t() (in module functional.transformations) is_iterable() (in module functional.util) is_namedtuple() (in module functional.util) is_primitive() (in module functional.util) is_tabulatable() (in module functional.util)

J

join() (functional.pipeline.Sequence method), [1] join_impl() (in module functional.transformations)

join_t() (in module functional.transformations) json() (functional.streams.Stream method), [1] jsonl() (functional.streams.Stream method), [1]

L

last() (functional.pipeline.Sequence method), [1] last_option() (functional.pipeline.Sequence method), [1] lazy_parallelize() (in module functional.util)

left_join() (functional.pipeline.Sequence method), [1] len() (functional.pipeline.Sequence method), [1] Lineage (class in functional.lineage) list() (functional.pipeline.Sequence method), [1]

M

make_string() (functional.pipeline.Sequence method), [1] map() (functional.pipeline.Sequence method), [1] map_t() (in module functional.transformations)

max() (functional.pipeline.Sequence method), [1] max_by() (functional.pipeline.Sequence method), [1] min() (functional.pipeline.Sequence method), [1] min_by() (functional.pipeline.Sequence method), [1]

N

name (functional.transformations.Transformation attribute)

name() (in module functional.transformations) non_empty() (functional.pipeline.Sequence method), [1]

O

open() (functional.streams.Stream method), [1] order_by() (functional.pipeline.Sequence method), [1]

order_by_t() (in module functional.transformations) outer_join() (functional.pipeline.Sequence method), [1]

P

pack() (in module functional.util) parallelize() (in module functional.util) ParallelStream (class in functional.streams), [1]

partition() (functional.pipeline.Sequence method), [1] partition_t() (in module functional.transformations) product() (functional.pipeline.Sequence method), [1]

R

range() (functional.streams.Stream method), [1] reduce() (functional.pipeline.Sequence method), [1] reduce_by_key() (functional.pipeline.Sequence method), [1] reduce_by_key_impl() (in module functional.transformations)

reduce_by_key_t() (in module functional.transformations) reverse() (functional.pipeline.Sequence method), [1] reversed_t() (in module functional.transformations) right_join() (functional.pipeline.Sequence method), [1]

S

select() (functional.pipeline.Sequence method), [1] select_t() (in module functional.transformations) Sequence (class in functional.pipeline), [1] sequence (functional.pipeline.Sequence attribute), [1] set() (functional.pipeline.Sequence method), [1] show() (functional.pipeline.Sequence method), [1] size() (functional.pipeline.Sequence method), [1] slice() (functional.pipeline.Sequence method), [1] slice_t() (in module functional.transformations) sliding() (functional.pipeline.Sequence method), [1] sliding_impl() (in module functional.transformations)

sliding_t() (in module functional.transformations) smap() (functional.pipeline.Sequence method), [1] sorted() (functional.pipeline.Sequence method), [1] sorted_t() (in module functional.transformations) split_every() (in module functional.util) sqlite3() (functional.streams.Stream method), [1] starmap() (functional.pipeline.Sequence method), [1] starmap_t() (in module functional.transformations) Stream (class in functional.streams), [1] sum() (functional.pipeline.Sequence method), [1] symmetric_difference() (functional.pipeline.Sequence method), [1] symmetric_difference_t() (in module functional.transformations)

T

tabulate() (functional.pipeline.Sequence method), [1] tail() (functional.pipeline.Sequence method), [1] tail_t() (in module functional.transformations) tails() (functional.pipeline.Sequence method), [1] tails_t() (in module functional.transformations) take() (functional.pipeline.Sequence method), [1] take_t() (in module functional.transformations) take_while() (functional.pipeline.Sequence method), [1] take_while_t() (in module functional.transformations)

to_csv() (functional.pipeline.Sequence method), [1] to_dict() (functional.pipeline.Sequence method), [1] to_file() (functional.pipeline.Sequence method), [1] to_json() (functional.pipeline.Sequence method), [1] to_jsonl() (functional.pipeline.Sequence method), [1] to_list() (functional.pipeline.Sequence method), [1] to_pandas() (functional.pipeline.Sequence method), [1] to_set() (functional.pipeline.Sequence method), [1] to_sqlite3() (functional.pipeline.Sequence method), [1] Transformation (class in functional.transformations)

U

union() (functional.pipeline.Sequence method), [1]

union_t() (in module functional.transformations) unpack() (in module functional.util)

W

where() (functional.pipeline.Sequence method), [1]

where_t() (in module functional.transformations)

Z

zip() (functional.pipeline.Sequence method), [1] zip_t() (in module functional.transformations)

zip_with_index() (functional.pipeline.Sequence method), [1] zip_with_index_t() (in module functional.transformations)