@Override
      public void end(FanOutOneBlockAsyncDFSOutput output) {
        try {
          endFileLeaseMethod.invoke(output.getClient(), getUniqKey(output));
        } catch (IllegalAccessException | InvocationTargetException e) {
          throw new RuntimeException(e);
        }
      }
Helper class for implementing {@link FanOutOneBlockAsyncDFSOutput}.
hbase-asyncfs/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputHelper.java