class SparkPipeline extends AbstractPipeline implements Compilable {

    public SparkPipeline(QueryProcedure plan, SqlRunner.Builder builder) {
        super(plan, builder);
        //TODO recode
        wrapper = new SparkBodyWrapper();
    }

    public  SparkPipeline(QueryProcedure plan, SqlRunner.Builder builder);

}