etl_lib.core package

Submodules

• etl_lib.core.BatchProcessor module
  • BatchProcessor
    • BatchProcessor.__init__()
    • BatchProcessor.context
    • BatchProcessor.get_batch()
    • BatchProcessor.predecessor
    • BatchProcessor.task
  • BatchResults
    • BatchResults.__init__()
    • BatchResults.batch_size
    • BatchResults.chunk
    • BatchResults.statistics
  • append_result()
• etl_lib.core.ClosedLoopBatchProcessor module
  • ClosedLoopBatchProcessor
    • ClosedLoopBatchProcessor.__init__()
    • ClosedLoopBatchProcessor.get_batch()
• etl_lib.core.ETLContext module
  • ETLContext
    • ETLContext.__init__()
    • ETLContext.env()
  • Neo4jContext
    • Neo4jContext.__init__()
    • Neo4jContext.query_database()
    • Neo4jContext.session()
  • QueryResult
    • QueryResult.data
    • QueryResult.summery
  • SQLContext
    • SQLContext.__init__()
  • append_results()
  • gds()
• etl_lib.core.ParallelBatchProcessor module
  • ParallelBatchProcessor
    • ParallelBatchProcessor.SingleBatchWrapper
      • ParallelBatchProcessor.SingleBatchWrapper.__init__()
      • ParallelBatchProcessor.SingleBatchWrapper.get_batch()
    • ParallelBatchProcessor.__init__()
    • ParallelBatchProcessor.get_batch()
  • ParallelBatchResult
• etl_lib.core.ProgressReporter module
  • Neo4jProgressReporter
    • Neo4jProgressReporter.__init__()
    • Neo4jProgressReporter.finished_task()
    • Neo4jProgressReporter.register_tasks()
    • Neo4jProgressReporter.report_progress()
    • Neo4jProgressReporter.started_task()
  • ProgressReporter
    • ProgressReporter.__init__()
    • ProgressReporter.end_time
    • ProgressReporter.finished_task()
    • ProgressReporter.register_tasks()
    • ProgressReporter.report_progress()
    • ProgressReporter.start_time
    • ProgressReporter.started_task()
  • get_reporter()
• etl_lib.core.SplittingBatchProcessor module
  • SplittingBatchProcessor
    • SplittingBatchProcessor.__init__()
    • SplittingBatchProcessor.get_batch()
  • dict_id_extractor()
  • tuple_id_extractor()
• etl_lib.core.Task module
  • ParallelTaskGroup
    • ParallelTaskGroup.__init__()
    • ParallelTaskGroup.run_internal()
  • Task
    • Task.__init__()
    • Task.abort_on_fail()
    • Task.context
    • Task.depth
    • Task.end_time
    • Task.execute()
    • Task.run_internal()
    • Task.start_time
    • Task.success
    • Task.task_name()
    • Task.uuid
  • TaskGroup
    • TaskGroup.__init__()
    • TaskGroup.abort_on_fail()
    • TaskGroup.run_internal()
    • TaskGroup.sub_tasks()
    • TaskGroup.task_name()
  • TaskReturn
    • TaskReturn.__init__()
    • TaskReturn.error
    • TaskReturn.success
    • TaskReturn.summery
• etl_lib.core.ValidationBatchProcessor module
  • ValidationBatchProcessor
    • ValidationBatchProcessor.__init__()
    • ValidationBatchProcessor.get_batch()
• etl_lib.core.utils module
  • add_sigint_handler()
  • merge_summery()
  • setup_logging()

Module contents