class SparkPipeline extends AbstractPipeline implements Compilable {

    @Override
    public PipelineResult asTextFile(String clusterPath, String deliminator) {
        return new JobPipelineResult.TextPipelineResult(clusterPath, deliminator,
            compileRequirement(buildWrapper().writeAsTextFile(clusterPath, deliminator), session(),
                SparkSession.class));
    }

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

}