test_class.declarator: NODE = EmbeddedElasticsearchPolicy.create()
test_class.modifier: @ClassRule
      public static final
test_class.original_string: @ClassRule
      public static final EmbeddedElasticsearchPolicy NODE = EmbeddedElasticsearchPolicy.create();
test_class.type: EmbeddedElasticsearchPolicy
test_class.var_name: NODE
test_class.file: core/src/test/java/com/qihoo/qsql/api/SqlRunnerTest.java
test_class.identifier: SqlRunnerTest
test_case.body: @Test
      public void testMixQueryInThreeEngineWithFlink() {
          String sql = "SELECT a.dep_id, b.stu_id"
              + " FROM edu_manage.department AS a, action_required.homework_content AS b,"
              + " student_profile.student AS c"
              + " WHERE a.dep_id = b.stu_id and b.stu_id = c.stu_id";
          Assert.assertEquals(buildFlinkSqlRunner().sql(sql).getClass(), FlinkPipeline.class);
      }
test_case.class_method_signature: SqlRunnerTest.testMixQueryInThreeEngineWithFlink()
test_case.full_signature: @Test public void testMixQueryInThreeEngineWithFlink()
test_case.identifier: testMixQueryInThreeEngineWithFlink
test_case.invocations: assertEquals getClass sql buildFlinkSqlRunner
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testMixQueryInThreeEngineWithFlink()
focal_class.declarator: environment
focal_class.modifier: protected
focal_class.original_string: protected Builder environment;
focal_class.type: Builder
focal_class.var_name: environment
focal_class.file: core/src/main/java/com/qihoo/qsql/api/SqlRunner.java
focal_class.identifier: SqlRunner
focal_class.class_method_signature: SqlRunner.SqlRunner(Builder builder)
focal_class.full_signature: public  SqlRunner(Builder builder)
focal_class.identifier: SqlRunner
focal_class.modifiers: public
focal_class.parameters: (Builder builder)
focal_class.signature:  SqlRunner(Builder builder)
focal_class.class_method_signature: SqlRunner.builder()
focal_class.full_signature: public static Builder builder()
focal_class.identifier: builder
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: Builder
focal_class.signature: Builder builder()
focal_class.class_method_signature: SqlRunner.getConnection()
focal_class.full_signature: public static Connection getConnection()
focal_class.identifier: getConnection
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: Connection
focal_class.signature: Connection getConnection()
focal_class.class_method_signature: SqlRunner.getConnection(String schema)
focal_class.full_signature: public static Connection getConnection(String schema)
focal_class.identifier: getConnection
focal_class.modifiers: public static
focal_class.parameters: (String schema)
focal_class.return: Connection
focal_class.signature: Connection getConnection(String schema)
focal_class.class_method_signature: SqlRunner.sql(String sql)
focal_class.full_signature: public abstract AbstractPipeline sql(String sql)
focal_class.identifier: sql
focal_class.modifiers: public abstract
focal_class.parameters: (String sql)
focal_class.return: AbstractPipeline
focal_class.signature: AbstractPipeline sql(String sql)
focal_class.class_method_signature: SqlRunner.stop()
focal_class.full_signature: public abstract void stop()
focal_class.identifier: stop
focal_class.modifiers: public abstract
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stop()
focal_method.body: public abstract AbstractPipeline sql(String sql);
focal_method.class_method_signature: SqlRunner.sql(String sql)
focal_method.full_signature: public abstract AbstractPipeline sql(String sql)
focal_method.identifier: sql
focal_method.modifiers: public abstract
focal_method.parameters: (String sql)
focal_method.return: AbstractPipeline
focal_method.signature: AbstractPipeline sql(String sql)