Method exec

tutorial/src/org/apache/pig/tutorial/NGramGenerator.java:48–67

(Tuple input)

    private static final int _ngramSizeLimit = 2;
  
    public DataBag exec(Tuple input) throws IOException {
        if (input == null || input.size() == 0)
            return null;
        try{
            DataBag output = DefaultBagFactory.getInstance().newDefaultBag();
            String query = (String)input.get(0);
            String[] words = TutorialUtil.splitToWords(query);
            Set<String> ngrams = new HashSet<String>();
            TutorialUtil.makeNGram(words, ngrams, _ngramSizeLimit);
            for (String ngram : ngrams) {
                Tuple t = TupleFactory.getInstance().newTuple(1);
                t.set(0, ngram);
                output.add(t);
            }
            return output;
        }catch(Exception e){
            System.err.println("NGramGenerator: failed to process input; error - " + e.getMessage());
            return null;
        }
    }

    @Override
    /**