3

我正在尝试测试我的驱动程序,MRUnit我的MapDriver格式是MapDriver <LongWritable, Group, ImmutableBytesWritable, KeyValue>我找到了正确的序列化KeyValue但找不到一个Group,我收到以下错误。

    Group group = sfg.newGroup()
    parquetMapDriver.withInput(new LongWritable(), group);

在 io.serializations 的 conf 中没有实现序列化的适用类:类 org.apache.parquet.example.data.simple.SimpleGroup

我目前正在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 组类的序列化?

4

0 回答 0