LocalHadoopStorage extends LocalStorage { @Override public InputStream getDependency(final Dependency dep) throws IOException { if (!dependencyFetchingEnabled()) { throw new UnsupportedOperationException("Dependency fetching is not enabled."); } return this.http.open(resolveAbsoluteDependencyURI(dep)); } @Inject  LocalHadoopStorage(final AzkabanCommonModuleConfig config,
      @Named("local_cached_httpFS") @Nullable final FileSystem http); @Override InputStream getDependency(final Dependency dep); @Override boolean dependencyFetchingEnabled(); @Override String getDependencyRootPath();  }
@Test public void testGetDependency() throws Exception { FSDataInputStream sampleInputStream = mock(FSDataInputStream.class); doReturn(sampleInputStream).when(this.http).open(expectedPathDepA); assertEquals(sampleInputStream, this.localStorage.getDependency(depA)); }