Hi,
all these operations can be implemented in Flink using the "filter()" function.
For example BETWEEN:
DataSet<Product> products = env.createFromElements(...);
products..filter(new FilterFunction<Product>() {
@Override
public boolean filter(Product value) throws Exception {
return value.price >= 10 && value.price <= 20;
}
})