We're also releasing an alpha version of a Flink connector for S2 streams:
github.com/s2-streamsto...
See the demos for an example real-time feature pipeline for turning beacons (stored on S2) into complex events, and ultimately a dynamic table of ML features stored upsert-style on an S2 stream.