Created
July 21, 2015 08:00
-
-
Save forcemax/5c976115be31f5e54583 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public final void execute(Tuple input) { | |
if (isTickTuple(input)) { | |
getLogger().debug("Received tick tuple, triggering emit of current rankings"); | |
emitRankings(collector); | |
} else { | |
getLogger().debug("tuple : {}", input); | |
updateRankingsWithTuple(input); | |
} | |
collector.ack(input); | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment