final LogicalExpression expr = ExpressionTreeMaterializer.materialize(filterExpression, incoming, collector);
if(collector.hasErrors()){
throw new SchemaChangeException(String.format("Failure while trying to materialize incoming schema. Errors:\n %s.", collector.toErrorString()));
}
cg.addExpr(new ReturnValueExpression(expr));
try {
Partitioner p = context.getImplementationClass(cg);
p.setup(context, incoming, outgoing);
} catch (ClassTransformationException | IOException e) {