Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
W
_
_debug (glide.core.Node attribute)
_log (glide.core.Node attribute)
A
add_table_suffix() (in module glide.sql_utils)
allowed_conn_types (glide.extensions.pandas.PandasSQLNode attribute)
(glide.sql.BaseSQLNode attribute)
,
[1]
(glide.sql.SQLNode attribute)
ArraySplitByNode (class in glide.flow)
ArraySplitPush (class in glide.flow)
as_completed_func (glide.extensions.dask.DaskClientPush attribute)
(glide.flow.FuturesPush attribute)
as_completed_func() (glide.flow.FuturesPush method)
AssertFunc (class in glide.core)
AssertSQL (class in glide.sql)
Async (glide.core.PushTypes attribute)
AsyncIOFuturesReduce (class in glide.flow)
AsyncIOSubmit (class in glide.core)
AttributeFilter (class in glide.filter)
Average (class in glide.math)
B
BaseSQLNode (class in glide.sql)
basic_glider() (in module glide.pipelines)
begin() (glide.extensions.pandas.DataFrameCSVLoad method)
(glide.flow.Reduce method)
(glide.flow.WindowReduce method)
(glide.load.CSVLoad method)
(glide.sql.BaseSQLNode method)
blacklisted() (glide.core.GliderScript method)
build_table_select() (in module glide.sql_utils)
C
cancel_asyncio_tasks() (in module glide.utils)
CeleryApplyAsync (class in glide.extensions.celery)
CeleryParaGlider (class in glide.extensions.celery)
CeleryReduce (class in glide.extensions.celery)
CelerySendTask (class in glide.extensions.celery)
check_conn() (glide.sql.BaseSQLNode method)
(glide.sql.SQLNode method)
check_data() (glide.core.PoolSubmit method)
(glide.extensions.dask.DaskClientMap method)
clean_up() (glide.core.GliderScript method)
clean_up_nodes() (in module glide.core)
cli() (glide.core.Glider method)
closer() (in module glide.utils)
commit() (glide.sql.BaseSQLNode method)
complete_count() (in module glide.extensions.rq)
compute_stats() (glide.extensions.pandas.DataFrameBollingerBands method)
(glide.extensions.pandas.DataFrameMovingAverage method)
(glide.extensions.pandas.DataFrameRollingNode method)
(glide.extensions.pandas.DataFrameRollingStd method)
(glide.extensions.pandas.DataFrameRollingSum method)
ConfigContext (class in glide.core)
consume() (glide.core.Glider method)
(glide.core.ParaGlider method)
(glide.extensions.celery.CeleryParaGlider method)
(glide.extensions.rq.RQParaGlider method)
(in module glide.core)
consume_none() (in module glide.core)
consume_task (glide.extensions.celery.CeleryParaGlider attribute)
context (glide.core.Node attribute)
ContextPush (class in glide.core)
copy() (glide.core.RuntimeContext method)
create_like() (glide.sql.BaseSQLNode method)
CSVExtract (class in glide.extract)
CSVLoad (class in glide.load)
D
DaskClientMap (class in glide.extensions.dask)
DaskClientPush (class in glide.extensions.dask)
DaskDataFrameApply (class in glide.extensions.dask)
DaskDelayedPush (class in glide.extensions.dask)
DaskFuturesReduce (class in glide.extensions.dask)
DaskParaGlider (class in glide.extensions.dask)
DataFrameApplyMap (class in glide.extensions.pandas)
DataFrameBollingerBands (class in glide.extensions.pandas)
DataFrameCSVExtract (class in glide.extensions.pandas)
DataFrameCSVLoad (class in glide.extensions.pandas)
DataFrameExcelExtract (class in glide.extensions.pandas)
DataFrameExcelLoad (class in glide.extensions.pandas)
DataFrameHTMLExtract (class in glide.extensions.pandas)
DataFrameHTMLLoad (class in glide.extensions.pandas)
DataFrameMethod (class in glide.extensions.pandas)
DataFrameMovingAverage (class in glide.extensions.pandas)
DataFramePush (class in glide.extensions.pandas)
DataFramePushMixin (class in glide.extensions.pandas)
DataFrameRollingNode (class in glide.extensions.pandas)
DataFrameRollingStd (class in glide.extensions.pandas)
DataFrameRollingSum (class in glide.extensions.pandas)
DataFrameSQLExtract (class in glide.extensions.pandas)
DataFrameSQLLoad (class in glide.extensions.pandas)
DataFrameSQLTableExtract (class in glide.extensions.pandas)
DataFrameSQLTempLoad (class in glide.extensions.pandas)
date_from_str() (in module glide.utils)
date_window_cli() (in module glide.utils)
datetime_cmp() (in module glide.utils)
datetime_window_cli() (in module glide.utils)
DateTimeWindowAction (class in glide.utils)
DateTimeWindowPush (class in glide.flow)
DateWindowAction (class in glide.utils)
DateWindowPush (class in glide.flow)
dbg() (in module glide.utils)
dbgsql() (in module glide.utils)
default_context (glide.core.Node attribute)
DictKeyFilter (class in glide.filter)
DictKeyTransform (class in glide.transform)
divide_data() (in module glide.utils)
do_push() (glide.extensions.pandas.DataFramePushMixin method)
(glide.sql.SQLCursorPushMixin method)
drop_table() (glide.sql.BaseSQLNode method)
E
EmailExtract (class in glide.extract)
EmailLoad (class in glide.load)
EmailMessageTransform (class in glide.transform)
end() (glide.core.GlidePipeline method)
(glide.extensions.celery.CeleryReduce method)
(glide.extensions.dask.DaskFuturesReduce method)
(glide.extensions.pandas.DataFrameCSVLoad method)
(glide.extensions.rq.RQReduce method)
(glide.flow.AsyncIOFuturesReduce method)
(glide.flow.FuturesReduce method)
(glide.flow.Reduce method)
(glide.flow.Return method)
(glide.load.CSVLoad method)
error() (in module glide.utils)
excel_file_type() (in module glide.utils)
ExcelExtract (class in glide.extract)
ExcelLoad (class in glide.load)
execute() (glide.sql.BaseSQLNode method)
executemany() (glide.sql.BaseSQLNode method)
executor_class (glide.extensions.dask.DaskClientPush attribute)
(glide.flow.FuturesPush attribute)
,
[1]
(glide.flow.ThreadPoolPush attribute)
executor_kwargs (glide.core.ParaGlider attribute)
F
FileConcat (class in glide.flow)
FileCopy (class in glide.flow)
FileExtract (class in glide.extract)
FileLoad (class in glide.load)
Filter (class in glide.filter)
find_class_in_dict() (in module glide.utils)
Flatten (class in glide.flow)
flatten() (in module glide.utils)
FormatPrint (class in glide.load)
FromDataFrame (class in glide.extensions.pandas)
Func (class in glide.transform)
FuturesPush (class in glide.flow)
FuturesReduce (class in glide.flow)
G
get_async_result() (in module glide.extensions.rq)
get_async_results() (in module glide.extensions.rq)
get_bulk_insert() (in module glide.sql_utils)
get_bulk_insert_ignore() (in module glide.sql_utils)
get_bulk_replace() (in module glide.sql_utils)
get_bulk_statement() (glide.sql.BaseSQLNode method)
(in module glide.sql_utils)
get_class_list_docstring() (in module glide.utils)
get_date_windows() (in module glide.utils)
get_datetime_windows() (in module glide.utils)
get_executor() (glide.core.ParaGlider method)
(glide.core.PoolSubmit method)
(glide.core.ProcessPoolParaGlider method)
(glide.core.ProcessPoolSubmit method)
(glide.core.ThreadPoolParaGlider method)
(glide.core.ThreadPoolSubmit method)
(glide.extensions.dask.DaskClientMap method)
(glide.extensions.dask.DaskParaGlider method)
get_file_handle() (in module glide.utils)
get_injected_kwargs() (glide.core.GliderScript method)
get_label() (glide.load.LenPrint method)
(glide.load.Print method)
get_node_contexts() (in module glide.core)
get_node_lookup() (glide.core.Glider method)
get_or_create_event_loop() (in module glide.utils)
get_results() (glide.core.AsyncIOSubmit method)
(glide.core.ParaGlider method)
(glide.core.PoolSubmit method)
(glide.core.ProcessPoolParaGlider method)
(glide.core.ProcessPoolSubmit method)
(glide.extensions.dask.DaskClientMap method)
(glide.extensions.dask.DaskParaGlider method)
get_splits() (glide.flow.ArraySplitByNode method)
(glide.flow.ArraySplitPush method)
(glide.flow.SplitByNode method)
(glide.flow.SplitPush method)
get_sql_executor() (glide.sql.BaseSQLNode method)
get_temp_table() (in module glide.sql_utils)
get_temp_table_name() (in module glide.sql_utils)
get_worker_count() (glide.core.ParaGlider method)
(glide.core.PoolSubmit method)
(glide.core.ProcessPoolParaGlider method)
(glide.core.ProcessPoolSubmit method)
(glide.extensions.dask.DaskClientMap method)
(glide.extensions.dask.DaskParaGlider method)
glide (module)
glide.core (module)
glide.extensions (module)
glide.extensions.celery (module)
glide.extensions.dask (module)
glide.extensions.pandas (module)
glide.extensions.rq (module)
glide.extensions.swifter (module)
glide.extract (module)
glide.filter (module)
glide.flow (module)
glide.load (module)
glide.math (module)
glide.pipelines (module)
glide.sql (module)
glide.sql_utils (module)
glide.transform (module)
glide.utils (module)
glide.version (module)
GlidePipeline (class in glide.core)
Glider (class in glide.core)
GliderScript (class in glide.core)
GliderTemplate (class in glide.pipelines)
global_state() (glide.core.Glider property)
GlobalState (class in glide.core)
GroupByNode (class in glide.core)
H
HashKey (class in glide.transform)
I
info() (in module glide.utils)
Input (glide.core.PushTypes attribute)
is_file_obj() (in module glide.utils)
is_function() (in module glide.utils)
is_pandas() (in module glide.utils)
is_sqlalchemy_conn() (in module glide.sql_utils)
is_sqlalchemy_transaction() (in module glide.sql_utils)
iterize() (in module glide.utils)
IterPush (class in glide.flow)
J
Join (class in glide.flow)
join() (in module glide.utils)
JSONDumps (class in glide.transform)
JSONLoads (class in glide.transform)
K
key() (glide.core.GroupByNode method)
L
LenPrint (class in glide.load)
listify() (in module glide.utils)
load_ini_config() (in module glide.utils)
load_json_config() (in module glide.utils)
load_yaml_config() (in module glide.utils)
M
Map (class in glide.transform)
N
name (glide.core.Node attribute)
nchunks() (in module glide.utils)
Node (class in glide.core)
nodes (glide.pipelines.GliderTemplate attribute)
NodeTemplate (class in glide.pipelines)
NoInputNode (class in glide.core)
not_none() (in module glide.utils)
O
open_filepath_or_buffer() (in module glide.utils)
P
PandasSQLNode (class in glide.extensions.pandas)
ParaGlider (class in glide.core)
pipeline (glide.core.Glider attribute)
(glide.core.ParaGlider attribute)
PlaceholderNode (class in glide.core)
plot() (glide.core.Glider method)
PollFunc (class in glide.flow)
PoolSubmit (class in glide.core)
PrettyPrint (class in glide.load)
Print (class in glide.load)
print() (glide.load.LenPrint method)
(glide.load.PrettyPrint method)
(glide.load.Print method)
(glide.load.ReprPrint method)
process() (glide.core.GroupByNode method)
(glide.core.Node method)
ProcessPoolParaGlider (class in glide.core)
ProcessPoolPush (class in glide.flow)
ProcessPoolSubmit (class in glide.core)
Profile (class in glide.core)
PushNode (class in glide.core)
PushTypes (class in glide.core)
Q
queue (glide.extensions.rq.RQParaGlider attribute)
R
read_excel() (in module glide.utils)
Reduce (class in glide.flow)
rename_tables() (glide.sql.BaseSQLNode method)
ReprPrint (class in glide.load)
reset_context() (glide.core.Node method)
reset_node_contexts() (in module glide.core)
Result (glide.core.PushTypes attribute)
Return (class in glide.flow)
rollback() (glide.sql.BaseSQLNode method)
rq_consume() (in module glide.extensions.rq)
RQJob (class in glide.extensions.rq)
RQParaGlider (class in glide.extensions.rq)
RQReduce (class in glide.extensions.rq)
RQTimeoutException
run() (glide.core.AssertFunc method)
(glide.core.AsyncIOSubmit method)
(glide.core.ContextPush method)
(glide.core.Node method)
(glide.core.PoolSubmit method)
(glide.core.Profile method)
(glide.core.PushNode method)
(glide.core.Shell method)
(glide.extensions.celery.CeleryApplyAsync method)
(glide.extensions.celery.CelerySendTask method)
(glide.extensions.dask.DaskClientPush method)
(glide.extensions.dask.DaskDataFrameApply method)
(glide.extensions.pandas.DataFrameApplyMap method)
(glide.extensions.pandas.DataFrameCSVExtract method)
(glide.extensions.pandas.DataFrameCSVLoad method)
(glide.extensions.pandas.DataFrameExcelExtract method)
(glide.extensions.pandas.DataFrameExcelLoad method)
(glide.extensions.pandas.DataFrameHTMLExtract method)
(glide.extensions.pandas.DataFrameHTMLLoad method)
(glide.extensions.pandas.DataFrameMethod method)
(glide.extensions.pandas.DataFrameRollingNode method)
(glide.extensions.pandas.DataFrameSQLExtract method)
(glide.extensions.pandas.DataFrameSQLLoad method)
(glide.extensions.pandas.DataFrameSQLTableExtract method)
(glide.extensions.pandas.DataFrameSQLTempLoad method)
(glide.extensions.pandas.FromDataFrame method)
(glide.extensions.pandas.ToDataFrame method)
(glide.extensions.rq.RQJob method)
(glide.extensions.swifter.SwifterApply method)
(glide.extract.CSVExtract method)
(glide.extract.EmailExtract method)
(glide.extract.ExcelExtract method)
(glide.extract.FileExtract method)
(glide.extract.SQLExtract method)
(glide.extract.SQLParamExtract method)
(glide.extract.SQLTableExtract method)
(glide.extract.URLExtract method)
(glide.filter.AttributeFilter method)
(glide.filter.DictKeyFilter method)
(glide.filter.Filter method)
(glide.flow.DateTimeWindowPush method)
(glide.flow.DateWindowPush method)
(glide.flow.FileConcat method)
(glide.flow.FileCopy method)
(glide.flow.Flatten method)
(glide.flow.IterPush method)
(glide.flow.Join method)
(glide.flow.PollFunc method)
(glide.flow.Reduce method)
(glide.flow.SplitPush method)
(glide.flow.WindowPush method)
(glide.flow.WindowReduce method)
(glide.load.CSVLoad method)
(glide.load.EmailLoad method)
(glide.load.ExcelLoad method)
(glide.load.FileLoad method)
(glide.load.FormatPrint method)
(glide.load.Print method)
(glide.load.SQLLoad method)
(glide.load.SQLTempLoad method)
(glide.load.URLLoad method)
(glide.math.Average method)
(glide.math.Sum method)
(glide.sql.AssertSQL method)
(glide.sql.SQLExecute method)
(glide.sql.SQLFetch method)
(glide.sql.SQLTransaction method)
(glide.transform.DictKeyTransform method)
(glide.transform.EmailMessageTransform method)
(glide.transform.Func method)
(glide.transform.HashKey method)
(glide.transform.JSONDumps method)
(glide.transform.JSONLoads method)
(glide.transform.Map method)
(glide.transform.Sort method)
(glide.transform.Transpose method)
run_args (glide.core.Node attribute)
run_kwargs (glide.core.Node attribute)
run_requires_data (glide.core.Node attribute)
,
[1]
(glide.core.NoInputNode attribute)
RuntimeContext (class in glide.core)
S
save_excel() (in module glide.utils)
set_global_results() (glide.core.Node method)
Shell (class in glide.core)
shutdown_executor() (glide.core.PoolSubmit method)
(glide.core.ProcessPoolSubmit method)
(glide.extensions.dask.DaskClientMap method)
size() (in module glide.utils)
SkipFalseNode (class in glide.flow)
Sort (class in glide.transform)
split_count_helper() (in module glide.utils)
SplitByNode (class in glide.flow)
SplitPush (class in glide.flow)
SQLCursorPushMixin (class in glide.sql)
SQLExecute (class in glide.sql)
SQLExtract (class in glide.extract)
SQLFetch (class in glide.sql)
SQLiteTemporaryTable (class in glide.sql_utils)
SQLLoad (class in glide.load)
SQLNode (class in glide.sql)
SQLParamExtract (class in glide.extract)
SQLTableExtract (class in glide.extract)
SQLTempLoad (class in glide.load)
SQLTransaction (class in glide.sql)
submit() (glide.core.PoolSubmit method)
(glide.core.ProcessPoolSubmit method)
(glide.extensions.dask.DaskClientMap method)
Sum (class in glide.math)
SwifterApply (class in glide.extensions.swifter)
T
TemporaryTable (class in glide.sql_utils)
ThreadPoolParaGlider (class in glide.core)
ThreadPoolPush (class in glide.flow)
ThreadPoolSubmit (class in glide.core)
ThreadReduce (class in glide.flow)
to_date() (in module glide.utils)
to_datetime() (in module glide.utils)
ToDataFrame (class in glide.extensions.pandas)
top_node() (glide.core.Glider property)
transaction() (glide.sql.BaseSQLNode method)
Transpose (class in glide.transform)
U
update_context() (glide.core.Node method)
update_downstream_context() (glide.core.Node method)
update_node_contexts() (in module glide.core)
URLExtract (class in glide.extract)
URLLoad (class in glide.load)
W
warn() (in module glide.utils)
window() (in module glide.utils)
WindowPush (class in glide.flow)
WindowReduce (class in glide.flow)
Navigation
Quickstart
Creating Nodes
Node Context
Runtime Context
Config Context
Cleaning Up
Common Nodes
Creating Pipelines
CLI Generation
Parallel Processing
Common Pipelines
Subpackages
Submodules
Related Topics
Documentation overview
Quick search