### Question:
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)); } 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 testSparkAsTextFilePipeline() { String sql = "select * from action_required.homework_content"; 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).asTextFile("", ""); }