Tokenizing unprocessed tweets in-memory

TweetParser.java

public class TweetParser {
    
    SQLQuery<SpaceDocument> getTemplate() {
        return new SQLQuery<SpaceDocument>("Tweet", "Processed = ?", false);
    }

    public SpaceDocument eventListener(SpaceDocument tweet) {
        
        Long id = (Long) tweet.getProperty("Id");
        String text = tweet.getProperty("Text");
        if (text != null) {
            //tokenize tweet in memory
            gigaSpace.write(new TokenizedTweet(id, tokenize(text)));
        }

        //mark tweet as processed in memory
        tweet.setProperty("Processed", true);
        return tweet;
    }
}