数据湖探索 DLI-作业相关:提交作业

时间：2025-02-12 14:54:10

数据湖探索 DLI

提交作业

DLI 提供提交作业和查询作业的接口。您可以通过提交接口提交作业，如果需要查询结果可以调用查询接口查询该作业的结果。示例代码如下：

  
       //实例化SQLJob对象，传入执行SQL所需的queue,数据库名，SQL语句  private static void runSqlJob(Queue queue, Table obsTable) throws DLIException {    String sql = "select * from " + obsTable.getTableName();    String queryResultPath = "OBS Path";    SQLJob sqlJob = new SQLJob(queue, obsTable.getDb().getDatabaseName(), sql);    System.out.println("start submit SQL job...");    //调用SQLJob对象的submit接口提交查询作业       sqlJob.submit();    //调用SQLJob对象的getStatus接口查询作业状态        JobStatus status = sqlJob.getStatus();    System.out.println(status);    System.out.println("start export Result...");    //调用SQLJob对象的exportResult接口导出查询结果，其中queryResultPath为导出数据的路径       sqlJob.exportResult(queryResultPath, StorageType. CS V,            CompressType.GZIP, ExportMode.ERRORIFEXISTS, null);    System.out.println("Job id: " + sqlJob.getJobId() + ", Status : " + status.getName());}