Project

General

Profile

« Previous | Next » 

Revision 52930

changed key type

View differences:

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