### Question:
SparkPipeline extends AbstractPipeline implements Compilable { public SparkPipeline(QueryProcedure plan, SqlRunner.Builder builder) { super(plan, builder); wrapper = new SparkBodyWrapper(); } SparkPipeline(QueryProcedure plan, SqlRunner.Builder builder); @Override void run(); @Override Object collect(); @Override void show(); @Override PipelineResult asTextFile(String clusterPath, String deliminator); @Override PipelineResult asJsonFile(String clusterPath); @Override AbstractPipeline asTempTable(String tempTableName); @Override void shutdown(); @Override String source();  }### Answer:
@Test public void testSparkPipeline() { String sql = "select 1"; SqlRunner.Builder.RunnerType runnerType = RunnerType.SPARK; SqlRunner runner = SqlRunner.builder() .setTransformRunner(runnerType) .setSchemaPath(SqlUtil.getSchemaPath(SqlUtil.parseTableName(sql).tableNames)) .setAppName("test hive") .setAcceptedResultsNum(10) .ok(); runner.sql(sql).show(); }