com.aliyun.odps.task

类 SQLTask

java.lang.Object

com.aliyun.odps.Task

com.aliyun.odps.task.SQLTask

public class SQLTask
extends Task

SQLTask的定义

嵌套类概要

从类继承的嵌套类/接口 com.aliyun.odps.Task

Task.Properties, Task.Property

构造器概要

构造器

构造器和说明
SQLTask()

方法概要

方法

限定符和类型	方法和说明
String	getCommandText() 获取 Task 命令信息
String	getQuery()
static Instance	run(Odps odps, String sql) 运行 SQL.
static Instance	run(Odps odps, String project, String sql, Map<String,String> hints, Map<String,String> aliases) 运行SQL
static Instance	run(Odps odps, String project, String sql, String taskName, Map<String,String> hints, Map<String,String> aliases)
static Instance	run(Odps odps, String project, String sql, String taskName, Map<String,String> hints, Map<String,String> aliases, int priority)
void	setQuery(String query) 设置SQL查询语句

从类继承的方法 com.aliyun.odps.Task

getComment, getName, getProperties, setComment, setName, setProperties, setProperty

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SQLTask

public SQLTask()

方法详细资料

getQuery

public String getQuery()

setQuery

public void setQuery(String query)

设置SQL查询语句

参数:

query - 需要执行的SQL查询

getCommandText

public String getCommandText()

从类复制的说明: Task

获取 Task 命令信息

覆盖:

getCommandText 在类中 Task

返回:

Task 命令信息

run

public static Instance run(Odps odps,
           String sql)
                    throws OdpsException

运行 SQL.
执行读取数据时，最多返回 1W 条记录，若超过，数据将被截断。
特别注意，在执行数据读取操作时：
正常情况下的 task 执行后，task 的状态为 SUCCESS，并正常返回数据结果。
但是，当读取数据量超过 10MB，task 的状态将是 FAILED，返回的数据结果为 error message。
因此,大量数据的获取建议使用 TableTunnel 进行操作。

示例代码：

{
        String sql = "select ....;";

        Instance instance = SQLTask.run(odps, sql);

        instance.waitForSuccess();

        Map results = instance.getTaskResults();
        Map taskStatus = instance.getTaskStatus();

        for(Entry status : taskStatus.entrySet()) {
            if (TaskStatus.Status.SUCCESS == status.getValue().getStatus()) {
                String result = results.get(status.getKey());
                System.out.println(result);
            }
        }
    }
 

参数:

{@link - Odps}

sql - 需要执行的SQL查询

返回:

运行实例 Instance

抛出:

OdpsException

run

public static Instance run(Odps odps,
           String project,
           String sql,
           Map<String,String> hints,
           Map<String,String> aliases)
                    throws OdpsException

运行SQL

参数:

odps - Odps对象

project - 任务运行时所属的Project名称

sql - 需要运行的SQL查询

hints - 能够影响SQL执行的Set信息，例如：odps.mapred.map.split.size等

alias - Alias信息。详情请参考用户手册中alias命令的相关介绍

返回:

作业运行实例 Instance

抛出:

OdpsException

run

public static Instance run(Odps odps,
           String project,
           String sql,
           String taskName,
           Map<String,String> hints,
           Map<String,String> aliases)
                    throws OdpsException

抛出:

OdpsException

run

public static Instance run(Odps odps,
           String project,
           String sql,
           String taskName,
           Map<String,String> hints,
           Map<String,String> aliases,
           int priority)
                    throws OdpsException

抛出:

OdpsException