Page History

public class WordCountTupleExtractor implements StreamTupleExtractor<String, String, Integer> {
    @Override 
	 @Override public Map.Entry<String, Integer> extract(String msg) {
        String[] tokens = msg.split("=");
        
 		return new IgniteBiTuple<>(tokens[0], Integer.valueOf(tokens[1]));
    }
}