public void generateNoMoreDataEvent ( PushSource . Context context ) { LOG . info ( "No More data to process, Triggered No More Data Event" ) ; BatchContext batchContext = context . startBatch ( ) ; CommonEvents . NO_MORE_DATA . create ( context , batchContext ) . createAndSend ( ) ; context . processBatch ( batchContext ) ; }
Generates the no - more - data event