class SparkPipeline extends AbstractPipeline implements Compilable {

    @Override
    public PipelineResult asJsonFile(String clusterPath) {
        return new JobPipelineResult.JsonPipelineResult(clusterPath,
            compileRequirement(buildWrapper().writeAsJsonFile(clusterPath), session(), SparkSession.class));
    }

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

}