HdfsStorage implements Storage { @Override public boolean deleteProject(final String key) { this.hdfsAuth.authorize(); final Path path = fullProjectPath(key); try { return this.hdfsFileContext.delete(path, false); } catch (final IOException e) { log.error("HDFS project file delete failed on " + path, e); return false; } } @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 testDeleteProject() throws Exception { this.hdfsStorage.deleteProject("1/1-hash.zip"); verify(this.hdfsFileContext).delete(new Path(PRJ_ROOT_URI + "/1/1-hash.zip"), false); }