mysql to hive 这里代码是不是有问题

[maidou75293]

obj != null && obj instanceof Map 为啥是map ?

@OverRide
public void writeRecord(Row row) throws IOException {
try {
if (row.getArity() == 2) {
Object obj = row.getField(0);
if (obj != null && obj instanceof Map) {
emitWithMap((Map<String, Object>) obj, row);
}
} else {
emitWithRow(row);
}
} catch (Throwable e) {
logger.error("{}", e);
}
}

[kanata163]

这是为了兼容binlong和kafka过来的map数据