1

我正在尝试使用元数据和 createflag 创建序列文件,但它给了我错误:

无法解析 createwriter 的方法

我是 Hadoop 和 Java 编程的新手。我在下面添加了代码。

我正在尝试在带有键的序列文件中添加多个图像。一旦序列文件被创建,如果它不存在并且如果它存在则附加图像数据。

Path path = new Path("hdfs://localhost:8020/user/image_data/SequenceFileCodecTest.seq");
FSDataInputStream in = null;
Text key = new Text();
BytesWritable value = new BytesWritable();
SequenceFile.Metadata metadata = null;
SequenceFile.Writer writer = null;
Option optPath = SequenceFile.Writer.file(path);
Option optKey = SequenceFile.Writer.keyClass(key.getClass());
Option optVal = SequenceFile.Writer.valueClass(value.getClass());
Option optCom = SequenceFile.Writer.compression(SequenceFile.CompressionType.RECORD);
final EnumSet<CreateFlag> flag = EnumSet.of(CreateFlag.CREATE,CreateFlag.APPEND);
writer = SequenceFile.createWriter(conf,optPath,optKey, optVal,optCom,new DefaultCodec(),metadata,flag);
4

0 回答 0