public void commitBlock ( final long workerId , final long usedBytesOnTier , final String tierAlias , final long blockId , final long length ) throws IOException { retryRPC ( ( RpcCallable < Void > ) ( ) -> { CommitBlockPRequest request = CommitBlockPRequest . newBuilder ( ) . setWorkerId ( workerId ) . setUsedBytesOnTier ( usedBytesOnTier ) . setTierAlias ( tierAlias ) . setBlockId ( blockId ) . setLength ( length ) . build ( ) ; mClient . commitBlock ( request ) ; return null ; } ) ; }
Commits a block on a worker .