refactor filtering
refactor filtering

This change uses the spark filter function to help refine the RDDs for
the messages we would like to send. Also laying the groundwork for
adding accumulators for message counts.

RedHatHackFest/spark-error-selector