Package com.northconcepts.datapipeline.job

Class AbstractJobCallback<R extends DataReader,W extends DataWriter>

java.lang.Object
com.northconcepts.datapipeline.job.AbstractJobCallback<R,W>
All Implemented Interfaces:
JobCallback<R,W>
Direct Known Subclasses:
DefaultJobCallback
public abstract class AbstractJobCallback<R extends DataReader,W extends DataWriter> extends Object implements JobCallback<R,W>
A default, abstract implementation of JobCallback.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface com.northconcepts.datapipeline.job.JobCallback

    JobCallback.Helper

  • Field Summary

    Fields inherited from interface com.northconcepts.datapipeline.job.JobCallback

    NULL

  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractJobCallback()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onFailure(R reader, W writer, Record currentRecord, Throwable exception)
    Called after a failed or cancelled transfer closes the reader and writer, with the record in progress or null; the default rethrows the exception, making Job.run() throw it.
    void
    onProgress(R reader, W writer, Record currentRecord)
    Called on the job's thread after each record is written.
    void
    onSuccess(R reader, W writer)
    Called after all records were transferred and the reader and writer closed.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait