Spring XD
org.springframework.xd.spark.streaming.java

Interface Processor<I extends org.apache.spark.streaming.api.java.JavaDStreamLike,O extends org.apache.spark.streaming.api.java.JavaDStreamLike>

Spring XD