我想这样做:protobuf->字节数组-> | HTTP post | ->字节数组->序列化为本地文件-> Hadoop中的MapReduce。
或任何其他方式可以解决我的问题?谢谢。
最佳答案
好的,问题现在已经解决。
org.apache.hadoop.io.SequenceFile.Writer为我工作。
Configuration conf = new Configuration();
LocalFileSystem fs = FileSystem.getLocal(conf);
SequenceFile.Writer writer = SequenceFile.createWriter(fs, conf, new Path("~/test"), LongWritable.class, BytesWritable.class);
LongWritable key = new LongWritable(1L);
BytesWritable val = new BytesWritable(protobufObject.toByteArray());
writer.append(key, val);
writer.close();
关于hadoop - 如何使用SequenceFileInputFormat将字节数组序列化为本地文件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20703541/