Same as the other Twitter PoC but using Flink SQL to compare with the Java Version - View it on GitHub