Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // way 1
- conditionsCountRDD = conditionRDD.map( condition=> /* ES count query with condition */)
- // way 2
- ESDataDF = /* get es data as DF */
- conditionsCountRDD = conditionRDD.map( condition=> /* DF.filter with condition */)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
