@Override
public void open(String filePath, CompressionCodec codeC, CompressionType compType)
throws IOException {
super.open(filePath, codeC, compType);
if (closed) {
opened = true;
}
}
HDFSTestSeqWriter.java 文件源码
java
阅读 25
收藏 0
点赞 0
评论 0
项目:flume-release-1.7.0
作者:
评论列表
文章目录