Index

_

_df (dfchain.backends.pandas.executor_impl.PandasExecutor attribute)

_groupby_cache (dfchain.backends.sqlite.executor_impl.SqliteExecutor attribute) _session (dfchain.backends.sqlite.executor_impl.SqliteExecutor attribute)

A

agg() (dfchain.backends.sqlite.util.DistributedGroupBy method)

B

Base (class in dfchain.backends.sqlite.models)

C

chunksize (dfchain.backends.pandas.executor_impl.PandasExecutor attribute) clear_cache() (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) (dfchain.backends.sqlite.util.DistributedGroupBy method)

clear_groups() (dfchain.backends.pandas.executor_impl.PandasExecutor method) (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) (dfchain.core.executor.partitionable.PartitionAble method)

D

data (dfchain.backends.sqlite.models.DfChunk attribute) (dfchain.backends.sqlite.models.DfGroup attribute) df() (dfchain.backends.pandas.executor_impl.PandasExecutor method) (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) dfchain module dfchain.api module dfchain.api.pipeline module dfchain.api.read_csv module dfchain.api.task module dfchain.backends module dfchain.backends.pandas module dfchain.backends.pandas.executor_impl module dfchain.backends.sqlite module

dfchain.backends.sqlite.adapters module dfchain.backends.sqlite.adapters.csvreader module dfchain.backends.sqlite.executor_impl module dfchain.backends.sqlite.models module dfchain.backends.sqlite.schema module dfchain.backends.sqlite.util module dfchain.core module dfchain.core.executor module dfchain.core.executor.groupbylike module dfchain.core.executor.partitionable module DfChunk (class in dfchain.backends.sqlite.models) DfGroup (class in dfchain.backends.sqlite.models) DistributedGroupBy (class in dfchain.backends.sqlite.util)

E

eager() (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) ensure_df_iter() (in module dfchain.backends.sqlite.util)

executor (dfchain.backends.sqlite.adapters.csvreader.SqliteCsvReader attribute) (dfchain.backends.sqlite.adapters.csvreader.SqliteCsvWriter attribute)

F

freeze_call() (in module dfchain.backends.sqlite.util)

G

get_default_executor() (in module dfchain.api.read_csv) get_groupkey() (dfchain.core.executor.partitionable.PartitionAble method) get_session() (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) groupby (dfchain.core.executor.partitionable.PartitionAble property)

groupby_iter_factory (dfchain.backends.sqlite.util.DistributedGroupBy attribute) groupbykeys (dfchain.backends.sqlite.models.DfChunk attribute) (dfchain.backends.sqlite.models.DfGroup attribute) GroupByLike (class in dfchain.core.executor.groupbylike) groupkey() (dfchain.backends.sqlite.executor_impl.SqliteExecutor method)

I

id (dfchain.backends.sqlite.models.DfChunk attribute) (dfchain.backends.sqlite.models.DfGroup attribute) init_chunk() (in module dfchain.backends.sqlite.util) init_group() (in module dfchain.backends.sqlite.util) is_df_iterator() (in module dfchain.api.task) is_eager (dfchain.backends.pandas.executor_impl.PandasExecutor attribute)

is_inplace (dfchain.backends.pandas.executor_impl.PandasExecutor attribute) iter_chunks() (dfchain.backends.pandas.executor_impl.PandasExecutor method) (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) (dfchain.core.executor.partitionable.PartitionAble method) iter_groups() (dfchain.backends.pandas.executor_impl.PandasExecutor method) (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) (dfchain.core.executor.partitionable.PartitionAble method)

L

logger (in module dfchain.backends.sqlite.executor_impl)

M

metadata (dfchain.backends.sqlite.models.Base attribute) module dfchain dfchain.api dfchain.api.pipeline dfchain.api.read_csv dfchain.api.task dfchain.backends dfchain.backends.pandas dfchain.backends.pandas.executor_impl dfchain.backends.sqlite dfchain.backends.sqlite.adapters dfchain.backends.sqlite.adapters.csvreader dfchain.backends.sqlite.executor_impl dfchain.backends.sqlite.models dfchain.backends.sqlite.schema dfchain.backends.sqlite.util dfchain.core dfchain.core.executor dfchain.core.executor.groupbylike dfchain.core.executor.partitionable

N

norm_key() (in module dfchain.backends.sqlite.util)

P

PandasExecutor (class in dfchain.backends.pandas.executor_impl)

PartitionAble (class in dfchain.core.executor.partitionable) Pipeline (class in dfchain.api.pipeline)

R

read_csv (dfchain.backends.sqlite.adapters.csvreader.SqliteCsvReader property) read_csv() (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) (in module dfchain.api.read_csv) rebuild_groups() (dfchain.backends.pandas.executor_impl.PandasExecutor method) (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) (dfchain.core.executor.partitionable.PartitionAble method)

registry (dfchain.backends.sqlite.models.Base attribute) run() (dfchain.api.pipeline.Pipeline method)

S

session() (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) session_factory() (in module dfchain.backends.sqlite.schema) SqliteCsvReader (class in dfchain.backends.sqlite.adapters.csvreader)

SqliteCsvWriter (class in dfchain.backends.sqlite.adapters.csvreader) SqliteExecutor (class in dfchain.backends.sqlite.executor_impl) steps (dfchain.api.pipeline.Pipeline attribute), [1]

T

task() (in module dfchain.api.task) textFileReader() (dfchain.backends.sqlite.executor_impl.SqliteExecutor method)

to_csv (dfchain.backends.sqlite.adapters.csvreader.SqliteCsvWriter property) transform() (in module dfchain.api.pipeline) Transformation (class in dfchain.api.pipeline)

U

update_group() (dfchain.backends.pandas.executor_impl.PandasExecutor method) (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) (dfchain.core.executor.partitionable.PartitionAble method) (in module dfchain.backends.sqlite.executor_impl)

W

write_chunk() (dfchain.backends.pandas.executor_impl.PandasExecutor method) (dfchain.backends.sqlite.executor_impl.SqliteExecutor method) (dfchain.core.executor.partitionable.PartitionAble method)