1

AvroMapper需要2个参数:

public static class AvroRecordMapper
        extends AvroMapper <MyRecord,Pair <CharSequence,CharSequence>>

mapDriver 需要 4 个参数:

K1 V1 K2 V2

我可以MRUnit用于单元测试AvroMapper吗?

4

0 回答 0