public void process ( Map < String , String > offsets , int batchSize , ReportErrorDelegate reportErrorDelegate ) throws StageException , PipelineRuntimeException { this . reportErrorDelegate = reportErrorDelegate ; getStage ( ) . setReportErrorDelegate ( this ) ; try { MDC . put ( LogConstants . STAGE , getStage ( ) . getInfo ( ) . getInstanceName ( ) ) ; getStage ( ) . execute ( offsets , batchSize ) ; } finally { MDC . put ( LogConstants . STAGE , "" ) ; } }
Process method for Push source that will give control of the execution to the origin .