spark Streaming 和drools整合

最近公司打算把drools引入spark Streaming實時計算引擎,測試了一下,仍是很好用html 對 JavaPairDStream<String, Float> aggregateRecords 執行如下程序,建立drools session,加載配置文件並執行規則,執行後調用ChannAmount的hbaseSave()方法java aggregateRecords.foreachRD
相關文章
相關標籤/搜索