dd4f891d6d9d

已解决，Filter Compositor返回前做了foreachRDD，将filter后的结果cache就可以了，3q all the same

StreamingPro 基于Spark 2.1.1版本 支持Spark Streaming

源码构建简化 很多人吐槽StreamingPro构建实在太麻烦了。看源码都难。然后花了一天时间做了比较大重构，这次只依赖于ServiceFramework项目。具体构建方式如...

祝威廉

3210 20 5

dd4f891d6d9d

大神，还能麻烦给个多个filter顺序执行的例子么？自己用SparkStreamingStrategy策略，配置多个Filter Compositor时，发现同个filter执行了多次

StreamingPro 基于Spark 2.1.1版本 支持Spark Streaming

源码构建简化 很多人吐槽StreamingPro构建实在太麻烦了。看源码都难。然后花了一天时间做了比较大重构，这次只依赖于ServiceFramework项目。具体构建方式如...

祝威廉

3210 20 5