@@ -0,0 +1,2487 @@
+package es.tid.cosmos.mobility.labelling.secondhomes;%0A%0Aimport static java.util.Arrays.asList;%0A%0Aimport com.twitter.elephantbird.mapreduce.io.ProtobufWritable;%0Aimport org.apache.hadoop.io.NullWritable;%0Aimport org.apache.hadoop.mrunit.mapreduce.ReduceDriver;%0Aimport org.junit.Before;%0Aimport org.junit.Test;%0A%0Aimport es.tid.cosmos.mobility.data.MobDataUtil;%0Aimport es.tid.cosmos.mobility.data.MobProtocol.MobData;%0Aimport es.tid.cosmos.mobility.data.MobProtocol.TwoInt;%0Aimport es.tid.cosmos.mobility.data.TwoIntUtil;%0A%0A/**%0A *%0A * @author dmicol%0A */%0Apublic class PoiFilterSechomeAdjacentReducerTest %7B%0A    private ReduceDriver%3CProtobufWritable%3CTwoInt%3E, ProtobufWritable%3CMobData%3E,%0A            ProtobufWritable%3CTwoInt%3E, ProtobufWritable%3CMobData%3E%3E driver;%0A    %0A    @Before%0A    public void setUp() %7B%0A        this.driver = new ReduceDriver%3CProtobufWritable%3CTwoInt%3E,%0A                ProtobufWritable%3CMobData%3E, ProtobufWritable%3CTwoInt%3E,%0A                ProtobufWritable%3CMobData%3E%3E(%0A                        new PoiFilterSechomeAdjacentReducer());%0A    %7D%0A%0A    @Test%0A    public void testWithOutput() %7B%0A        final ProtobufWritable%3CTwoInt%3E key = TwoIntUtil.createAndWrap(57L, 32L);%0A        final ProtobufWritable%3CMobData%3E value1 = MobDataUtil.createAndWrap(17L);%0A        final ProtobufWritable%3CTwoInt%3E outKey1 = TwoIntUtil.createAndWrap(17L,%0A                                                                          32L);%0A        final ProtobufWritable%3CMobData%3E value2 = MobDataUtil.createAndWrap(88L);%0A        final ProtobufWritable%3CTwoInt%3E outKey2 = TwoIntUtil.createAndWrap(88L,%0A                                                                          32L);%0A        final ProtobufWritable%3CMobData%3E outValue = MobDataUtil.createAndWrap(%0A                NullWritable.get());%0A        this.driver%0A                .withInput(key, asList(value1, value2))%0A                .withOutput(outKey1, outValue)%0A                .withOutput(outKey2, outValue)%0A                .runTest();%0A    %7D%0A    %0A    @Test%0A    public void testEmptyOutput() %7B%0A        final ProtobufWritable%3CTwoInt%3E key = TwoIntUtil.createAndWrap(57L, 32L);%0A        final ProtobufWritable%3CMobData%3E value1 = MobDataUtil.createAndWrap(17L);%0A        final ProtobufWritable%3CMobData%3E value2 = MobDataUtil.createAndWrap(%0A                NullWritable.get());%0A        final ProtobufWritable%3CMobData%3E value3 = MobDataUtil.createAndWrap(88L);%0A        this.driver%0A                .withInput(key, asList(value1, value2, value3))%0A                .runTest();%0A    %7D%0A%7D%0A

Add PoiFilterSechomeAdjacentReducerTest.