Package com.northconcepts.datapipeline.job
package com.northconcepts.datapipeline.job
Running, tracking, and managing data transfer pipelines.
-
ClassDescriptionUsed to run, pause, and cancel Runnables.A default, abstract implementation of JobCallback.DataReaderDecorator<T extends DataReader>A Decorator that allows a DataReader to be wrapped in new behavior.A factory to create new DataReaders.A DataReader that sequentially reads from an Iterator of other DataReaders.DataWriterDecorator<T extends DataWriter>A Decorator that allows a DataWriter to be wrapped in new behavior.A factory to create new DataWriters.A default implementation of JobCallback.A unit of work that can be run synchronously or asynchronously, paused, resumed, cancelled and monitored.Used to run, manage, and track pipelines.Receives the progress and outcome of a
Job; the defaultonFailurerethrows the exception.Factory for default callbacks such asJobCallback.NULL.Receives start, pause, resume and finish notifications for jobs; register withJob.addJobLifecycleListener(JobLifecycleListener).JobTemplate is the base type for classes that transfer records from DataReaders to DataWriters.The defaultJobTemplate, which runs each transfer as aJob.Runs aRunnableas anAbstractJob; pausing has no effect and cancelling only interrupts its thread.