@Test
    public void testFiltering() throws ExecException {
        String[] expected = {
            "(4,323,242,http://www.google.com/url&url=http%3A%2F%2Fwww.tagesschau.de&q=barack%20obama)",
            "(5,423,342,http://www.google.com/url&url=http%3A%2F%2Fwww.bild.de&q=obama)"
        };


        pigServer = new PigServer(ExecType.LOCAL);

        try {
            Util.registerMultiLineQuery(pigServer, "a = LOAD '" + INPUT_FILE +
                    "' AS (id:int, grp:int, additional:int, referer:chararray); " +
                    "b = FILTER a BY " +
                    "com.adition.pig.filtering.string.CONTAINS(referer, 'obama');");

            Iterator<Tuple> iter = pigServer.openIterator("b");
            int counter = 0;
            while (iter.hasNext()){
                assertEquals(expected[counter++].toString(), iter.next().toString());
            }

            assertEquals(expected.length, counter);

        } catch (Exception e) {
            e.printStackTrace();
            Assert.fail();
        }

        pigServer.shutdown();

    }