public boolean triggerCheckpoint ( CheckpointMetaData checkpointMetaData , CheckpointOptions checkpointOptions , boolean advanceToEndOfEventTime ) throws Exception { throw new UnsupportedOperationException ( String . format ( "triggerCheckpoint not supported by %s" , this . getClass ( ) . getName ( ) ) ) ; }
This method is called to trigger a checkpoint asynchronously by the checkpoint coordinator .