Revision 52930
Added by Sandro La Bruzzo over 5 years ago
modules/dnet-mapreduce-jobs/branches/beta/src/main/java/eu/dnetlib/data/mapreduce/hbase/dataimport/ScholexplorerMapper.java | ||
---|---|---|
7 | 7 |
import eu.dnetlib.actionmanager.actions.AtomicAction; |
8 | 8 |
import eu.dnetlib.actionmanager.common.Agent; |
9 | 9 |
import eu.dnetlib.miscutils.datetime.DateUtils; |
10 |
import org.apache.hadoop.io.LongWritable; |
|
11 | 10 |
import org.apache.hadoop.io.Text; |
12 | 11 |
import org.apache.hadoop.mapreduce.Mapper; |
13 | 12 |
|
... | ... | |
16 | 15 |
import java.util.List; |
17 | 16 |
import java.util.Map; |
18 | 17 |
|
19 |
public class ScholexplorerMapper extends Mapper<LongWritable, Text, Text, Text> {
|
|
18 |
public class ScholexplorerMapper extends Mapper<Text, Text, Text, Text> {
|
|
20 | 19 |
|
21 | 20 |
private ActionFactory factory; |
22 | 21 |
private JsonParser parser; |
... | ... | |
58 | 57 |
} |
59 | 58 |
|
60 | 59 |
@Override |
61 |
protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
|
|
60 |
protected void map(Text key, Text value, Context context) throws IOException, InterruptedException {
|
|
62 | 61 |
|
63 | 62 |
final String inputJson =value.toString(); |
64 | 63 |
final JsonObject rootElement = parser.parse(inputJson).getAsJsonObject(); |
Also available in: Unified diff
changed key type