我正在尝试测试我的驱动程序,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 组类的序列化?