This project provides couple of sample applications which leverage stream-stream join, window aggregation, deduplication respectively.
This project depends on HDP version of Spark, so you may want to modify Spark version before building the project to accomodate your installation of Spark.