com.aliyun.odps

Class StreamJobs

java.lang.Object

com.aliyun.odps.StreamJobs

All Implemented Interfaces:

Iterable<StreamJob>

public class StreamJobs
extends Object
implements Iterable<StreamJob>

StreamJobs表示ODPS中所有StreamJob的集合

Constructor Summary

Constructors

Constructor and Description
StreamJobs(Odps odps)

Method Summary

Methods

Modifier and Type	Method and Description
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的状态
Iterator<StreamJob>	iterator()
Iterator<StreamJob>	iterator(String projectName)
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

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamJobs

public StreamJobs(Odps odps)

Method Detail

iterator

public Iterator<StreamJob> iterator()

Specified by:

iterator in interface Iterable<StreamJob>

iterator

public Iterator<StreamJob> iterator(String projectName)

create

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

创建StreamJob

Parameters:

streamJobName - 所要创建的StreamJob名

sql - StreamJob的sql描述

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

Throws:

OdpsException

create

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

创建StreamJob

Parameters:

projectName - StreamJob所在Project名称

streamJobName - 所要创建的StreamJob名

sql - StreamJob的SQL描述

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

Throws:

OdpsException

delete

public String delete(String streamJobName)
              throws OdpsException

删除StreamJob

Parameters:

streamJobName - StreamJob名

Throws:

OdpsException

delete

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

删除StreamJob

Parameters:

projectName - StreamJob所在Project

streamJobName - StreamJob名

Throws:

OdpsException

getStatus

public String getStatus(String streamJobName)
                 throws OdpsException

获取StreamJob的状态

Parameters:

streamJobName - StreamJob名

Throws:

OdpsException

getStatus

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

获取StreamJob的状态

Parameters:

projectName - StreamJob所在Project

streamJobName - StreamJob名

Throws:

OdpsException

pause

public String pause(String streamJobName)
             throws OdpsException

暂停StreamJob

Parameters:

streamJobName - StreamJob名

Throws:

OdpsException

pause

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

暂停StreamJob

Parameters:

projectName - StreamJob所在Project

streamJobName - StreamJob名

Throws:

OdpsException

resume

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

恢复StreamJob

Parameters:

streamJobName - StreamJob名

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

Throws:

OdpsException

resume

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

恢复StreamJob

Parameters:

projectName - StreamJob所在Project

streamJobName - StreamJob名

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

Throws:

OdpsException

rebalance

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

Rebalance StreamJob

Parameters:

streamJobName - StreamJob名

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

Throws:

OdpsException

rebalance

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

Rebalance StreamJob

Parameters:

projectName - StreamJob所在Project

streamJobName - StreamJob名

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

Throws:

OdpsException