HdfsStorage implements Storage { @Override public InputStream getProject(final String key) throws IOException { this.hdfsAuth.authorize(); Path projectFilePath = fullProjectPath(key); log.info("Opening for reading, project file " + projectFilePath); return this.hdfsFileContext.open(projectFilePath); } @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 testGetProject() throws Exception { this.hdfsStorage.getProject("1/1-hash.zip"); verify(this.hdfsFileContext).open(new Path(PRJ_ROOT_URI + "/1/1-hash.zip")); }