public CompletableFuture executeOpenFile()

in hadoop-api-shim/src/main/java/org/apache/hadoop/fs/shim/impl/FileSystemShimImpl.java [150:166]

• 14 lines of code
• 3 McCabe index (conditional complexity)

    public CompletableFuture<FSDataInputStream> executeOpenFile(final OpenFileBuilder builder)
        throws IllegalArgumentException, UnsupportedOperationException, IOException {

      if (openFileFound()) {
        try {
          // use the builder API; return the result
          return openFileThroughBuilder.executeOpenFile(builder);
        } catch (ClassCastException | UnsupportedOperationException e) {
          LOG.warn(
              "Failed to open file using openFileThroughBuilder, falling back to classicOpenFile",
              e);
          // disable the API for this shim instance and fall back to classicOpenFile.
          useOpenFileAPI.set(false);
        }
      }
      return classicOpenFile.executeOpenFile(builder);
    }