test_class.file: core/src/test/java/com/qihoo/qsql/exec/spark/SparkPipelineTest.java
test_class.identifier: SparkPipelineTest
test_case.body: @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("", "");
      }
test_case.class_method_signature: SparkPipelineTest.testSparkAsTextFilePipeline()
test_case.full_signature: @Test public void testSparkAsTextFilePipeline()
test_case.identifier: testSparkAsTextFilePipeline
test_case.invocations: ok setAcceptedResultsNum setAppName setSchemaPath setTransformRunner builder getSchemaPath parseTableName asTextFile sql
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSparkAsTextFilePipeline()
focal_class.declarator: LOGGER = LoggerFactory.getLogger(SparkPipeline.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOGGER = LoggerFactory.getLogger(SparkPipeline.class);
focal_class.type: Logger
focal_class.var_name: LOGGER
focal_class.file: core/src/main/java/com/qihoo/qsql/exec/spark/SparkPipeline.java
focal_class.identifier: SparkPipeline
focal_class.interfaces: implements Compilable
focal_class.class_method_signature: SparkPipeline.SparkPipeline(QueryProcedure plan, SqlRunner.Builder builder)
focal_class.full_signature: public  SparkPipeline(QueryProcedure plan, SqlRunner.Builder builder)
focal_class.identifier: SparkPipeline
focal_class.modifiers: public
focal_class.parameters: (QueryProcedure plan, SqlRunner.Builder builder)
focal_class.signature:  SparkPipeline(QueryProcedure plan, SqlRunner.Builder builder)
focal_class.class_method_signature: SparkPipeline.run()
focal_class.full_signature: @Override public void run()
focal_class.identifier: run
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void run()
focal_class.class_method_signature: SparkPipeline.session()
focal_class.full_signature: private SparkSession session()
focal_class.identifier: session
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: SparkSession
focal_class.signature: SparkSession session()
focal_class.class_method_signature: SparkPipeline.loadSparkConf()
focal_class.full_signature: private SparkConf loadSparkConf()
focal_class.identifier: loadSparkConf
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: SparkConf
focal_class.signature: SparkConf loadSparkConf()
focal_class.class_method_signature: SparkPipeline.collect()
focal_class.full_signature: @Override public Object collect()
focal_class.identifier: collect
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Object
focal_class.signature: Object collect()
focal_class.class_method_signature: SparkPipeline.show()
focal_class.full_signature: @Override public void show()
focal_class.identifier: show
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void show()
focal_class.class_method_signature: SparkPipeline.asTextFile(String clusterPath, String deliminator)
focal_class.full_signature: @Override public PipelineResult asTextFile(String clusterPath, String deliminator)
focal_class.identifier: asTextFile
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterPath, String deliminator)
focal_class.return: PipelineResult
focal_class.signature: PipelineResult asTextFile(String clusterPath, String deliminator)
focal_class.class_method_signature: SparkPipeline.asJsonFile(String clusterPath)
focal_class.full_signature: @Override public PipelineResult asJsonFile(String clusterPath)
focal_class.identifier: asJsonFile
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterPath)
focal_class.return: PipelineResult
focal_class.signature: PipelineResult asJsonFile(String clusterPath)
focal_class.class_method_signature: SparkPipeline.asTempTable(String tempTableName)
focal_class.full_signature: @Override public AbstractPipeline asTempTable(String tempTableName)
focal_class.identifier: asTempTable
focal_class.modifiers: @Override public
focal_class.parameters: (String tempTableName)
focal_class.return: AbstractPipeline
focal_class.signature: AbstractPipeline asTempTable(String tempTableName)
focal_class.class_method_signature: SparkPipeline.shutdown()
focal_class.full_signature: @Override public void shutdown()
focal_class.identifier: shutdown
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void shutdown()
focal_class.class_method_signature: SparkPipeline.source()
focal_class.full_signature: @Override public String source()
focal_class.identifier: source
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String source()
focal_class.class_method_signature: SparkPipeline.buildWrapper()
focal_class.full_signature: private SparkBodyWrapper buildWrapper()
focal_class.identifier: buildWrapper
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: SparkBodyWrapper
focal_class.signature: SparkBodyWrapper buildWrapper()
focal_class.superclass: extends AbstractPipeline
focal_method.body: @Override
      public PipelineResult asTextFile(String clusterPath, String deliminator) {
          return new JobPipelineResult.TextPipelineResult(clusterPath, deliminator,
              compileRequirement(buildWrapper().writeAsTextFile(clusterPath, deliminator), session(),
                  SparkSession.class));
      }
focal_method.class_method_signature: SparkPipeline.asTextFile(String clusterPath, String deliminator)
focal_method.full_signature: @Override public PipelineResult asTextFile(String clusterPath, String deliminator)
focal_method.identifier: asTextFile
focal_method.invocations: compileRequirement writeAsTextFile buildWrapper session
focal_method.modifiers: @Override public
focal_method.parameters: (String clusterPath, String deliminator)
focal_method.return: PipelineResult
focal_method.signature: PipelineResult asTextFile(String clusterPath, String deliminator)