Index

_

__init__() (BatchProcessor method) (BatchResults method) (ClosedLoopBatchProcessor method) (CreateReportingConstraintsTask method) (CSVBatchSink method) (CSVBatchSource method) (CSVLoad2Neo4jTask method) (CypherBatchSink method) (CypherBatchSource method) (ETLContext method) (ExecuteCypherTask method) (GDSTask method) (Neo4jContext method) (Neo4jProgressReporter method) (ParallelBatchProcessor method) (ParallelBatchProcessor.SingleBatchWrapper method) (ParallelCSVLoad2Neo4jTask method) (ParallelParquetLoad2Neo4jTask method) (ParallelSQLLoad2Neo4jTask method) (ParallelTaskGroup method) (ParquetBatchSource method) (ParquetLoad2Neo4jTask method) (ProgressReporter method) (SplittingBatchProcessor method) (SQLBatchSink method) (SQLBatchSource method) (SQLContext method) (Task method) (TaskGroup method) (TaskReturn method) (ValidationBatchProcessor method)

A

abort_on_fail() (Task method) (TaskGroup method)

add_sigint_handler() (in module etl_lib.core.utils) append_result() (in module etl_lib.core.BatchProcessor) append_results() (in module etl_lib.core.ETLContext)

B

batch_size (BatchResults attribute)

BatchProcessor (class in etl_lib.core.BatchProcessor) BatchResults (class in etl_lib.core.BatchProcessor)

C

canonical_int_or_str_id_extractor() (in module etl_lib.core.SplittingBatchProcessor) canonical_integer_id_extractor() (in module etl_lib.core.SplittingBatchProcessor) chunk (BatchResults attribute) ClosedLoopBatchProcessor (class in etl_lib.core.ClosedLoopBatchProcessor) context (BatchProcessor attribute) (Task attribute)

CreateReportingConstraintsTask (class in etl_lib.task.CreateReportingConstraintsTask) CSVBatchSink (class in etl_lib.data_sink.CSVBatchSink) CSVBatchSource (class in etl_lib.data_source.CSVBatchSource) CSVLoad2Neo4jTask (class in etl_lib.task.data_loading.CSVLoad2Neo4jTask) CypherBatchSink (class in etl_lib.data_sink.CypherBatchSink) CypherBatchSource (class in etl_lib.data_source.CypherBatchSource)

D

data (QueryResult attribute) delete_runs() (in module etl_lib.cli.run_tools)

depth (Task attribute) dict_id_extractor() (in module etl_lib.core.SplittingBatchProcessor)

E

end_time (ProgressReporter attribute) (Task attribute) engine (SQLContext attribute) env() (ETLContext method) error (TaskReturn attribute) etl_lib module etl_lib.cli module etl_lib.cli.run_tools module etl_lib.core module etl_lib.core.BatchProcessor module etl_lib.core.ClosedLoopBatchProcessor module etl_lib.core.ETLContext module etl_lib.core.ParallelBatchProcessor module etl_lib.core.ProgressReporter module etl_lib.core.SplittingBatchProcessor module etl_lib.core.Task module etl_lib.core.utils module etl_lib.core.ValidationBatchProcessor module etl_lib.data_sink module etl_lib.data_sink.CSVBatchSink module etl_lib.data_sink.CypherBatchSink module

etl_lib.data_sink.SQLBatchSink module etl_lib.data_source module etl_lib.data_source.CSVBatchSource module etl_lib.data_source.CypherBatchSource module etl_lib.data_source.ParquetBatchSource module etl_lib.data_source.SQLBatchSource module etl_lib.task module etl_lib.task.CreateReportingConstraintsTask module etl_lib.task.data_loading module etl_lib.task.data_loading.CSVLoad2Neo4jTask module etl_lib.task.data_loading.ParallelCSVLoad2Neo4jTask module etl_lib.task.data_loading.ParallelParquetLoad2Neo4jTask module etl_lib.task.data_loading.ParallelSQLLoad2Neo4jTask module etl_lib.task.data_loading.ParquetLoad2Neo4jTask module etl_lib.task.ExecuteCypherTask module etl_lib.task.GDSTask module ETLContext (class in etl_lib.core.ETLContext) execute() (Task method) ExecuteCypherTask (class in etl_lib.task.ExecuteCypherTask)

F

finished_task() (Neo4jProgressReporter method) (ProgressReporter method)

G

gds() (in module etl_lib.core.ETLContext) GDSTask (class in etl_lib.task.GDSTask) get_batch() (BatchProcessor method) (ClosedLoopBatchProcessor method) (CSVBatchSink method) (CSVBatchSource method) (CypherBatchSink method) (CypherBatchSource method) (ParallelBatchProcessor method) (ParallelBatchProcessor.SingleBatchWrapper method) (ParquetBatchSource method) (SplittingBatchProcessor method) (SQLBatchSink method) (SQLBatchSource method) (ValidationBatchProcessor method)

get_reporter() (in module etl_lib.core.ProgressReporter) get_total_rows() (ParquetBatchSource static method)

M

merge_summery() (in module etl_lib.core.utils) module etl_lib etl_lib.cli etl_lib.cli.run_tools etl_lib.core etl_lib.core.BatchProcessor etl_lib.core.ClosedLoopBatchProcessor etl_lib.core.ETLContext etl_lib.core.ParallelBatchProcessor etl_lib.core.ProgressReporter etl_lib.core.SplittingBatchProcessor etl_lib.core.Task etl_lib.core.utils etl_lib.core.ValidationBatchProcessor etl_lib.data_sink etl_lib.data_sink.CSVBatchSink etl_lib.data_sink.CypherBatchSink etl_lib.data_sink.SQLBatchSink etl_lib.data_source etl_lib.data_source.CSVBatchSource etl_lib.data_source.CypherBatchSource etl_lib.data_source.ParquetBatchSource etl_lib.data_source.SQLBatchSource etl_lib.task etl_lib.task.CreateReportingConstraintsTask etl_lib.task.data_loading etl_lib.task.data_loading.CSVLoad2Neo4jTask etl_lib.task.data_loading.ParallelCSVLoad2Neo4jTask etl_lib.task.data_loading.ParallelParquetLoad2Neo4jTask etl_lib.task.data_loading.ParallelSQLLoad2Neo4jTask etl_lib.task.data_loading.ParquetLoad2Neo4jTask etl_lib.task.ExecuteCypherTask etl_lib.task.GDSTask

N

Neo4jContext (class in etl_lib.core.ETLContext)

Neo4jProgressReporter (class in etl_lib.core.ProgressReporter)

P

ParallelBatchProcessor (class in etl_lib.core.ParallelBatchProcessor) ParallelBatchProcessor.SingleBatchWrapper (class in etl_lib.core.ParallelBatchProcessor) ParallelBatchResult (class in etl_lib.core.ParallelBatchProcessor) ParallelCSVLoad2Neo4jTask (class in etl_lib.task.data_loading.ParallelCSVLoad2Neo4jTask) ParallelParquetLoad2Neo4jTask (class in etl_lib.task.data_loading.ParallelParquetLoad2Neo4jTask)

ParallelSQLLoad2Neo4jTask (class in etl_lib.task.data_loading.ParallelSQLLoad2Neo4jTask) ParallelTaskGroup (class in etl_lib.core.Task) ParquetBatchSource (class in etl_lib.data_source.ParquetBatchSource) ParquetLoad2Neo4jTask (class in etl_lib.task.data_loading.ParquetLoad2Neo4jTask) predecessor (BatchProcessor attribute) ProgressReporter (class in etl_lib.core.ProgressReporter)

Q

query_database() (Neo4jContext method)

QueryResult (class in etl_lib.core.ETLContext)

R

register_tasks() (Neo4jProgressReporter method) (ProgressReporter method) report_progress() (Neo4jProgressReporter method) (ProgressReporter method) run_internal() (CreateReportingConstraintsTask method) (CSVLoad2Neo4jTask method) (ExecuteCypherTask method) (GDSTask method) (ParallelCSVLoad2Neo4jTask method) (ParallelParquetLoad2Neo4jTask method) (ParallelSQLLoad2Neo4jTask method) (ParallelTaskGroup method) (ParquetLoad2Neo4jTask method) (Task method) (TaskGroup method)

S

session() (Neo4jContext method) setup_logging() (in module etl_lib.core.utils) SplittingBatchProcessor (class in etl_lib.core.SplittingBatchProcessor) SQLBatchSink (class in etl_lib.data_sink.SQLBatchSink) SQLBatchSource (class in etl_lib.data_source.SQLBatchSource) SQLContext (class in etl_lib.core.ETLContext) start_time (ProgressReporter attribute) (Task attribute)

started_task() (Neo4jProgressReporter method) (ProgressReporter method) statistics (BatchResults attribute) sub_tasks() (TaskGroup method) success (Task attribute) (TaskReturn attribute) summery (QueryResult attribute) (TaskReturn attribute)

T

task (BatchProcessor attribute) Task (class in etl_lib.core.Task) task_name() (Task method) (TaskGroup method)

TaskGroup (class in etl_lib.core.Task) TaskReturn (class in etl_lib.core.Task) transform_dict() (in module etl_lib.task.GDSTask) tuple_id_extractor() (in module etl_lib.core.SplittingBatchProcessor)

U

uuid (Task attribute)

V

ValidationBatchProcessor (class in etl_lib.core.ValidationBatchProcessor)