HdfsStorage implements Storage { @Override public InputStream getDependency(final Dependency dep) throws IOException { if (!dependencyFetchingEnabled()) { throw new UnsupportedOperationException("Dependency fetching is not enabled."); } this.hdfsAuth.authorize(); return this.http.open(resolveAbsoluteDependencyURI(dep)); } @Inject  HdfsStorage(final AzkabanCommonModuleConfig config, final HdfsAuth hdfsAuth,
      @Named("hdfsFileContext") final FileContext hdfsFileContext,
      @Named("hdfs_cached_httpFS") @Nullable final FileSystem http); @Override InputStream getProject(final String key); @Override String putProject(final ProjectStorageMetadata metadata, final File localFile); @Override InputStream getDependency(final Dependency dep); @Override boolean dependencyFetchingEnabled(); @Override boolean deleteProject(final String key); @Override String getDependencyRootPath();  }
@Test public void testGetDependency() throws Exception { this.hdfsStorage.getDependency(depA); verify(this.http).open(expectedPathDepA); }