THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!

Page History

Versions Compared

Key

This line was added.
This line was removed.
Formatting was changed.

...

Code Block

language	java

public class WordCountTupleExtractor implements StreamTupleExtractor<String, String, Integer> {

    @Override public Map.Entry<String, Integer> extract(String msg) {

        String[] tokens = msg.split("=");

        return new IgniteBiTuple<>(tokens[0], Integer.valueOf(tokens[1]));

    }

}

Streamer Lifecycle

Implementation Tips

...