protected void scheduleAsyncPersist ( ) throws IOException { try ( CloseableResource < FileSystemMasterClient > masterClient = mContext . acquireMasterClientResource ( ) ) { ScheduleAsyncPersistencePOptions persistOptions = FileSystemOptions . scheduleAsyncPersistDefaults ( mContext . getPathConf ( mUri ) ) . toBuilder ( ) . setCommonOptions ( mOptions . getCommonOptions ( ) ) . build ( ) ; masterClient . get ( ) . scheduleAsyncPersist ( mUri , persistOptions ) ; } }
Schedules the async persistence of the current file .