mrunitParquet地板

jdzmm42g  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(211)

我正试着测试我的司机 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组类的序列化?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题