@@ -0,0 +1,2088 @@
+package es.tid.cosmos.mobility.adjacentextraction;%0A%0Aimport static java.util.Arrays.asList;%0Aimport java.io.IOException;%0Aimport java.util.List;%0A%0Aimport com.twitter.elephantbird.mapreduce.io.ProtobufWritable;%0Aimport org.apache.hadoop.mrunit.mapreduce.MapDriver;%0Aimport org.apache.hadoop.mrunit.types.Pair;%0Aimport static org.junit.Assert.assertEquals;%0Aimport org.junit.Before;%0Aimport org.junit.Test;%0A%0Aimport es.tid.cosmos.mobility.data.MobProtocol.Poi;%0Aimport es.tid.cosmos.mobility.data.MobProtocol.PoiNew;%0Aimport es.tid.cosmos.mobility.data.MobProtocol.TwoInt;%0Aimport es.tid.cosmos.mobility.data.PoiUtil;%0Aimport es.tid.cosmos.mobility.data.TwoIntUtil;%0A%0A/**%0A *%0A * @author dmicol%0A */%0Apublic class AdjAddUniqueIdPoiToPoiNewMapperTest %7B%0A    private MapDriver%3C%0A            ProtobufWritable%3CTwoInt%3E, ProtobufWritable%3CPoi%3E,%0A            ProtobufWritable%3CTwoInt%3E, ProtobufWritable%3CPoiNew%3E%3E driver;%0A    %0A    @Before%0A    public void setUp() %7B%0A        this.driver = new MapDriver%3CProtobufWritable%3CTwoInt%3E,%0A                ProtobufWritable%3CPoi%3E, ProtobufWritable%3CTwoInt%3E,%0A                ProtobufWritable%3CPoiNew%3E%3E(%0A                        new AdjAddUniqueIdPoiToPoiNewMapper());%0A    %7D%0A    %0A    @Test%0A    public void testReduce() throws IOException %7B%0A        Poi poi = PoiUtil.create(1, 2L, 3, 4, 5, 1, 4.3D, 6, 7,%0A                                 0, 9.1D, 10, 11, 1, 8.45D, 1, 0);%0A        List%3CPair%3CProtobufWritable%3CTwoInt%3E, ProtobufWritable%3CPoiNew%3E%3E%3E result =%0A                this.driver%0A                        .withInput(TwoIntUtil.createAndWrap(137L, 201L),%0A                                   PoiUtil.wrap(poi))%0A                        .run();%0A        ProtobufWritable%3CTwoInt%3E keyWrapper = result.get(0).getFirst();%0A        keyWrapper.setConverter(TwoInt.class);%0A        TwoInt key = keyWrapper.get();%0A        assertEquals(2, key.getNum1());%0A        assertEquals(11, key.getNum2());%0A        ProtobufWritable%3CPoiNew%3E valueWrapper = result.get(0).getSecond();%0A        valueWrapper.setConverter(PoiNew.class);%0A        PoiNew value = valueWrapper.get();%0A        assertEquals(37, value.getId());%0A    %7D%0A%7D%0A

Add AdjAddUniqueIdPoiToPoiNewMapperTest.java.