protected static void waitForDataDelivery ( int waitTimeSecs ) throws InterruptedException { LOG . info ( "Since the Buffering Hints IntervalInSeconds parameter is specified as: " + waitTimeSecs + " seconds. Waiting for " + waitTimeSecs + " seconds for the data to be written to S3 bucket" ) ; TimeUnit . SECONDS . sleep ( waitTimeSecs ) ; LOG . info ( "Data delivery to S3 bucket " + s3BucketName + " is complete" ) ; }
Method to wait for the specified buffering interval seconds so that data will be delivered to corresponding destination .