草庐IT

CustomWritable

全部标签

java - 如何从 Hadoop 中的文本解析 CustomWritable

假设我在文本文件中有特定用户的时间戳值,例如#userid;unix-timestamp;value1;2010-01-0100:00:00;102;2010-01-0100:00:00;201;2010-01-0101:00:00;112;2010-01-0101:00:00,211;2010-01-0200:00:00;122;2010-01-0200:00:00;22我有一个自定义类“SessionSummary”实现readFields和write的WritableComparable。它的目的是汇总每个日历日每个用户的所有值。所以mapper将行映射到每个用户,reducer