我正试着测试我的司机 MRUnit
还有我的 MapDriver
格式为 MapDriver <LongWritable, Group, ImmutableBytesWritable, KeyValue>
我找到了正确的序列化 KeyValue
但找不到一个 Group
我得到以下错误。
Group group = sfg.newGroup()
parquetMapDriver.withInput(new LongWritable(), group);
在io.serializations:class org.apache.parquet.example.data.simple.simplegroup中没有在conf中实现序列化的适用类
我正在设置 io.serializations
就像这样
parquetMapDriver = MapDriver.newMapDriver(parquetMapper);
conf = parquetMapDriver.getConfiguration();
conf.setStrings("io.serializations", conf.get("io.serializations"),
MutationSerialization.class.getName(),
KeyValueSerialization.class.getName(),
WritableSerialization.class.getName(),
ResultSerialization.class.getName());
在哪里可以找到hadoop组类的序列化?
暂无答案!
目前还没有任何答案,快来回答吧!