spark-netflow
spark-netflow copied to clipboard
Introduce more rules on predicate resolution
Currently we support predicate resolution based on statistics and if one of the filters is trivial. We should also support situation when filter is And(GreaterThan(port, 10), GreaterThan(port, 12))
, which should result in simple GreaterThan(port, 12)
.
Currently it is assumed that Spark will handle this case and will never give us predicate like this, but when using just library it becomes quite handy to have this functionality.