com.aliyun.odps

类 StreamJobs

java.lang.Object

com.aliyun.odps.StreamJobs

public class StreamJobs
extends Object

StreamJobs表示ODPS中所有StreamJob的集合

构造器概要

构造器

构造器和说明
StreamJobs(Odps odps)

方法概要

方法

限定符和类型	方法和说明
String	create(String streamJobName, String sql, Map<String,String> hints) 创建StreamJob
String	create(String projectName, String streamJobName, String sql, Map<String,String> hints) 创建StreamJob
String	delete(String streamJobName) 删除StreamJob
String	delete(String projectName, String streamJobName) 删除StreamJob
String	getStatus(String streamJobName) 获取StreamJob的状态
String	getStatus(String projectName, String streamJobName) 获取StreamJob的状态
String	list()
String	pause(String streamJobName) 暂停StreamJob
String	pause(String projectName, String streamJobName) 暂停StreamJob
String	rebalance(String streamJobName, Map<String,String> hints) Rebalance StreamJob
String	rebalance(String projectName, String streamJobName, Map<String,String> hints) Rebalance StreamJob
String	resume(String streamJobName, Map<String,String> hints) 恢复StreamJob
String	resume(String projectName, String streamJobName, Map<String,String> hints) 恢复StreamJob

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

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

构造器详细资料

StreamJobs

public StreamJobs(Odps odps)

方法详细资料

list

public String list()
            throws OdpsException

抛出:

OdpsException

create

public String create(String streamJobName,
            String sql,
            Map<String,String> hints)
              throws OdpsException

创建StreamJob

参数:

streamJobName - 所要创建的StreamJob名

sql - StreamJob的sql描述

hints - 能够影响Streamjob执行的Set信息，例如：odps.streamjob.work.size等

抛出:

OdpsException

create

public String create(String projectName,
            String streamJobName,
            String sql,
            Map<String,String> hints)
              throws OdpsException

创建StreamJob

参数:

projectName - StreamJob所在Project名称

streamJobName - 所要创建的StreamJob名

sql - StreamJob的SQL描述

hints - 能够影响Streamjob执行的Set信息，例如：odps.streamjob.work.size等

抛出:

OdpsException

delete

public String delete(String streamJobName)
              throws OdpsException

删除StreamJob

参数:

streamJobName - StreamJob名

抛出:

OdpsException

delete

public String delete(String projectName,
            String streamJobName)
              throws OdpsException

删除StreamJob

参数:

projectName - StreamJob所在Project

streamJobName - StreamJob名

抛出:

OdpsException

getStatus

public String getStatus(String streamJobName)
                 throws OdpsException

获取StreamJob的状态

参数:

streamJobName - StreamJob名

抛出:

OdpsException

getStatus

public String getStatus(String projectName,
               String streamJobName)
                 throws OdpsException

获取StreamJob的状态

参数:

projectName - StreamJob所在Project

streamJobName - StreamJob名

抛出:

OdpsException

pause

public String pause(String streamJobName)
             throws OdpsException

暂停StreamJob

参数:

streamJobName - StreamJob名

抛出:

OdpsException

pause

public String pause(String projectName,
           String streamJobName)
             throws OdpsException

暂停StreamJob

参数:

projectName - StreamJob所在Project

streamJobName - StreamJob名

抛出:

OdpsException

resume

public String resume(String streamJobName,
            Map<String,String> hints)
              throws OdpsException

恢复StreamJob

参数:

streamJobName - StreamJob名

hints - 能够影响Streamjob执行的Set信息，例如：odps.streamjob.work.size等

抛出:

OdpsException

resume

public String resume(String projectName,
            String streamJobName,
            Map<String,String> hints)
              throws OdpsException

恢复StreamJob

参数:

projectName - StreamJob所在Project

streamJobName - StreamJob名

hints - 能够影响Streamjob执行的Set信息，例如：odps.streamjob.work.size等

抛出:

OdpsException

rebalance

public String rebalance(String streamJobName,
               Map<String,String> hints)
                 throws OdpsException

Rebalance StreamJob

参数:

streamJobName - StreamJob名

hints - 必须包含odps.streamjob.worker.num和odps.streamjob.worker.mem

抛出:

OdpsException

rebalance

public String rebalance(String projectName,
               String streamJobName,
               Map<String,String> hints)
                 throws OdpsException

Rebalance StreamJob

参数:

projectName - StreamJob所在Project

streamJobName - StreamJob名

hints - 必须包含odps.streamjob.worker.num和odps.streamjob.worker.mem

抛出:

OdpsException