A B C D E F G H I J L M N O P Q R S T U V W X

A

Account - Interface in com.aliyun.odps.account

用于认证的账号信息

Account.AccountProvider - Enum in com.aliyun.odps.account

淘宝账号,有两种认证方式（1）使用token认证（2）使用AccessId/AccessKey认证 阿里云账号,使用AccessId/AccessKey认证 域帐号使用token认证

addProperty(Task.Property) - Method in class com.aliyun.odps.Task.Properties

addTask(Task) - Method in class com.aliyun.odps.Job

after(Instance, Odps) - Method in class com.aliyun.odps.OdpsHook

instance 结束后，框架会将 Instance 和 odps 对象传入 hook

after(Instance, Odps) - Method in class com.aliyun.odps.OdpsHooks

调用 Hook 的 after

AliyunAccount - Class in com.aliyun.odps.account

阿里云认证账号

AliyunAccount(String, String) - Constructor for class com.aliyun.odps.account.AliyunAccount

构造AliyunAccount对象

AliyunRequestSigner - Class in com.aliyun.odps.account

ODPS请求签名工具

AliyunRequestSigner(String, String) - Constructor for class com.aliyun.odps.account.AliyunRequestSigner

append(Record) - Method in class com.aliyun.odps.data.RecordPack

插入一条记录

append(Record) - Method in class com.aliyun.odps.datahub.DatahubRecordPack

向DatahubRecordPack中append一条Record。

ArchiveResource - Class in com.aliyun.odps

ArchiveResource表示ODPS中一个Archive类型资源。ODPS通过资源名称中的后缀识别压缩类型，支持的压缩文件类型包括：.zip/.tgz/.tar.gz/.tar/.jar

ArchiveResource() - Constructor for class com.aliyun.odps.ArchiveResource

构造Archive类型的资源对象

AuthorizationUtil - Class in com.aliyun.odps.account

AuthorizationUtil() - Constructor for class com.aliyun.odps.account.AuthorizationUtil

B

before(Job, Odps) - Method in class com.aliyun.odps.OdpsHook

提交代码前，框架会将 Job 和 Odps 对象传入 Hook

before(Job, Odps) - Method in class com.aliyun.odps.OdpsHooks

调用 Hook 的 before

BLOCKID - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

C

checkPathHasVolume(String) - Static method in class com.aliyun.odps.Volume

Check whether the path has a volume part

clear() - Method in class com.aliyun.odps.datahub.DatahubRecordPack

清空DatahubRecordPack

clearRegisteredHooks() - Static method in class com.aliyun.odps.OdpsHooks

清空 hooks

clone() - Method in class com.aliyun.odps.Odps

close() - Method in class com.aliyun.odps.data.DefaultRecordReader

com.aliyun.odps - package com.aliyun.odps

提供操作ODPS基本资源的类

com.aliyun.odps.account - package com.aliyun.odps.account

提供ODPS支持的账号类型

com.aliyun.odps.commons - package com.aliyun.odps.commons

com.aliyun.odps.data - package com.aliyun.odps.data

提供表示ODPS中记录的数据结构定义

com.aliyun.odps.datahub - package com.aliyun.odps.datahub

ODPS Datahub服务用于上传、下载数据到ODPS

com.aliyun.odps.task - package com.aliyun.odps.task

提供ODPS支持的Task定义

com.aliyun.odps.task.copy - package com.aliyun.odps.task.copy

com.aliyun.odps.tunnel - package com.aliyun.odps.tunnel

ODPS Tunnel服务用于上传、下载数据到ODPS

commit() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

不进行校验的会话提交

commit(Long[]) - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

提交本次上传的所有数据块

commit(String, String, String) - Method in class com.aliyun.odps.tunnel.VolumeFSTunnel

Commit upload session

commit(String[]) - Method in class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

提交本次上传的所有file

create(Function) - Method in class com.aliyun.odps.Functions

创建函数

create(String, Function) - Method in class com.aliyun.odps.Functions

创建函数

create(Job) - Method in class com.aliyun.odps.Instances

为给定的Job定义在默认Project中创建Instance

create(Task) - Method in class com.aliyun.odps.Instances

为给定的Task创建Instance

create(Task, int) - Method in class com.aliyun.odps.Instances

为给定的Task创建Instance

create(Task, int, String) - Method in class com.aliyun.odps.Instances

为给定的Task创建Instance

create(String, Task) - Method in class com.aliyun.odps.Instances

为给定的Task创建Instance

create(String, Task, int) - Method in class com.aliyun.odps.Instances

为给定的Task创建Instance

create(String, Task, int, String) - Method in class com.aliyun.odps.Instances

为给定的Task创建Instance

create(String, Task, Integer, String) - Method in class com.aliyun.odps.Instances

create(FileResource, InputStream) - Method in class com.aliyun.odps.Resources

创建文件资源

create(String, FileResource, InputStream) - Method in class com.aliyun.odps.Resources

创建文件资源

create(TableResource) - Method in class com.aliyun.odps.Resources

创建表资源

create(String, TableResource) - Method in class com.aliyun.odps.Resources

创建表资源

create(VolumeResource) - Method in class com.aliyun.odps.Resources

创建 Volume 资源

create(String, VolumeResource) - Method in class com.aliyun.odps.Resources

创建 Volume 资源

create(String, String, Map<String, String>) - Method in class com.aliyun.odps.StreamJobs

创建StreamJob

create(String, String, String, Map<String, String>) - Method in class com.aliyun.odps.StreamJobs

创建StreamJob

create(String, TableSchema) - Method in class com.aliyun.odps.Tables

创建表

create(String, TableSchema, boolean) - Method in class com.aliyun.odps.Tables

创建表

create(String, String, TableSchema, boolean, Long, Long) - Method in class com.aliyun.odps.Tables

创建表

create(String, String, TableSchema) - Method in class com.aliyun.odps.Tables

创建表

create(String, String, TableSchema, boolean) - Method in class com.aliyun.odps.Tables

创建表

create(String, String, TableSchema, String, boolean, Long, Long) - Method in class com.aliyun.odps.Tables

创建表

create(String, String, TableSchema, String, boolean) - Method in class com.aliyun.odps.Tables

创建表

create(String, String) - Method in class com.aliyun.odps.Topologies

创建Topology

create(String, String, String) - Method in class com.aliyun.odps.Topologies

创建Topology

create(String, String, boolean, RestClient) - Static method in class com.aliyun.odps.VolumeFSFile

Create new file (Only support to create directory now)

create(String, String) - Method in class com.aliyun.odps.Volumes

Deprecated.

call #create(String, String, Volume.TYPE) instead.

create(String, String, String) - Method in class com.aliyun.odps.Volumes

Deprecated.

call #create(String, String, String, Volume.TYPE) instead.

create(String, String, Volume.Type) - Method in class com.aliyun.odps.Volumes

创建Volume

create(String, String, String, Volume.Type) - Method in class com.aliyun.odps.Volumes

创建Volume

createDownloadSession(String, String) - Method in class com.aliyun.odps.tunnel.InstanceTunnel

在 Instance 上创建下载会话 特殊情况 1.

createDownloadSession(String, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

在非分区表上创建下载会话

createDownloadSession(String, String, PartitionSpec) - Method in class com.aliyun.odps.tunnel.TableTunnel

在分区表上创建下载会话

createDownloadSession(String, String, long) - Method in class com.aliyun.odps.tunnel.TableTunnel

在shard表上创建下载会话

createDownloadSession(String, String, PartitionSpec, long) - Method in class com.aliyun.odps.tunnel.TableTunnel

在shard表上创建下载会话

createDownloadSession(String, String, String, String) - Method in class com.aliyun.odps.tunnel.VolumeTunnel

构造一个新的VolumeTunnel.DownloadSession对象。

createPartition(PartitionSpec) - Method in class com.aliyun.odps.Table

增加分区

createPartition(PartitionSpec, boolean) - Method in class com.aliyun.odps.Table

增加分区

createShards(long) - Method in class com.aliyun.odps.Table

在Table上创建Shards

createStreamClient(String, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

Deprecated.

createStreamUploadWriter(String, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

创建流式上传Writer

createTableWithLifeCycle(String, String, TableSchema, String, boolean, Long) - Method in class com.aliyun.odps.Tables

创建表

createTempResource(String) - Method in class com.aliyun.odps.Resources

上传临时文件资源

createTempResource(String, String) - Method in class com.aliyun.odps.Resources

上传临时文件资源

createTempResource(String, String, Resource.Type) - Method in class com.aliyun.odps.Resources

createUploadSession(String, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

在非分区表上创建上传会话

createUploadSession(String, String, PartitionSpec) - Method in class com.aliyun.odps.tunnel.TableTunnel

在分区表上创建上传会话

createUploadSession(String, String, String) - Method in class com.aliyun.odps.tunnel.VolumeTunnel

构造一个新的VolumeTunnel.UploadSession对象。

CupidTask - Class in com.aliyun.odps.task

CupidTask() - Constructor for class com.aliyun.odps.task.CupidTask

D

DatahubClient - Class in com.aliyun.odps.datahub

DatahubClient(Odps, String, String, String) - Constructor for class com.aliyun.odps.datahub.DatahubClient

Datahub服务入口类

DatahubClient.ShardState - Enum in com.aliyun.odps.datahub

shard的状态

DatahubConfiguration - Class in com.aliyun.odps.datahub

ODPS Datahub 配置项

DatahubConfiguration(Odps) - Constructor for class com.aliyun.odps.datahub.DatahubConfiguration

DatahubConstants - Interface in com.aliyun.odps.datahub

DatahubConstants defined for ODPS.

DatahubException - Exception in com.aliyun.odps.datahub

该异常在DataHub服务访问失败时抛出。

DatahubException() - Constructor for exception com.aliyun.odps.datahub.DatahubException

构造异常对象

DatahubException(String) - Constructor for exception com.aliyun.odps.datahub.DatahubException

构造异常对象

DatahubException(String, Throwable) - Constructor for exception com.aliyun.odps.datahub.DatahubException

构造异常对象

DatahubException(InputStream) - Constructor for exception com.aliyun.odps.datahub.DatahubException

构造异常对象

DatahubHttpHeaders - Class in com.aliyun.odps.datahub

DatahubHttpHeaders() - Constructor for class com.aliyun.odps.datahub.DatahubHttpHeaders

DatahubReader - Class in com.aliyun.odps.datahub

DatahubReader(RestClient, TableSchema, String, Map<String, String>, Map<String, String>) - Constructor for class com.aliyun.odps.datahub.DatahubReader

DatahubReader(RestClient, TableSchema, String, Map<String, String>, Map<String, String>, String) - Constructor for class com.aliyun.odps.datahub.DatahubReader

DatahubRecordPack - Class in com.aliyun.odps.datahub

DatahubRecordPack(TableSchema) - Constructor for class com.aliyun.odps.datahub.DatahubRecordPack

新建一个DatahubRecordPack

DatahubWriter - Class in com.aliyun.odps.datahub

DatahubWriter(RestClient, String, HashMap<String, String>, Map<String, String>) - Constructor for class com.aliyun.odps.datahub.DatahubWriter

Datasource - Class in com.aliyun.odps.task.copy

Datasource(String, String, String, String) - Constructor for class com.aliyun.odps.task.copy.Datasource

Datasource.Direction - Enum in com.aliyun.odps.task.copy

DEFAULT_CHUNK_SIZE - Static variable in class com.aliyun.odps.commons.GeneralConfiguration

上传数据的默认块大小(单位字节)。默认值按照MTU-4设置，MTU值1500。

DEFAULT_DIRECTORY_PERMISSION - Static variable in class com.aliyun.odps.VolumeFSFile

DEFAULT_GROUP - Static variable in class com.aliyun.odps.VolumeFSFile

DEFAULT_OWNER - Static variable in class com.aliyun.odps.VolumeFSFile

DEFAULT_SOCKET_CONNECT_TIMEOUT - Static variable in class com.aliyun.odps.commons.GeneralConfiguration

底层网络链接的默认超时时间,180秒

DEFAULT_SOCKET_TIMEOUT - Static variable in class com.aliyun.odps.commons.GeneralConfiguration

底层网络默认超时时间, 300秒。

DefaultRecordReader - Class in com.aliyun.odps.data

默认 RecordReader 的实现，用于读取 Record

DefaultRecordReader(InputStream, TableSchema) - Constructor for class com.aliyun.odps.data.DefaultRecordReader

构造一个 DefaultRecordReader

delete(String) - Method in class com.aliyun.odps.Functions

删除函数

delete(String, String) - Method in class com.aliyun.odps.Functions

删除函数

delete(String) - Method in class com.aliyun.odps.Resources

删除资源

delete(String, String) - Method in class com.aliyun.odps.Resources

删除资源

delete(String) - Method in class com.aliyun.odps.StreamJobs

删除StreamJob

delete(String, String) - Method in class com.aliyun.odps.StreamJobs

删除StreamJob

delete(String) - Method in class com.aliyun.odps.Tables

删除表

delete(String, boolean) - Method in class com.aliyun.odps.Tables

删除表

delete(String, String) - Method in class com.aliyun.odps.Tables

删除表

delete(String, String, boolean) - Method in class com.aliyun.odps.Tables

删除表

delete(String) - Method in class com.aliyun.odps.Topologies

删除Topology

delete(String, String) - Method in class com.aliyun.odps.Topologies

删除Topology

delete(boolean) - Method in class com.aliyun.odps.VolumeFSFile

Delete file (or dir)

delete(String) - Method in class com.aliyun.odps.Volumes

删除Volume

delete(String, String) - Method in class com.aliyun.odps.Volumes

删除Volume

DeleteConflict - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

deletePartition(PartitionSpec) - Method in class com.aliyun.odps.Table

删除指定分区

deletePartition(PartitionSpec, boolean) - Method in class com.aliyun.odps.Table

删除指定分区

deleteVolumePartition(String) - Method in class com.aliyun.odps.Volume

删除指定分区

DOWNLOADID - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

DOWNLOADS - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

E

exists(String) - Method in class com.aliyun.odps.Functions

判断 Function 是否存在

exists(String, String) - Method in class com.aliyun.odps.Functions

判断 Function 是否存在

exists(String) - Method in class com.aliyun.odps.Instances

判断指定 Instance 是否存在

exists(String, String) - Method in class com.aliyun.odps.Instances

判断指定 Instance 是否存在

exists(String) - Method in class com.aliyun.odps.Projects

检查Project是否存在

exists(String) - Method in class com.aliyun.odps.Resources

判断指定资源是否存在

exists(String, String) - Method in class com.aliyun.odps.Resources

判断指定资源是否存在

exists(String) - Method in class com.aliyun.odps.Tables

判断指定表是否存在

exists(String, String) - Method in class com.aliyun.odps.Tables

判断指定表是否存在

exists(String) - Method in class com.aliyun.odps.Volumes

判断指定Volume是否存在

exists(String, String) - Method in class com.aliyun.odps.Volumes

判断指定Volume是否存在

F

FileResource - Class in com.aliyun.odps

FileResource表示ODPS中一个文件类型资源

FileResource() - Constructor for class com.aliyun.odps.FileResource

FileResource表示ODPS中一个File类型的资源

FIRST_PACK_ID - Static variable in interface com.aliyun.odps.datahub.PackType

fromString(String) - Static method in enum com.aliyun.odps.LogType

设置日志类型

Function - Class in com.aliyun.odps

Function表示ODPS中的函数

Function() - Constructor for class com.aliyun.odps.Function

Functions - Class in com.aliyun.odps

表示ODPS内所有Function的集合

functions() - Method in class com.aliyun.odps.Odps

获取表示ODPS所有Function的集合对象

G

GalaxyTask - Class in com.aliyun.odps.task

GalaxyTask() - Constructor for class com.aliyun.odps.task.GalaxyTask

GeneralConfiguration - Class in com.aliyun.odps.commons

Created by dongxiao.dx on 2015/9/7.

GeneralConfiguration(Odps) - Constructor for class com.aliyun.odps.commons.GeneralConfiguration

generateLogView(Instance, long) - Method in class com.aliyun.odps.LogView

get(String) - Method in class com.aliyun.odps.Functions

获取 Function 对象

get(String, String) - Method in class com.aliyun.odps.Functions

获取 Function 对象

get(String) - Method in class com.aliyun.odps.Instances

获取指定Instance

get(String, String) - Method in class com.aliyun.odps.Instances

获取指定Instance

get() - Method in class com.aliyun.odps.Projects

获得默认Project对象

get(String) - Method in class com.aliyun.odps.Projects

获取指定Project

get(String) - Method in class com.aliyun.odps.Resources

获取资源信息

get(String, String) - Method in class com.aliyun.odps.Resources

获取资源信息

get(String) - Method in class com.aliyun.odps.Tables

获得指定表信息

get(String, String) - Method in class com.aliyun.odps.Tables

获得指定表信息

get(String) - Method in class com.aliyun.odps.Topologies

获得指定Topology信息

get(String, String) - Method in class com.aliyun.odps.Topologies

获得指定Topology信息

get(String) - Method in class com.aliyun.odps.Volumes

获得指定Volume信息

get(String, String) - Method in class com.aliyun.odps.Volumes

获得指定Volume信息

getAccessId() - Method in class com.aliyun.odps.account.AliyunAccount

获取当前帐号AccessID

getAccessKey() - Method in class com.aliyun.odps.account.AliyunAccount

获取当前帐号AccessKey

getAccessTime() - Method in class com.aliyun.odps.VolumeFSFile

getAccount() - Method in class com.aliyun.odps.commons.GeneralConfiguration

getAccount() - Method in class com.aliyun.odps.Odps

获取Account 暂未开放，仅限内部使用

getAccountType() - Method in class com.aliyun.odps.task.copy.TunnelDatasource

getAvailBlockId() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

多个线程中的 TunnelBufferedWriter 将通过这个接口获得写入的 blockId 为了防止 blockId 重复分配，对于 curBlockId 的访问必须加锁。

getBackupWorkers() - Method in class com.aliyun.odps.Instance.StageProgress

获得backup的Worker数，对应于original worker，backup会在长尾时被启动，同时运行。

getBlockList() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

获取当前会话已经上传成功的数据块列表

getBlockReplications() - Method in class com.aliyun.odps.VolumeFSFile

getBlockSize() - Method in class com.aliyun.odps.VolumeFSFile

getByteArray() - Method in class com.aliyun.odps.datahub.DatahubRecordPack

getChunkSize() - Method in class com.aliyun.odps.commons.GeneralConfiguration

取得当前配置的数据传输块大小

getClassPath() - Method in class com.aliyun.odps.Function

获得函数使用的类名

getClassType() - Method in class com.aliyun.odps.Function

Deprecated.

getCommandText() - Method in class com.aliyun.odps.Task

获取 Task 命令信息

getCommandText() - Method in class com.aliyun.odps.task.SqlPlanTask

getCommandText() - Method in class com.aliyun.odps.task.SQLTask

getComment() - Method in class com.aliyun.odps.Job

getComment() - Method in class com.aliyun.odps.Project

获取Project注释

getComment() - Method in class com.aliyun.odps.Resource

获取资源注释信息

getComment() - Method in class com.aliyun.odps.Table

获取注释

getComment() - Method in class com.aliyun.odps.Task

获取注释信息

getComment() - Method in class com.aliyun.odps.Topology

获取注释

getComment() - Method in class com.aliyun.odps.Volume

获取注释

getComment() - Method in class com.aliyun.odps.VolumePartition

获取注释

getContentMd5() - Method in class com.aliyun.odps.FileResource

获得资源在ODPS中记录的MD5值

getCPUBind() - Method in class com.aliyun.odps.StreamJob

getCPUCost() - Method in class com.aliyun.odps.Instance.TaskCost

getCreatedTime() - Method in class com.aliyun.odps.Function

获取函数创建时间

getCreatedTime() - Method in class com.aliyun.odps.Job

getCreatedTime() - Method in class com.aliyun.odps.Partition

获取分区的创建时间

getCreatedTime() - Method in class com.aliyun.odps.Project

获取Project创建时间

getCreatedTime() - Method in class com.aliyun.odps.Resource

获取资源创建时间

getCreatedTime() - Method in class com.aliyun.odps.Table

获取创建时间

getCreatedTime() - Method in class com.aliyun.odps.Volume

获取创建时间

getCreatedTime() - Method in class com.aliyun.odps.VolumePartition

获取创建时间

getCreateTime() - Method in class com.aliyun.odps.StreamJob

getCreationTime() - Method in class com.aliyun.odps.VolumeFSFile

getCryptoAlgoName() - Method in class com.aliyun.odps.Table

获取表加密算法名称

getDefaultProject() - Method in class com.aliyun.odps.Odps

取得当前对象的默认Project名称

getDefaultRunningCluster() - Method in class com.aliyun.odps.Instances

获取默认 runningCluster 如果为 null,使用project 默认 cluster

getDescription() - Method in class com.aliyun.odps.Topology

获取 Topology 的JSON描述文件

getDest() - Method in class com.aliyun.odps.task.copy.MappingItem

getDistributeColumnNames() - Method in class com.aliyun.odps.Shard

返回创建shard表时指定的cluster by列名

getDownloadSession(String, String) - Method in class com.aliyun.odps.tunnel.InstanceTunnel

获得在Instance 上获取的下载会话

getDownloadSession(String, String, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

获得在非分区表上创建的下载会话

getDownloadSession(String, String, long, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

获得在非分区表上创建的下载会话

getDownloadSession(String, String, PartitionSpec, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

获得在分区表上创建的下载会话

getDownloadSession(String, String, PartitionSpec, long, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

获得在shard表上创建的下载会话

getDownloadSession(String, String, String, String, String) - Method in class com.aliyun.odps.tunnel.VolumeTunnel

根据已有downloadId获取一个VolumeTunnel.DownloadSession对象。

getEndpoint(String) - Method in class com.aliyun.odps.commons.GeneralConfiguration

getEndpoint(String) - Method in class com.aliyun.odps.datahub.DatahubConfiguration

取得指定Project的Datahub服务入口地址

getEndpoint() - Method in class com.aliyun.odps.Odps

获取ODPS服务的地址

getEndPoint() - Method in class com.aliyun.odps.task.copy.TunnelDatasource

getEndTime() - Method in class com.aliyun.odps.Instance

获得Instance结束执行时间

getEndTime() - Method in class com.aliyun.odps.InstanceFilter

获得结束时间的过滤条件

getErrCode() - Method in exception com.aliyun.odps.VolumeException

getErrMsg() - Method in exception com.aliyun.odps.VolumeException

getErrorCode() - Method in exception com.aliyun.odps.datahub.DatahubException

获得错误代码

getErrorCode() - Method in exception com.aliyun.odps.OdpsException

getErrorCode() - Method in exception com.aliyun.odps.tunnel.TunnelException

获得错误代码

getErrorMsg() - Method in exception com.aliyun.odps.datahub.DatahubException

获得错误信息

getErrorMsg() - Method in exception com.aliyun.odps.tunnel.TunnelException

获得错误信息

getExtendedProperties() - Method in class com.aliyun.odps.Project

获取 Project 扩展配置信息

getFileCount() - Method in class com.aliyun.odps.Volume

获取内部文件个数

getFileCount() - Method in class com.aliyun.odps.VolumePartition

获取内部文件个数

getFileIterator() - Method in class com.aliyun.odps.VolumePartition

获取文件迭代器

getFileIterator(String) - Method in class com.aliyun.odps.VolumePartition

获取文件迭代器

getFileLength() - Method in class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

获取当前VolumeTunnel.DownloadSession操作的File的长度。

getFileLength(String) - Method in class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

getFileList() - Method in class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

获取当前VolumeTunnel.UploadSession已成功上传的files

getFileNum() - Method in class com.aliyun.odps.Partition

获取分区数据的文件数

getFileNum() - Method in class com.aliyun.odps.Table

返回表数据所占的盘古文件数

getFinishedPercentage() - Method in class com.aliyun.odps.Instance.StageProgress

获得已处理数据量的百分比

getFormat() - Method in class com.aliyun.odps.Instance.Result

指明返回结果的格式，包括：XML，JSON，CSV

getFromTime() - Method in class com.aliyun.odps.InstanceFilter

获得起始执行时间过滤条件

getGroup() - Method in class com.aliyun.odps.VolumeFSFile

getHubLifecycle() - Method in class com.aliyun.odps.Shard

Deprecated.

getHubLifecycle() - Method in class com.aliyun.odps.Table

获取表的datahub生命周期值，单位：天

getId() - Method in class com.aliyun.odps.Instance

获得Instance的ID

getId() - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

获取会话ID

getId() - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

获取会话ID

getId() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

获取会话ID

getId() - Method in class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

获取当前VolumeTunnel.DownloadSession的唯一标识符

getId() - Method in class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

获取当前VolumeTunnel.UploadSession的唯一标识符

getInputRecords() - Method in class com.aliyun.odps.Instance.StageProgress

获得输入的Record数

getInputSize() - Method in class com.aliyun.odps.Instance.TaskCost

getInputTablenames() - Method in class com.aliyun.odps.task.XLibTask

getInstanceID() - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

获取 instanceID

getIsdir() - Method in class com.aliyun.odps.VolumeFSFile

getIsTempResource() - Method in class com.aliyun.odps.FileResource

获得资源是否是临时资源。所谓临时资源即可以将本地文件作为Resource上传到ODPS中，供MapReduce使用。该资源仅对 运行的作业有效。

getJobConf() - Method in class com.aliyun.odps.task.GraphTask

Gets the value of the jobConf property.

getJsonSchema() - Method in class com.aliyun.odps.Table

getJsonSummary() - Method in class com.aliyun.odps.Instance.TaskSummary

getKvMeta() - Method in class com.aliyun.odps.datahub.ReadPackResult

getLastDataModifiedTime() - Method in class com.aliyun.odps.Partition

获取分区数据的最后修改时间

getLastDataModifiedTime() - Method in class com.aliyun.odps.Table

获取数据最后修改时间

getLastMetaModifiedTime() - Method in class com.aliyun.odps.Partition

获取分区的Meta修改时间

getLastMetaModifiedTime() - Method in class com.aliyun.odps.Table

获取最后修改时间

getLastModifiedTime() - Method in class com.aliyun.odps.Job

getLastModifiedTime() - Method in class com.aliyun.odps.Project

获取Project最后修改时间

getLastModifiedTime() - Method in class com.aliyun.odps.Resource

获取资源最后修改时间

getLastModifiedTime() - Method in class com.aliyun.odps.Volume

获取volume最后修改时间

getLastModifiedTime() - Method in class com.aliyun.odps.VolumePartition

获取volume partition最后修改时间

getLastPackId() - Method in class com.aliyun.odps.datahub.DatahubReader

获取当前从服务端读取的pack的packId

GetLastReplicatedPackId() - Method in class com.aliyun.odps.datahub.ReplicatorStatus

获得shard最后一个复制到离线集群的pack的id

GetLastReplicatedPackTimeStamp() - Method in class com.aliyun.odps.datahub.ReplicatorStatus

获得shard最后一个复制到离线集群的pack的时间戳

getLastUpdator() - Method in class com.aliyun.odps.Resource

获得资源最后更新者

getLength() - Method in class com.aliyun.odps.Volume

获取内部存储大小

getLength() - Method in class com.aliyun.odps.VolumeFSFile

getLength() - Method in class com.aliyun.odps.VolumePartition

获取内部存储大小

getLife() - Method in class com.aliyun.odps.Table

获取表的生命周期值，单位：天

getLifeCycle() - Method in class com.aliyun.odps.Partition

获取表的生命周期

getLog(String, LogType, int) - Method in class com.aliyun.odps.Instance

获取Worker运行的LOG内容

getLogViewHost() - Method in class com.aliyun.odps.LogView

getLogViewHost() - Method in class com.aliyun.odps.Odps

获取logview host地址，可能为null

getMaxLabel() - Method in class com.aliyun.odps.Table

获取最高的label级别 Label的定义分两部分： 1.

getMemoryCost() - Method in class com.aliyun.odps.Instance.TaskCost

getMessage() - Method in exception com.aliyun.odps.datahub.DatahubException

getMessage() - Method in exception com.aliyun.odps.tunnel.TunnelException

getMessage() - Method in exception com.aliyun.odps.VolumeException

getMeta() - Method in class com.aliyun.odps.datahub.ReadPackResult

getMethod() - Method in class com.aliyun.odps.task.XLibTask

返回方法名。

getModificationTime() - Method in class com.aliyun.odps.VolumeFSFile

getName() - Method in class com.aliyun.odps.Function

获得函数名

getName() - Method in class com.aliyun.odps.Instance.StageProgress

获得Stage名称。任意Task 可以由任意多个Stage构成。Stage由任意多个Worker构成。Stage内的Worker有相同的数据处理逻辑。

getName() - Method in class com.aliyun.odps.Instance.TaskStatus

返回状态名称

getName() - Method in class com.aliyun.odps.Job

getName() - Method in class com.aliyun.odps.Project.Cluster

getName() - Method in class com.aliyun.odps.Project

获取Project名称

getName() - Method in class com.aliyun.odps.Resource

获得资源名称

getName() - Method in class com.aliyun.odps.StreamJob

获取StreamJob名

getName() - Method in class com.aliyun.odps.Table

获取表名

getName() - Method in class com.aliyun.odps.TableFilter

获得表名前缀

getName() - Method in class com.aliyun.odps.Task

获取Task的名称

getName() - Method in class com.aliyun.odps.Task.Property

返回属性名。

getName() - Method in class com.aliyun.odps.Topology

获取Topology名

getName() - Method in class com.aliyun.odps.Volume

获取volume名

getName() - Method in class com.aliyun.odps.VolumeFile

获得VolumeFile的名字

getName() - Method in class com.aliyun.odps.VolumeFilter

获得Volume名或partition名前缀

getName() - Method in class com.aliyun.odps.VolumePartition

获取volume partition名

getNextPackId() - Method in class com.aliyun.odps.datahub.ReadPackResult

getOdps() - Method in class com.aliyun.odps.Instance

获得Instance的 ODPS 对象

getOdpsEndPoint() - Method in class com.aliyun.odps.task.copy.TunnelDatasource

getOdpsHooks() - Method in class com.aliyun.odps.Instance

getOnlyOwner() - Method in class com.aliyun.odps.InstanceFilter

获得Instance owner过滤条件

getOutputRecords() - Method in class com.aliyun.odps.Instance.StageProgress

获得输出的Record数

getOutputTablenames() - Method in class com.aliyun.odps.task.XLibTask

getOwner() - Method in class com.aliyun.odps.Function

获得函数所属用户

getOwner() - Method in class com.aliyun.odps.Instance

获得Instance所属用户

getOwner() - Method in class com.aliyun.odps.Job

getOwner() - Method in class com.aliyun.odps.Project

获得Project所属用户

getOwner() - Method in class com.aliyun.odps.Resource

获取资源所属用户

getOwner() - Method in class com.aliyun.odps.StreamJob

获取StreamJob所属用户

getOwner() - Method in class com.aliyun.odps.Table

获取表所属用户

getOwner() - Method in class com.aliyun.odps.TableFilter

获得表所有者

getOwner() - Method in class com.aliyun.odps.Topology

获取Topology所属用户

getOwner() - Method in class com.aliyun.odps.Volume

获取volume所属用户

getOwner() - Method in class com.aliyun.odps.VolumeFSFile

getOwner() - Method in class com.aliyun.odps.VolumePartition

获取volume partition所属用户

getPackId() - Method in class com.aliyun.odps.datahub.ReadPackResult

getPackId() - Method in class com.aliyun.odps.datahub.SeekPackResult

getPackId() - Method in class com.aliyun.odps.datahub.WritePackResult

getParameters() - Method in class com.aliyun.odps.task.XLibTask

返回参数

getPartition(PartitionSpec) - Method in class com.aliyun.odps.Table

获取指定分区信息

getPartition() - Method in class com.aliyun.odps.task.copy.Datasource

getPartitionIterator() - Method in class com.aliyun.odps.Table

获取分区迭代器

getPartitionIterator(PartitionSpec) - Method in class com.aliyun.odps.Table

获取分区迭代器

getPartitionIterator() - Method in class com.aliyun.odps.Volume

获取分区迭代器

getPartitionIterator(VolumeFilter) - Method in class com.aliyun.odps.Volume

获取volume partition迭代器

getPartitions() - Method in class com.aliyun.odps.Table

获取所有分区信息

getPartitionSpec() - Method in class com.aliyun.odps.datahub.ReadPackResult

getPartitionSpec() - Method in class com.aliyun.odps.Partition

获得PartitionSpec对象

getPartitionSpec() - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

获取 partition

getPath() - Method in class com.aliyun.odps.VolumeFSFile

getPermission() - Method in class com.aliyun.odps.VolumeFSFile

getPhysicalSize() - Method in class com.aliyun.odps.Partition

获得分区数据的物理大小，单位Byte

getPhysicalSize() - Method in class com.aliyun.odps.Table

查看表所占磁盘的物理大小

getPlan() - Method in class com.aliyun.odps.task.CupidTask

getPlan() - Method in class com.aliyun.odps.task.LOTTask

getPlan() - Method in class com.aliyun.odps.task.MoyeTask

getPriority() - Method in class com.aliyun.odps.Instance

获取 Instance 的优先级

getPriority() - Method in class com.aliyun.odps.Job

getProject() - Method in class com.aliyun.odps.Function

获取函数所在Project名称

getProject() - Method in class com.aliyun.odps.Instance

获得Instance所属Project名称

getProject() - Method in class com.aliyun.odps.Resource

获取资源所在Project名称

getProject() - Method in class com.aliyun.odps.StreamJob

获取 StreamJob 所在Project名称

getProject() - Method in class com.aliyun.odps.Table

获取表所属Project名称

getProject() - Method in class com.aliyun.odps.task.copy.Datasource

getProject() - Method in class com.aliyun.odps.task.LOTTask.Plan

getProject() - Method in class com.aliyun.odps.Volume

获取 volume 所在Project名称

getProject() - Method in class com.aliyun.odps.VolumeFSFile

getProjectName() - Method in class com.aliyun.odps.datahub.DatahubClient

getProjectName() - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

获取 project name

getProjectName() - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

getProjectName() - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

getProperties() - Method in class com.aliyun.odps.Project

获取Project配置信息

getProperties() - Method in class com.aliyun.odps.Task

获取所有配置信息

getProperty(String) - Method in class com.aliyun.odps.Project

查询Project指定配置信息

getQuery() - Method in class com.aliyun.odps.task.LOTTask

getQuery() - Method in class com.aliyun.odps.task.SQLCostTask

getQuery() - Method in class com.aliyun.odps.task.SqlPlanTask

返回查询语句。

getQuery() - Method in class com.aliyun.odps.task.SQLTask

getQuota() - Method in class com.aliyun.odps.VolumeFSFile

getQuotaID() - Method in class com.aliyun.odps.Project.Cluster

getRawStream() - Method in class com.aliyun.odps.data.DefaultRecordReader

getRecordCount() - Method in class com.aliyun.odps.datahub.DatahubRecordPack

getRecordCount() - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

获取可下载的记录总数

getRecordCount() - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

获取可下载的记录总数

getRecordReader() - Method in class com.aliyun.odps.data.RecordPack

返回一个RecordReader，里面包含了所有的记录

getRecords() - Method in class com.aliyun.odps.datahub.ReadPackResult

getRegisteredHooks() - Static method in class com.aliyun.odps.OdpsHooks

Deprecated.

getRequestId() - Method in exception com.aliyun.odps.datahub.DatahubException

获得请求标识

getRequestId() - Method in exception com.aliyun.odps.OdpsException

获取 失败请求的 RequestID, 如果不是网络请求 返回 null

getRequestId() - Method in exception com.aliyun.odps.tunnel.TunnelException

获得请求标识

getRequestId() - Method in exception com.aliyun.odps.VolumeException

getRequestSigner() - Method in interface com.aliyun.odps.account.Account

获得用于对API请求进行签名的RequestSigner对象

getRequestSigner() - Method in class com.aliyun.odps.account.AliyunAccount

getResource(String, String) - Method in class com.aliyun.odps.commons.GeneralConfiguration

获得RESTful资源标识符

getResourceAsStream(String, String) - Method in class com.aliyun.odps.Resources

获得资源文件的字节流

getResourceAsStream(String) - Method in class com.aliyun.odps.Resources

获得资源文件的字节流

getResourceName() - Method in class com.aliyun.odps.task.LOTTask.Plan

getResourceNames() - Method in class com.aliyun.odps.Function

获得函数相关的资源名称列表。

getResources() - Method in class com.aliyun.odps.Function

获得函数相关的资源列表。UDF所用到的资源列表，这个里面必须包括UDF代码所在的资源。如果用户UDF中需要读取其他资源文件，这个列表中还得包括UDF所读取的资源文件列表。

getRestClient() - Method in class com.aliyun.odps.Odps

获取ODPS底层传输接口

getResult(Instance, String) - Static method in class com.aliyun.odps.task.SQLTask

Deprecated.

getResult(Instance) - Static method in class com.aliyun.odps.task.SQLTask

Columns of each record in result are ALL OdpsType.STIRNG, ignore their real type in odps
Return value is valid only when SQL query is select, otherwise, result will be empty.

getResultByInstanceTunnel(Instance, String, Long) - Static method in class com.aliyun.odps.task.SQLTask

Columns of each record in result are ALL OdpsType.STIRNG, ignore their real type in odps
Return value is valid only when SQL query is select, otherwise, result will be empty.

getResultByInstanceTunnel(Instance, Long) - Static method in class com.aliyun.odps.task.SQLTask

使用 instance tunnel 的方式获取 Anonymous task 的结果

getResultByInstanceTunnel(Instance, String) - Static method in class com.aliyun.odps.task.SQLTask

使用 instance tunnel 的方式获取 instance 结果 当数据量不大于 SQLTask.SQL_TASK_RESULT_LIMIT 条时,成功; 若数据量量大于 SQLTask.SQL_TASK_RESULT_LIMIT 条, 返回 SQL_TASK_RESULT_LIMIT 条结果; 可使用 SQLTask.getResultByInstanceTunnel(Instance, String, Long) 接口调整 limit 参数, 来获取更多数据;

getResultByInstanceTunnel(Instance) - Static method in class com.aliyun.odps.task.SQLTask

使用 instance tunnel 的方式获取 Anonymous task 的结果

getRoot(String, Odps) - Static method in class com.aliyun.odps.VolumeFSFile

Get a mocked root path

getRunningCluster() - Method in class com.aliyun.odps.Job

getRunningWorkers() - Method in class com.aliyun.odps.Instance.StageProgress

获得正在运行的Worker数。多个Worker构成一个Stage，Worker可以简单的被看做一个进程。

getSchema() - Method in class com.aliyun.odps.data.DefaultRecordReader

getSchema() - Method in class com.aliyun.odps.Table

获取表结构定义

getSchema() - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

获取数据对应的表结构

getSchema() - Method in class com.aliyun.odps.tunnel.StreamUploadWriter

getSchema() - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

获取数据对应的表结构

getSchema() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

获取表结构

getSecurityManager() - Method in class com.aliyun.odps.Project

获取SecurityManager对象

getShard() - Method in class com.aliyun.odps.Table

返回Shard

getShardList() - Method in class com.aliyun.odps.datahub.DatahubClient

getShardList() - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

getShardNum() - Method in class com.aliyun.odps.Shard

返回shard数量

getShardStatus() - Method in class com.aliyun.odps.datahub.DatahubClient

查询DatahubClinet对应的table拥有的shard在服务端的状态

getShardStatus() - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

查询StreamClinet对应的table拥有的shard在服务端的状态

getSignature(String, Request) - Method in class com.aliyun.odps.account.AliyunRequestSigner

getSignature() - Method in class com.aliyun.odps.task.copy.TunnelDatasource

getSize() - Method in class com.aliyun.odps.Partition

获取分区内部存储的大小，单位Byte

getSize() - Method in class com.aliyun.odps.Resource

获得资源大小 注意: 表 和 volumn 返回 null

getSize() - Method in class com.aliyun.odps.Table

获取内部存储大小，单位：Byte

getSocketConnectTimeout() - Method in class com.aliyun.odps.commons.GeneralConfiguration

取得当前配置的网络链接超时时间, 单位秒

getSocketTimeout() - Method in class com.aliyun.odps.commons.GeneralConfiguration

取得当前配置的网络IO超时时间, 秒

getSortColumnNames() - Method in class com.aliyun.odps.Shard

返回创建shard表时指定的sorted by列名

getSourceTable() - Method in class com.aliyun.odps.TableResource

获得该资源对应的表对象

getSourceTablePartition() - Method in class com.aliyun.odps.TableResource

获得该资源对应的表分区对象

getSrc() - Method in class com.aliyun.odps.task.copy.MappingItem

getStageProgressFormattedString(List<Instance.StageProgress>) - Static method in class com.aliyun.odps.Instance

getStartTime() - Method in class com.aliyun.odps.Instance

获得Instance开始执行时间

getStatus() - Method in class com.aliyun.odps.Instance

获得Instance状态

getStatus() - Method in class com.aliyun.odps.Instance.StageProgress

getStatus() - Method in class com.aliyun.odps.Instance.TaskStatus

返回状态对象

getStatus() - Method in class com.aliyun.odps.InstanceFilter

获得Instance状态过滤条件

getStatus() - Method in class com.aliyun.odps.Project

获取Project当前状态

getStatus() - Method in class com.aliyun.odps.StreamJob

getStatus(String) - Method in class com.aliyun.odps.StreamJobs

获取StreamJob的状态

getStatus(String, String) - Method in class com.aliyun.odps.StreamJobs

获取StreamJob的状态

getStatus() - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

获取会话状态

getStatus() - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

获取会话状态

getStatus() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

获取会话状态

getStatus() - Method in class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

获取当前VolumeTunnel.DownloadSession的Status

getStatus() - Method in class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

获取当前VolumeTunnel.UploadSession的Status

getStreamSchema() - Method in class com.aliyun.odps.datahub.DatahubClient

getStreamSchema() - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

getStreamSchema() - Method in class com.aliyun.odps.tunnel.StreamUploadClient

Deprecated.

getStreamSchemaFromServer() - Method in class com.aliyun.odps.datahub.DatahubClient

getStreamUploadResource(String, String, long) - Method in class com.aliyun.odps.commons.GeneralConfiguration

获得Stream upload数据的RESTful资源标识符

getStreamUploadResource(String, String) - Method in class com.aliyun.odps.commons.GeneralConfiguration

获得流式上传的RESTful资源标识符

getString() - Method in class com.aliyun.odps.Instance.Result

Instance执行后，无论成功与否，返回给客户端的结果或失败信息。

getSummaryText() - Method in class com.aliyun.odps.Instance.TaskSummary

返回文本化汇总信息，类似于：

getSymlink() - Method in class com.aliyun.odps.VolumeFSFile

getSystemVersion() - Method in class com.aliyun.odps.Project

getTable() - Method in class com.aliyun.odps.task.copy.Datasource

getTableID() - Method in class com.aliyun.odps.Table

获取表 ID

getTableLabel() - Method in class com.aliyun.odps.Table

getTableName() - Method in class com.aliyun.odps.datahub.DatahubClient

getTableName() - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

getTableName() - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

getTableReplicatedTimeStamp() - Method in class com.aliyun.odps.datahub.DatahubClient

返回一个写入datahub的pack的时间戳，datahub确保小于等于这个时间戳的pack都已经进入离线ODPS

getTableTimestamp() - Method in class com.aliyun.odps.datahub.DatahubClient

返回一个时间戳，datahub确保小于等于这个时间戳的pack都已经进入离线ODPS

getTaskCost(String) - Method in class com.aliyun.odps.Instance

获得 Instance 中 Task 的运行资源消耗信息 当且仅当 Task 产生计量信息时，返回资源消耗信息，否则返回 null

getTaskDetailJson(String) - Method in class com.aliyun.odps.Instance

getTaskDetailJson2(String) - Method in class com.aliyun.odps.Instance

getTaskNames() - Method in class com.aliyun.odps.Instance

获得Instance所包含的所有Task的名称

getTaskProgress(String) - Method in class com.aliyun.odps.Instance

查询指定Task的Stage进度

getTaskResults() - Method in class com.aliyun.odps.Instance

获得Instance中Task的运行结果

getTaskResultsWithFormat() - Method in class com.aliyun.odps.Instance

获得Instance中Task的运行结果

getTasks() - Method in class com.aliyun.odps.Instance

返回与作业运行实例相关的作业Task实例。

getTasks() - Method in class com.aliyun.odps.Job

getTaskStatus() - Method in class com.aliyun.odps.Instance

查询Instance中所有Task的执行状态

getTaskSummary(String) - Method in class com.aliyun.odps.Instance

获得Instance中Task的运行汇总信息 当 Server 端返回信息，但是信息格式错误时，返回 null

getTerminatedWorkers() - Method in class com.aliyun.odps.Instance.StageProgress

获得结束运行的Worker数

getTimeStamp() - Method in class com.aliyun.odps.datahub.ReadPackResult

getTotalWorkers() - Method in class com.aliyun.odps.Instance.StageProgress

获得所有Worker数

getType() - Method in interface com.aliyun.odps.account.Account

获取当前账号的类型

getType() - Method in class com.aliyun.odps.account.AliyunAccount

getType() - Method in class com.aliyun.odps.Instance.TaskStatus

返回Task类型

getType() - Method in class com.aliyun.odps.Resource

获取资源类型

getType() - Method in class com.aliyun.odps.task.copy.Datasource

getType() - Method in class com.aliyun.odps.Volume

getUploadSession(String, String, String, long, long) - Method in class com.aliyun.odps.tunnel.TableTunnel

获得在非分区表的上传会话，且该会话将要使用 TunnelBufferedWriter 进行数据上传。 当有多个这样的会话实例（多进程或多线程）共享会话 ID 时，需要同时声明此会话实例的唯一标识（shareId）和共享的会话实例个数（shares）。

getUploadSession(String, String, PartitionSpec, String, long, long) - Method in class com.aliyun.odps.tunnel.TableTunnel

获得在分区表的上传会话，且该会话将要使用 TunnelBufferedWriter 进行数据上传。 当有多个这样的会话实例（多进程或多线程）共享会话 ID 时，需要同时声明此会话实例的唯一标识（shareId）和共享的会话实例个数（shares）。

getUploadSession(String, String, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

获得在非分区表上创建的上传会话

getUploadSession(String, String, PartitionSpec, String) - Method in class com.aliyun.odps.tunnel.TableTunnel

获得在分区表上创建的上传会话

getUploadSession(String, String, String, String) - Method in class com.aliyun.odps.tunnel.VolumeTunnel

根据已有uploadId获取一个VolumeTunnel.UploadSession对象。

getUploadSessionId(VolumeOutputStream) - Static method in class com.aliyun.odps.tunnel.VolumeFSTunnel

Get upload sessionId from outputStream

getURI(String, String) - Method in class com.aliyun.odps.commons.GeneralConfiguration

取得URI

getUserAgent() - Method in class com.aliyun.odps.commons.GeneralConfiguration

获取User-Agent信息

getUserAgent() - Method in class com.aliyun.odps.Odps

获取访问API时附加的User-Agent信息

getValue() - Method in class com.aliyun.odps.Task.Property

返回属性值。

getViewText() - Method in class com.aliyun.odps.Table

获取视图的文本内容

getVolume() - Method in class com.aliyun.odps.VolumeFSFile

getVolume(String) - Static method in class com.aliyun.odps.VolumeFSFile

getVolumeFSFile(String) - Method in class com.aliyun.odps.Volume

getVolumePartition(String) - Method in class com.aliyun.odps.Volume

获取指定分区信息

getVolumePath() - Method in class com.aliyun.odps.VolumeResource

getWorkerNum() - Method in class com.aliyun.odps.StreamJob

GraphTask - Class in com.aliyun.odps.task

Java class for GraphType complex type.

GraphTask(String) - Constructor for class com.aliyun.odps.task.GraphTask

H

hasNext() - Method in class com.aliyun.odps.ListIterator

hasPartition(PartitionSpec) - Method in class com.aliyun.odps.Table

判断指定分区是否存在

HEADER_ODPS_CURRENT_PACKID - Static variable in class com.aliyun.odps.datahub.DatahubHttpHeaders

HEADER_ODPS_CURRENT_PACKID - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HEADER_ODPS_NEXT_PACKID - Static variable in class com.aliyun.odps.datahub.DatahubHttpHeaders

HEADER_ODPS_NEXT_PACKID - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HEADER_ODPS_PACK_NUM - Static variable in class com.aliyun.odps.datahub.DatahubHttpHeaders

HEADER_ODPS_PACK_NUM - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HEADER_ODPS_PACK_TIMESTAMP - Static variable in class com.aliyun.odps.datahub.DatahubHttpHeaders

HEADER_ODPS_PACK_TIMESTAMP - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HEADER_ODPS_REQUEST_ID - Static variable in class com.aliyun.odps.datahub.DatahubHttpHeaders

HEADER_ODPS_REQUEST_ID - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HEADER_ODPS_TUNNEL_VERSION - Static variable in class com.aliyun.odps.datahub.DatahubHttpHeaders

HEADER_ODPS_TUNNEL_VERSION - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HEADER_ODPS_VOLUME_FS_PATH - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HEADER_ODPS_VOLUME_SESSIONID - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HEADER_STREAM_VERSION - Static variable in class com.aliyun.odps.datahub.DatahubHttpHeaders

HEADER_STREAM_VERSION - Static variable in class com.aliyun.odps.tunnel.HttpHeaders

HttpHeaders - Class in com.aliyun.odps.tunnel

HttpHeaders() - Constructor for class com.aliyun.odps.tunnel.HttpHeaders

HUB_TABLE_TYPE - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

I

ignoreHttpsCerts(HttpURLConnection) - Static method in class com.aliyun.odps.account.AuthorizationUtil

InconsistentVolume - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

Instance - Class in com.aliyun.odps

Instance表示ODPS中计算任务的一个运行实例

Instance.Result - Class in com.aliyun.odps

Instance.Result() - Constructor for class com.aliyun.odps.Instance.Result

Instance.StageProgress - Class in com.aliyun.odps

StageProgress表示Task执行过程中各阶段的进度统计

Instance.StageProgress() - Constructor for class com.aliyun.odps.Instance.StageProgress

Instance.StageProgress.Status - Enum in com.aliyun.odps

Instance.Status - Enum in com.aliyun.odps

Instance的运行状态。

Instance.TaskCost - Class in com.aliyun.odps

Instance.TaskCost() - Constructor for class com.aliyun.odps.Instance.TaskCost

Instance.TaskStatus - Class in com.aliyun.odps

Task执行状态

Instance.TaskStatus.Status - Enum in com.aliyun.odps

Instance中Task的状态

Instance.TaskSummary - Class in com.aliyun.odps

TaskSummary包含Task运行结束后的汇总信息

Instance.TaskSummary() - Constructor for class com.aliyun.odps.Instance.TaskSummary

InstanceFilter - Class in com.aliyun.odps

InstanceFilter用于查询所有Instance时根据条件过滤

InstanceFilter() - Constructor for class com.aliyun.odps.InstanceFilter

Instances - Class in com.aliyun.odps

Instances表示ODPS中所有Instance的集合

instances() - Method in class com.aliyun.odps.Odps

获得表示ODPS所有Instance的集合对象

InstanceTunnel - Class in com.aliyun.odps.tunnel

InstanceTunnel(Odps) - Constructor for class com.aliyun.odps.tunnel.InstanceTunnel

构造此类对象

InstanceTunnel.DownloadSession - Class in com.aliyun.odps.tunnel

DownloadSession 表示从 ODPS Instance 中下载数据的会话，一般通过InstanceTunnel来创建。
Session ID 是 Session 的唯一标识符，可通过 InstanceTunnel.DownloadSession.getId() 获取。

Instance 中Record总数可通过 InstanceTunnel.DownloadSession.getRecordCount() 得到，用户可根据 Record 总数来启动并发下载。

DownloadSession 通过创建 RecordReader 来完成数据的读取,需指定读取记录的起始位置和数量
RecordReader 对应HTTP请求的超时时间为 300S，超时后 service 端会主动关闭。

InstanceTunnel.DownloadStatus - Enum in com.aliyun.odps.tunnel

下载会话的状态
UNKNOWN 未知
NORMAL 正常
CLOSED 关闭
EXPIRED 过期

InvalidItem - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

InvalidParameter - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

InvalidPath - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

InvalidSessionId - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

isArchived() - Method in class com.aliyun.odps.Partition

查看表是否进行了归档

isArchived() - Method in class com.aliyun.odps.Table

查看表是否进行过归档操作

isEnabled() - Static method in class com.aliyun.odps.OdpsHooks

获取 hook 开关

isExstore() - Method in class com.aliyun.odps.Partition

isHookInvoked() - Method in class com.aliyun.odps.Instance

isPartitioned() - Method in class com.aliyun.odps.Table

判断是否 Partition 表

isSuccessful() - Method in class com.aliyun.odps.Instance

检查Instance是否执行成功

isSync() - Method in class com.aliyun.odps.Instance

获得Instance是否为同步执行

isTerminated() - Method in class com.aliyun.odps.Instance

检查是否执行完成

isVirtualView() - Method in class com.aliyun.odps.Table

判断表是否为虚拟视图

ITER_MODE_AFTER_PACKID - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

ITER_MODE_AFTER_PACKID - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

ITER_MODE_AT_PACKID - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

ITER_MODE_AT_PACKID - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

ITER_MODE_FIRST_PACK - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

ITER_MODE_LAST_PACK - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

iterable() - Method in class com.aliyun.odps.Functions

返回指定Project下所有函数的迭代器

iterable(String) - Method in class com.aliyun.odps.Functions

返回指定Project下所有函数的迭代器

iterable() - Method in class com.aliyun.odps.Instances

获得Instance的 iterable 迭代器

iterable(String) - Method in class com.aliyun.odps.Instances

获得指定Project下，Instance iterable迭代器

iterable(InstanceFilter) - Method in class com.aliyun.odps.Instances

获得Instance iterable 迭代器

iterable(String, InstanceFilter) - Method in class com.aliyun.odps.Instances

获得指定Project下，Instance iterable 迭代器

iterable(String) - Method in class com.aliyun.odps.Resources

获得资源 iterable 迭代器

iterable() - Method in class com.aliyun.odps.Resources

获得资源 iterable 迭代器

iterable() - Method in class com.aliyun.odps.Tables

获取默认Project的所有表信息迭代器 iterable

iterable(String) - Method in class com.aliyun.odps.Tables

获取表信息迭代器 iterable

iterable(TableFilter) - Method in class com.aliyun.odps.Tables

获取默认Project的表信息迭代器 iterable

iterable(String, TableFilter) - Method in class com.aliyun.odps.Tables

获得表信息迭代器 iterable

ITERATE_MODE - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

ITERATE_MODE - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

iterator() - Method in class com.aliyun.odps.Functions

返回默认Project下所有函数的迭代器

iterator(String) - Method in class com.aliyun.odps.Functions

返回指定Project下所有函数的迭代器

iterator() - Method in class com.aliyun.odps.Instances

获得Instance的迭代器

iterator(String) - Method in class com.aliyun.odps.Instances

获得指定Project下，Instance迭代器

iterator(InstanceFilter) - Method in class com.aliyun.odps.Instances

获得Instance迭代器

iterator(String, InstanceFilter) - Method in class com.aliyun.odps.Instances

获得指定Project下，Instance迭代器

iterator(String) - Method in class com.aliyun.odps.Resources

获得资源迭代器

iterator() - Method in class com.aliyun.odps.Resources

获得资源迭代器

iterator() - Method in class com.aliyun.odps.StreamJobs

iterator(String) - Method in class com.aliyun.odps.StreamJobs

iterator() - Method in class com.aliyun.odps.Tables

获取默认Project的所有表信息迭代器

iterator(String) - Method in class com.aliyun.odps.Tables

获取表信息迭代器

iterator(TableFilter) - Method in class com.aliyun.odps.Tables

获取默认Project的表信息迭代器

iterator(String, TableFilter) - Method in class com.aliyun.odps.Tables

获得表信息迭代器

iterator() - Method in class com.aliyun.odps.Topologies

获取默认Project的所有Topology信息迭代器

iterator(String) - Method in class com.aliyun.odps.Topologies

获取Topology信息迭代器

iterator() - Method in class com.aliyun.odps.VolumeFSFile

iterator() - Method in class com.aliyun.odps.Volumes

获取默认Project的所有Volume信息迭代器

iterator(String) - Method in class com.aliyun.odps.Volumes

获取Volume信息迭代器

iterator(VolumeFilter) - Method in class com.aliyun.odps.Volumes

获取Volume信息迭代器

iterator(String, VolumeFilter) - Method in class com.aliyun.odps.Volumes

获取Volume信息迭代器

J

JarResource - Class in com.aliyun.odps

JarResource表示ODPS中一个JAR类型的资源

JarResource() - Constructor for class com.aliyun.odps.JarResource

构造Jar类型的资源对象

Job - Class in com.aliyun.odps

ODPS Job定义。ODPS内部使用。

Job() - Constructor for class com.aliyun.odps.Job

Job(Job.JobModel) - Constructor for class com.aliyun.odps.Job

L

LAST_PACK_ID - Static variable in interface com.aliyun.odps.datahub.PackType

LazyLoad - Class in com.aliyun.odps

LazyLoad表示此类型的属性值可能是延迟加载的

LazyLoad() - Constructor for class com.aliyun.odps.LazyLoad

ListIterator<E> - Class in com.aliyun.odps

支持通过ListIterator.list()自定义的Iterator

ListIterator() - Constructor for class com.aliyun.odps.ListIterator

loadFromJson(InputStream) - Method in exception com.aliyun.odps.tunnel.TunnelException

Deprecated.

loadShard(long) - Method in class com.aliyun.odps.datahub.DatahubClient

在ODPS hub服务上启用shard

loadShard(long) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

在ODPS hub服务上启用shard

loadShard(int) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

loadTables(Collection<String>) - Method in class com.aliyun.odps.Tables

批量加载表信息

loadTables(String, Collection<String>) - Method in class com.aliyun.odps.Tables

批量加载表信息

LOCAL_ERROR_CODE - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

LOCAL_ERROR_CODE - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

LocalDatasource - Class in com.aliyun.odps.task.copy

LocalDatasource(Datasource.Direction, String, String, String) - Constructor for class com.aliyun.odps.task.copy.LocalDatasource

LogType - Enum in com.aliyun.odps

日志类型。

LogView - Class in com.aliyun.odps

LogView(Odps) - Constructor for class com.aliyun.odps.LogView

logview() - Method in class com.aliyun.odps.Odps

获取Logview工具类

LOTTask - Class in com.aliyun.odps.task

LOTTask的定义

LOTTask() - Constructor for class com.aliyun.odps.task.LOTTask

LOTTask.Plan - Class in com.aliyun.odps.task

LOTTask.Plan() - Constructor for class com.aliyun.odps.task.LOTTask.Plan

M

MappingItem - Class in com.aliyun.odps.task.copy

MappingItem(String, String) - Constructor for class com.aliyun.odps.task.copy.MappingItem

marshal(LinkedHashMap<String, String>) - Method in class com.aliyun.odps.XmlPropertyMapAdapter

md5Signature(String) - Static method in class com.aliyun.odps.account.SecurityUtils

MODE - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

MoyeTask - Class in com.aliyun.odps.task

MoyeTask() - Constructor for class com.aliyun.odps.task.MoyeTask

N

newRecord() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

创建临时Record对象

newRecordPack() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

newRecordPack(CompressOption) - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

next() - Method in class com.aliyun.odps.ListIterator

NON_VOLUME_FS_ERROR - Static variable in exception com.aliyun.odps.VolumeException

NoPermission - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

NORMAL_TABLE_TYPE - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

NoSuchObjectException - Exception in com.aliyun.odps

ODPS对象不存在

NoSuchObjectException() - Constructor for exception com.aliyun.odps.NoSuchObjectException

NoSuchObjectException(String) - Constructor for exception com.aliyun.odps.NoSuchObjectException

NoSuchObjectException(String, Throwable) - Constructor for exception com.aliyun.odps.NoSuchObjectException

NoSuchPath - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

NoSuchVolume - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

NotAcceptableOperation - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

O

Odps - Class in com.aliyun.odps

Odps类是ODPS SDK的入口

Odps(Account) - Constructor for class com.aliyun.odps.Odps

指定Account构造Odps对象

Odps(Odps) - Constructor for class com.aliyun.odps.Odps

OdpsException - Exception in com.aliyun.odps

ODPS SDK产生的异常

OdpsException() - Constructor for exception com.aliyun.odps.OdpsException

OdpsException(String) - Constructor for exception com.aliyun.odps.OdpsException

OdpsException(String, String) - Constructor for exception com.aliyun.odps.OdpsException

OdpsException(String, Throwable) - Constructor for exception com.aliyun.odps.OdpsException

OdpsException(String, String, Throwable) - Constructor for exception com.aliyun.odps.OdpsException

OdpsException(Exception) - Constructor for exception com.aliyun.odps.OdpsException

OdpsHook - Class in com.aliyun.odps

OdpsHook 对象，用于在提交作业前后插入代码

OdpsHook() - Constructor for class com.aliyun.odps.OdpsHook

OdpsHooks - Class in com.aliyun.odps

OdpsHooks 类 注册 OdpsHook 类 用于在启动 Instance 前后分别运行插件代码 一个 OdpsHooks 实例针对一个 Instance， 包含了一组实例化的 OdpsHook 对象

OdpsHooks() - Constructor for class com.aliyun.odps.OdpsHooks

新建一个 OdpsHooks 对象

onInstanceCreated(Instance, Odps) - Method in class com.aliyun.odps.OdpsHook

向远程提交 job 并产生 instance 时，将 Instance 和 Odps 对象传入 Hook

onInstanceCreated(Instance, Odps) - Method in class com.aliyun.odps.OdpsHooks

调用 Hook 的 ready

openBufferedWriter() - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

打开一个无压缩 TunnelBufferedWriter 用来写入数据

openBufferedWriter(boolean) - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

打开 TunnelBufferedWriter 用来写入数据

openBufferedWriter(CompressOption) - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

打开 TunnelBufferedWriter 用来写入数据

openDatahubReader(long) - Method in class com.aliyun.odps.datahub.DatahubClient

创建DatahubReader读取指定shard

openDatahubReader(long, String) - Method in class com.aliyun.odps.datahub.DatahubClient

创建DatahubReader读取指定shard

openDatahubWriter(long) - Method in class com.aliyun.odps.datahub.DatahubClient

创建DatahubWriter写入指定shard

openDatahubWriter() - Method in class com.aliyun.odps.datahub.DatahubClient

创建DatahubWriter

openInputStream(String, String, Long, Long, CompressOption) - Method in class com.aliyun.odps.tunnel.VolumeFSTunnel

Create an InputStream at the indicated Path

openInputStream() - Method in class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

创建InputStream用来将指定File以数据流的形式输出。

openInputStream(boolean) - Method in class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

创建InputStream用来将指定File以数据流的形式输出。

openInputStream(long, long) - Method in class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

创建InputStream用来将指定File以数据流的形式输出。

openInputStream(long, long, boolean) - Method in class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

创建InputStream用来将指定File以数据流的形式输出。

openOutputStream(String, String, Integer, CompressOption) - Method in class com.aliyun.odps.tunnel.VolumeFSTunnel

Create an OutputStream at the indicated Path

openOutputStream(String) - Method in class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

创建OutputStream用来将数据流入到指定File。

openOutputStream(String, boolean) - Method in class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

创建OutputStream用来将数据流入到指定File。

openOutputStream(String, boolean, boolean) - Method in class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

创建OutputStream用来将数据流入到指定File。

openPackReader(long) - Method in class com.aliyun.odps.datahub.DatahubClient

openPackReader(long, String) - Method in class com.aliyun.odps.datahub.DatahubClient

openPackReader(long) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

openPackReader(long, String) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

openRecordReader(long, long) - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long, boolean) - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long, CompressOption) - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long, boolean, List<Column>) - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long, CompressOption, List<Column>) - Method in class com.aliyun.odps.tunnel.InstanceTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long) - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long, boolean) - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long, CompressOption) - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long, boolean, List<Column>) - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordReader(long, long, CompressOption, List<Column>) - Method in class com.aliyun.odps.tunnel.TableTunnel.DownloadSession

打开RecordReader用来读取记录

openRecordWriter(long) - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

打开RecordWriter用来写入数据

openRecordWriter(long, boolean) - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

打开RecordWriter用来写入数据

openRecordWriter(long, CompressOption) - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

打开RecordWriter用来写入数据

openStreamReader(long) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

openStreamReader(long, String) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

openStreamUploadWriter() - Method in class com.aliyun.odps.tunnel.StreamUploadClient

Deprecated.

打开StreamUploadWriter

openStreamWriter(String) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

openStreamWriter(long) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

openStreamWriter() - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

P

PACK_FETCHMODE - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

PACK_ID - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

PACK_ID - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

PACK_NUM - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

PACK_NUM - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

PACKID_LENGTH - Static variable in interface com.aliyun.odps.datahub.PackType

PackReader - Class in com.aliyun.odps.datahub

PackReader(RestClient, TableSchema, String, Map<String, String>, Map<String, String>) - Constructor for class com.aliyun.odps.datahub.PackReader

PackReader(RestClient, TableSchema, String, Map<String, String>, Map<String, String>, String) - Constructor for class com.aliyun.odps.datahub.PackReader

PackType - Interface in com.aliyun.odps.datahub

PackType.ReadMode - Enum in com.aliyun.odps.datahub

ParentNotDirectory - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

parseShard(JSONObject) - Static method in class com.aliyun.odps.Shard

parseShard(JsonNode) - Static method in class com.aliyun.odps.Shard

Deprecated.

use another method parseShard(JSONObject tree)

Partition - Class in com.aliyun.odps

Partition类的对象表示ODPS分区表中一个特定的分区

PathAlreadyExists - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

pause(String) - Method in class com.aliyun.odps.StreamJobs

暂停StreamJob

pause(String, String) - Method in class com.aliyun.odps.StreamJobs

暂停StreamJob

Project - Class in com.aliyun.odps

ODPS项目空间

Project.Cluster - Class in com.aliyun.odps

Project.Cluster(String, String) - Constructor for class com.aliyun.odps.Project.Cluster

Project.Status - Enum in com.aliyun.odps

项目空间状态

projects() - Method in class com.aliyun.odps.Odps

获取表示ODPS所有Project的集合对象

Projects - Class in com.aliyun.odps

Projects表示ODPS中所有Project的集合

PyResource - Class in com.aliyun.odps

PyResource表示ODPS中一个python类型资源

PyResource() - Constructor for class com.aliyun.odps.PyResource

构造Py类型的资源对象

Q

QueryReplicatorStatus(long, PartitionSpec) - Method in class com.aliyun.odps.datahub.DatahubClient

Deprecated.

返回的packid不一定是对应partition的, 只能通过比较大小来判断, 不要使用是否相等来判断

QueryReplicatorStatus(long) - Method in class com.aliyun.odps.datahub.DatahubClient

在ODPS hub查询非分区表拷贝到离线集群的状态

QueryReplicatorStatus(long, PartitionSpec) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

在ODPS hub查询partiton对应的拷贝到离线集群的状态

QueryReplicatorStatus(long) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

在ODPS hub查询非分区表拷贝到离线集群的状态

R

RANGE - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

read() - Method in class com.aliyun.odps.data.DefaultRecordReader

读取一条记录

read() - Method in interface com.aliyun.odps.data.RecordReader

读取一条记录

read() - Method in class com.aliyun.odps.datahub.DatahubReader

从指定的shard读取一条记录

read() - Method in class com.aliyun.odps.datahub.PackReader

read(String, PackType.ReadMode) - Method in class com.aliyun.odps.datahub.PackReader

read(int) - Method in class com.aliyun.odps.Table

读取表内的数据

read(PartitionSpec, List<String>, int) - Method in class com.aliyun.odps.Table

读取表内的数据
读取数据时，最多返回 1W 条记录，若超过，数据将被截断。
另外，读取的数据大小不能超过 10MB，否则将抛出异常。

readMeta() - Method in class com.aliyun.odps.datahub.DatahubReader

readMeta() - Method in class com.aliyun.odps.datahub.PackReader

readPackMeta() - Method in class com.aliyun.odps.datahub.PackReader

ReadPackResult - Class in com.aliyun.odps.datahub

ReadPackResult(String, String, long, String, List<Record>) - Constructor for class com.aliyun.odps.datahub.ReadPackResult

ReadPackResult(String, String, long, String, List<Record>, byte[]) - Constructor for class com.aliyun.odps.datahub.ReadPackResult

ReadPackResult(String, String, long, String, List<Record>, Map<String, String>) - Constructor for class com.aliyun.odps.datahub.ReadPackResult

readRaw() - Method in class com.aliyun.odps.data.DefaultRecordReader

rebalance(String, Map<String, String>) - Method in class com.aliyun.odps.StreamJobs

Rebalance StreamJob

rebalance(String, String, Map<String, String>) - Method in class com.aliyun.odps.StreamJobs

Rebalance StreamJob

RECORD_COUNT - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

RECORD_COUNT - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

RecordPack - Class in com.aliyun.odps.data

RecordPack 用于在内存中存放批量 Record

RecordPack() - Constructor for class com.aliyun.odps.data.RecordPack

RecordReader - Interface in com.aliyun.odps.data

RecordReader用来读取记录

RecordWriter - Interface in com.aliyun.odps.data

RecordWriter用来写入一条记录

registerHook(Class<? extends OdpsHook>) - Static method in class com.aliyun.odps.OdpsHooks

注册一个 hook

registerHooks(Collection<Class<? extends OdpsHook>>) - Static method in class com.aliyun.odps.OdpsHooks

注册多个 hook

reload() - Method in class com.aliyun.odps.Function

reload() - Method in class com.aliyun.odps.Instance

reload() - Method in class com.aliyun.odps.LazyLoad

重新加载属性值

reload() - Method in class com.aliyun.odps.Partition

reload() - Method in class com.aliyun.odps.Project

reload() - Method in class com.aliyun.odps.Resource

reload() - Method in class com.aliyun.odps.StreamJob

reload() - Method in class com.aliyun.odps.Table

reload(Table.TableModel) - Method in class com.aliyun.odps.Table

reload() - Method in class com.aliyun.odps.Topology

reload() - Method in class com.aliyun.odps.Volume

reload() - Method in class com.aliyun.odps.VolumeFSFile

reload() - Method in class com.aliyun.odps.VolumePartition

ReloadException - Exception in com.aliyun.odps

重新加载异常，当LazyLoad对象实际加载对象属性时， 如果遇到网络等异常状况，可能抛出此异常

ReloadException() - Constructor for exception com.aliyun.odps.ReloadException

ReloadException(String) - Constructor for exception com.aliyun.odps.ReloadException

ReloadException(String, Throwable) - Constructor for exception com.aliyun.odps.ReloadException

ReloadException(Throwable) - Constructor for exception com.aliyun.odps.ReloadException

reloadTables(Collection<Table>) - Method in class com.aliyun.odps.Tables

批量加载表信息

reloadTables(Iterator<Table>) - Method in class com.aliyun.odps.Tables

批量加载表信息
rest api 对请求数量有限制, 目前一次操作最多可请求 100 张表信息;
返回的表数据,与操作权限有关.

remove() - Method in class com.aliyun.odps.ListIterator

removeProperty(Task.Property) - Method in class com.aliyun.odps.Task.Properties

ReplicatorStatus - Class in com.aliyun.odps.datahub

ReplicatorStatus(InputStream) - Constructor for class com.aliyun.odps.datahub.ReplicatorStatus

RequestedRangeNotSatisfiable - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

RequestEntityTooLarge - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

RequestSigner - Interface in com.aliyun.odps.account

RequestSigner用于对HTTP请求进行签名

RES_COLUMNS - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

RES_PARTITION - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

RES_PARTITION - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

RES_SHARD - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

RESERVED_META_PARTITION - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

Resource - Class in com.aliyun.odps

Resource表示ODPS中的资源

Resource() - Constructor for class com.aliyun.odps.Resource

创建Resource类的对象

Resource.Type - Enum in com.aliyun.odps

表示ODPS中资源的类型

resources() - Method in class com.aliyun.odps.Odps

获取表示ODPS所有Resource的集合对象

Resources - Class in com.aliyun.odps

Resources 表示ODPS内所有Resource的集合，可以通过此对象可以创建、删除和浏览 各种Resource类型。
比如：

resume(String, Map<String, String>) - Method in class com.aliyun.odps.StreamJobs

恢复StreamJob

resume(String, String, Map<String, String>) - Method in class com.aliyun.odps.StreamJobs

恢复StreamJob

RESUME_MODE - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

ROW_RANGE - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

run(Odps, String, String, Map<String, String>, int) - Static method in class com.aliyun.odps.task.CupidTask

run(Odps, String, String, Map<String, String>) - Static method in class com.aliyun.odps.task.CupidTask

run(Odps, String, GraphTask) - Static method in class com.aliyun.odps.task.GraphTask

run(Odps, String, GraphTask, int) - Static method in class com.aliyun.odps.task.GraphTask

run(Odps, String, boolean) - Static method in class com.aliyun.odps.task.LOTTask

通过匿名Instance运行LOTTask

run(Odps, String, String, boolean, Map<String, String>, Map<String, String>) - Static method in class com.aliyun.odps.task.LOTTask

通过匿名Instance运行LOTTask

run(Odps, String, String, boolean, String, Map<String, String>, Map<String, String>) - Static method in class com.aliyun.odps.task.LOTTask

运行LOTTask

run(Odps, String, String, Map<String, String>, int) - Static method in class com.aliyun.odps.task.MoyeTask

run(Odps, String, String, Map<String, String>) - Static method in class com.aliyun.odps.task.MoyeTask

run(Odps, String) - Static method in class com.aliyun.odps.task.SQLCostTask

通过匿名Instance运行SQLCostTask

run(Odps, String, String, Map<String, String>) - Static method in class com.aliyun.odps.task.SQLCostTask

通过匿名Instance运行SQLCostTask

run(Odps, String, String, String, Map<String, String>) - Static method in class com.aliyun.odps.task.SQLCostTask

运行SQLCostTask

run(Odps, String) - Static method in class com.aliyun.odps.task.SQLTask

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

示例代码：

run(Odps, String, String, Map<String, String>, Map<String, String>) - Static method in class com.aliyun.odps.task.SQLTask

运行SQL

run(Odps, String, String, String, Map<String, String>, Map<String, String>) - Static method in class com.aliyun.odps.task.SQLTask

run(Odps, String, String, String, Map<String, String>, Map<String, String>, int) - Static method in class com.aliyun.odps.task.SQLTask

S

SecurityUtils - Class in com.aliyun.odps.account

SecurityUtils() - Constructor for class com.aliyun.odps.account.SecurityUtils

seek(long) - Method in class com.aliyun.odps.datahub.DatahubReader

seek(long) - Method in class com.aliyun.odps.datahub.PackReader

SEEK_TIME - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

SEEK_TIME - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

SeekPackResult - Class in com.aliyun.odps.datahub

SeekPackResult(String) - Constructor for class com.aliyun.odps.datahub.SeekPackResult

setAccount(Account) - Method in class com.aliyun.odps.Odps

setAccountType(String) - Method in class com.aliyun.odps.task.copy.TunnelDatasource

setChunkSize(int) - Method in class com.aliyun.odps.commons.GeneralConfiguration

设置上传数据时HTTP使用的块大小(单位字节)。

setClassPath(String) - Method in class com.aliyun.odps.Function

设置函数使用的类名

setClassType(String) - Method in class com.aliyun.odps.Function

Deprecated.

setComment(String) - Method in class com.aliyun.odps.Job

setComment(String) - Method in class com.aliyun.odps.Resource

设置资源注释信息

setComment(String) - Method in class com.aliyun.odps.Task

设置注释信息

setCPUCost(Integer) - Method in class com.aliyun.odps.Instance.TaskCost

setDefaultProject(String) - Method in class com.aliyun.odps.Odps

指定默认使用的Project名称

setDefaultRunningCluster(String) - Method in class com.aliyun.odps.Instances

设置默认 runningCluster 如果为 null,使用project 默认 cluster

setEnabled(boolean) - Static method in class com.aliyun.odps.OdpsHooks

设置 hook 开关

setEndpoint(URI) - Method in class com.aliyun.odps.commons.GeneralConfiguration

Set endpoint

setEndpoint(String) - Method in class com.aliyun.odps.datahub.DatahubClient

设置DatahubServer地址

setEndpoint(String) - Method in class com.aliyun.odps.Odps

设置ODPS服务的地址

setEndPoint(String) - Method in class com.aliyun.odps.task.copy.TunnelDatasource

setEndpoint(String) - Method in class com.aliyun.odps.tunnel.InstanceTunnel

设置TunnelServer地址

setEndpoint(String) - Method in class com.aliyun.odps.tunnel.TableTunnel

设置TunnelServer地址

setEndpoint(String) - Method in class com.aliyun.odps.tunnel.VolumeFSTunnel

setEndpoint(String) - Method in class com.aliyun.odps.tunnel.VolumeTunnel

设置TunnelServer地址

setEndTime(Date) - Method in class com.aliyun.odps.InstanceFilter

设置结束时间的过滤条件

setErrorCode(String) - Method in exception com.aliyun.odps.datahub.DatahubException

setErrorCode(String) - Method in exception com.aliyun.odps.tunnel.TunnelException

setErrorMsg(String) - Method in exception com.aliyun.odps.datahub.DatahubException

setErrorMsg(String) - Method in exception com.aliyun.odps.tunnel.TunnelException

setFromTime(Date) - Method in class com.aliyun.odps.InstanceFilter

设置起始时间过滤条件

setHookInvoked(boolean) - Method in class com.aliyun.odps.Instance

setInputSize(Integer) - Method in class com.aliyun.odps.Instance.TaskCost

setInputTablenames(String) - Method in class com.aliyun.odps.task.XLibTask

setIsTempResource(boolean) - Method in class com.aliyun.odps.FileResource

设置是否是临时资源

setJobConf(Task.Properties) - Method in class com.aliyun.odps.task.GraphTask

Sets the value of the jobConf property.

setLogViewHost(String) - Method in class com.aliyun.odps.LogView

setLogViewHost(String) - Method in class com.aliyun.odps.Odps

设置logview host地址

setMemoryCost(Integer) - Method in class com.aliyun.odps.Instance.TaskCost

setMethod(String) - Method in class com.aliyun.odps.task.XLibTask

设置方法名。

setName(String) - Method in class com.aliyun.odps.Function

设置函数名

setName(String) - Method in class com.aliyun.odps.Job

setName(String) - Method in class com.aliyun.odps.Resource

设置资源名称

setName(String) - Method in class com.aliyun.odps.TableFilter

设置表名前缀

setName(String) - Method in class com.aliyun.odps.Task.Property

设置属性值。

setName(String) - Method in class com.aliyun.odps.Task

设置Task的名称

setName(String) - Method in class com.aliyun.odps.VolumeFilter

设置Volume名或partition名前缀

setOdpsEndPoint(String) - Method in class com.aliyun.odps.task.copy.TunnelDatasource

setOdpsHooks(OdpsHooks) - Method in class com.aliyun.odps.Instance

setOnlyOwner(Boolean) - Method in class com.aliyun.odps.InstanceFilter

设置Instance状态过滤条件，只返回owner的Instance

setOperationType(String) - Method in class com.aliyun.odps.task.GalaxyTask

setOutputTablenames(String) - Method in class com.aliyun.odps.task.XLibTask

setOwner(String) - Method in class com.aliyun.odps.TableFilter

设置表所有者

setParameters(String) - Method in class com.aliyun.odps.task.XLibTask

设置参数。

setPlan(String) - Method in class com.aliyun.odps.task.CupidTask

setPlan(LOTTask.Plan) - Method in class com.aliyun.odps.task.LOTTask

设置查询Plan

setPlan(String) - Method in class com.aliyun.odps.task.MoyeTask

setPriority(int) - Method in class com.aliyun.odps.Job

setProject(String) - Method in class com.aliyun.odps.task.LOTTask.Plan

setProperties(Map<String, String>) - Method in class com.aliyun.odps.Task

设置所有配置信息

setProperty(String, String) - Method in class com.aliyun.odps.Task

设置配置

setQuery(String) - Method in class com.aliyun.odps.task.LOTTask

设置SQL查询语句

setQuery(String) - Method in class com.aliyun.odps.task.SQLCostTask

设置SQL查询语句

setQuery(String) - Method in class com.aliyun.odps.task.SqlPlanTask

设置查询语句。

setQuery(String) - Method in class com.aliyun.odps.task.SQLTask

设置SQL查询语句

setRequestId(String) - Method in exception com.aliyun.odps.datahub.DatahubException

setRequestId(String) - Method in exception com.aliyun.odps.tunnel.TunnelException

setResourceName(String) - Method in class com.aliyun.odps.task.LOTTask.Plan

setResources(List<String>) - Method in class com.aliyun.odps.Function

设置函数依赖的相关资源

setRunningCluster(String) - Method in class com.aliyun.odps.Job

setSettings(String) - Method in class com.aliyun.odps.task.GalaxyTask

setSignature(String) - Method in class com.aliyun.odps.task.copy.TunnelDatasource

setSocketConnectTimeout(int) - Method in class com.aliyun.odps.commons.GeneralConfiguration

设置网络链接超时时间, 单位秒

setSocketTimeout(int) - Method in class com.aliyun.odps.commons.GeneralConfiguration

设置网络IO超时时间, 秒

setSql(String) - Method in class com.aliyun.odps.task.GalaxyTask

setStatus(Instance.Status) - Method in class com.aliyun.odps.InstanceFilter

设置Instance状态过滤条件，只返回处于该状态的Instance

setStreamJobName(String) - Method in class com.aliyun.odps.task.GalaxyTask

setUserAgent(String) - Method in class com.aliyun.odps.Odps

设置访问API时附加的User-Agent信息

setValue(String) - Method in class com.aliyun.odps.Task.Property

设置属性值。

setVolumePath(String) - Method in class com.aliyun.odps.VolumeResource

Shard - Class in com.aliyun.odps

Created by yinyue on 15-3-17.

SHARD_NUMBER - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

SHARD_NUMBER - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

SHARD_STATUS - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

SHARD_STATUS - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

sign(String, Request) - Method in class com.aliyun.odps.account.AliyunRequestSigner

sign(String, Request) - Method in interface com.aliyun.odps.account.RequestSigner

对HTTP请求签名

skipPack() - Method in class com.aliyun.odps.datahub.DatahubReader

跳过某条Record不进行数据读取

SQLCostTask - Class in com.aliyun.odps.task

SQLCoastTask的定义

SQLCostTask() - Constructor for class com.aliyun.odps.task.SQLCostTask

SqlPlanTask - Class in com.aliyun.odps.task

执行SQL Plan的任务。

SqlPlanTask(String) - Constructor for class com.aliyun.odps.task.SqlPlanTask

使用给定任务名构造一个SqlPlanTask实例。

SqlPlanTask(String, String) - Constructor for class com.aliyun.odps.task.SqlPlanTask

使用给定任务名和查询语句构造一个SqlPlanTask实例。

SQLTask - Class in com.aliyun.odps.task

SQLTask的定义

SQLTask() - Constructor for class com.aliyun.odps.task.SQLTask

stop() - Method in class com.aliyun.odps.Instance

停止正在执行的Instance

STREAM_UPLOAD - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

StreamClient - Class in com.aliyun.odps.tunnel

Deprecated.

StreamClient(Configuration, String, String) - Constructor for class com.aliyun.odps.tunnel.StreamClient

Deprecated.

StreamClient.ShardState - Enum in com.aliyun.odps.tunnel

Deprecated.

shard的状态

StreamJob - Class in com.aliyun.odps

StreamJobs表示ODPS中所有StreamJob的集合

StreamJob(StreamJob.StreamJobModel, String, RestClient) - Constructor for class com.aliyun.odps.StreamJob

streamJobs() - Method in class com.aliyun.odps.Odps

获取表示Project下所有STREAMJOB的集合对象

StreamJobs - Class in com.aliyun.odps

StreamJobs表示ODPS中所有StreamJob的集合

StreamJobs(Odps) - Constructor for class com.aliyun.odps.StreamJobs

StreamTask - Class in com.aliyun.odps.task

StreamTask() - Constructor for class com.aliyun.odps.task.StreamTask

StreamUploadClient - Class in com.aliyun.odps.tunnel

Deprecated.

StreamUploadWriter - Class in com.aliyun.odps.tunnel

Created by yinyue on 15-6-10.

StreamUploadWriter(RestClient, String) - Constructor for class com.aliyun.odps.tunnel.StreamUploadWriter

StreamUploadWriter(RestClient, String, HashMap<String, String>, HashMap<String, String>, TunnelTableSchema) - Constructor for class com.aliyun.odps.tunnel.StreamUploadWriter

T

Table - Class in com.aliyun.odps

Table表示ODPS中的表

TABLE_REPLICATED_TIMESTAMP - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

TableFilter - Class in com.aliyun.odps

TableFilter用于查询所有表时根据条件过滤表

TableFilter() - Constructor for class com.aliyun.odps.TableFilter

TableResource - Class in com.aliyun.odps

TableResource表示ODPS中一个表资源

TableResource() - Constructor for class com.aliyun.odps.TableResource

构造此类的对象

TableResource(String) - Constructor for class com.aliyun.odps.TableResource

构造此类的对象

TableResource(String, String) - Constructor for class com.aliyun.odps.TableResource

构造此类的对象

TableResource(String, String, PartitionSpec) - Constructor for class com.aliyun.odps.TableResource

构造此类的对象

TableResource(Resource) - Constructor for class com.aliyun.odps.TableResource

Deprecated.

tables() - Method in class com.aliyun.odps.Odps

获取表示ODPS所有Table的集合对象

Tables - Class in com.aliyun.odps

Tables表示ODPS中所有Table的集合

TableTunnel - Class in com.aliyun.odps.tunnel

Tunnel 是 ODPS 的数据通道，用户可以通过 Tunnel 向 ODPS 中上传或者下载数据。
TableTunnel 是访问 ODPS Tunnel 服务的入口类，仅支持表数据（非视图）的上传和下载。

对一张表或 partition 上传下载的过程，称为一个session。session 由一或多个到 Tunnel RESTful API 的 HTTP Request 组成。
session 用 session ID 来标识，session 的超时时间是24小时，如果大批量数据传输导致超过24小时，需要自行拆分成多个 session。
数据的上传和下载分别由 TableTunnel.UploadSession 和 TableTunnel.DownloadSession 这两个会话来负责。
TableTunnel 提供创建 UploadSession 对象和 DownloadSession 对象的方法.

典型表数据上传流程：
1) 创建 TableTunnel
2) 创建 UploadSession
3) 创建 RecordWriter,写入 Record
4）提交上传操作

典型表数据下载流程：
1) 创建 TableTunnel
2) 创建 DownloadSession
3) 创建 RecordReader,读取 Record

TableTunnel(Odps) - Constructor for class com.aliyun.odps.tunnel.TableTunnel

构造此类对象

TableTunnel.DownloadSession - Class in com.aliyun.odps.tunnel

DownloadSession 表示从 ODPS 表中下载数据的会话，一般通过TableTunnel来创建。
Session ID 是 Session 的唯一标识符，可通过 TableTunnel.DownloadSession.getId() 获取。

表中Record总数可通过 TableTunnel.DownloadSession.getRecordCount() 得到，用户可根据 Record 总数来启动并发下载。

DownloadSession 通过创建 RecordReader 来完成数据的读取,需指定读取记录的起始位置和数量
RecordReader 对应HTTP请求的超时时间为 300S，超时后 service 端会主动关闭。

TableTunnel.DownloadStatus - Enum in com.aliyun.odps.tunnel

下载会话的状态
UNKNOWN 未知
NORMAL 正常
CLOSED 关闭
EXPIRED 过期

TableTunnel.UploadSession - Class in com.aliyun.odps.tunnel

UploadSession 表示向ODPS表中上传数据的会话，一般通过TableTunnel来创建。
上传 Session 是 INSERT INTO 语义，即对同一张表或 partition 的多个/多次上传 Session 互不影响。
Session ID 是Session的唯一标识符，可通过 TableTunnel.UploadSession.getId() 获取。

UploadSession 通过创建 RecordWriter 来完成数据的写入操作。
每个 RecordWriter 对应一个 HTTP Request，单个 UploadSession 可创建多个RecordWriter。

创建 RecordWriter 时需指定 block ID，block ID是 RecordWriter 的唯一标识符,取值范围 [0, 20000)，单个block上传的数据限制是 100G。
同一 UploadSession 中，使用同一 block ID 多次打开 RecordWriter 会导致覆盖行为，最后一个调用 close() 的 RecordWriter 所上传的数据会被保留。同一RecordWriter实例不能重复调用 close().
RecordWriter 对应的 HTTP Request超时为 120s，若 120s 内没有数据传输，service 端会主动关闭连接。特别提醒，HTTP协议本身有8K buffer。

TableTunnel.UploadStatus - Enum in com.aliyun.odps.tunnel

UploadStatus表示当前Upload的状态
UNKNOWN 未知
NORMAL 正常
CLOSING 关闭中
CLOSED 已关闭
CANCELED 已取消
EXPIRED 已过期
CRITICAL 严重错误

TARGET - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

Task - Class in com.aliyun.odps

ODPS的Task定义

Task() - Constructor for class com.aliyun.odps.Task

Task.Properties - Class in com.aliyun.odps

Task properties

Task.Properties() - Constructor for class com.aliyun.odps.Task.Properties

Task.Property - Class in com.aliyun.odps

Task property

Task.Property(String, String) - Constructor for class com.aliyun.odps.Task.Property

构造一个新的Task.Property实例。

topologies() - Method in class com.aliyun.odps.Odps

获取表示Project下所有TOPOLOGY的集合对象

Topologies - Class in com.aliyun.odps

Topologies表示ODPS中所有Topology的集合

Topologies(Odps) - Constructor for class com.aliyun.odps.Topologies

Topology - Class in com.aliyun.odps

Topologies表示ODPS中所有Topology的集合

Topology(Topology.TopologyModel, String, RestClient) - Constructor for class com.aliyun.odps.Topology

toString() - Method in exception com.aliyun.odps.datahub.DatahubException

toString() - Method in enum com.aliyun.odps.Instance.Status

RUNNING 被转换成 "Running"，SUSPENDED 被转换成 "Suspended"，TERMINATED 被转换成 "Terminated"。

toString() - Method in enum com.aliyun.odps.LogType

toString() - Method in exception com.aliyun.odps.tunnel.TunnelException

toString() - Method in exception com.aliyun.odps.VolumeException

toXmlString() - Method in class com.aliyun.odps.Job

transferVolumeToVolumeFSFile(String, Volume, RestClient) - Static method in class com.aliyun.odps.VolumeFSFile

Transfer Volume to VolumeFSFile

truncate() - Method in class com.aliyun.odps.Table

删除表数据

TunnelConstants - Interface in com.aliyun.odps.tunnel

TunnelConstants defined for OPDS.

TunnelDatasource - Class in com.aliyun.odps.task.copy

TunnelDatasource(Datasource.Direction, String, String, String) - Constructor for class com.aliyun.odps.task.copy.TunnelDatasource

TunnelException - Exception in com.aliyun.odps.tunnel

该异常在DataTunnel服务访问失败时抛出。

TunnelException() - Constructor for exception com.aliyun.odps.tunnel.TunnelException

构造异常对象

TunnelException(String) - Constructor for exception com.aliyun.odps.tunnel.TunnelException

构造异常对象

TunnelException(String, Throwable) - Constructor for exception com.aliyun.odps.tunnel.TunnelException

构造异常对象

TunnelException(InputStream) - Constructor for exception com.aliyun.odps.tunnel.TunnelException

构造异常对象

TYPE - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

U

UNKNOWN_REQUEST_ID - Static variable in exception com.aliyun.odps.VolumeException

unmarshal(Task.Properties) - Method in class com.aliyun.odps.XmlPropertyMapAdapter

update(Function) - Method in class com.aliyun.odps.Functions

更新 Function

update(String, Function) - Method in class com.aliyun.odps.Functions

更新 Function

update(VolumeResource) - Method in class com.aliyun.odps.Resources

更新 Volume 资源

update(String, VolumeResource) - Method in class com.aliyun.odps.Resources

更新 Volume 资源

update(TableResource) - Method in class com.aliyun.odps.Resources

更新表资源

update(String, TableResource) - Method in class com.aliyun.odps.Resources

更新表资源

update(FileResource, InputStream) - Method in class com.aliyun.odps.Resources

更新文件资源

update(String, FileResource, InputStream) - Method in class com.aliyun.odps.Resources

更新文件资源

update(Map<String, String>) - Method in class com.aliyun.odps.VolumeFSFile

updateOwner(String) - Method in class com.aliyun.odps.Function

updateOwner(String) - Method in class com.aliyun.odps.Resource

更新 资源的 owner 需要是 project owner

UPLOADID - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

UPLOADS - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

V

valueOf(String) - Static method in enum com.aliyun.odps.account.Account.AccountProvider

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.datahub.DatahubClient.ShardState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.datahub.PackType.ReadMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.Instance.StageProgress.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.Instance.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.Instance.TaskStatus.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.LogType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.Project.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.Resource.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.task.copy.Datasource.Direction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.tunnel.InstanceTunnel.DownloadStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.tunnel.StreamClient.ShardState

Deprecated.

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.tunnel.TableTunnel.DownloadStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.tunnel.TableTunnel.UploadStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.tunnel.VolumeTunnel.DownloadStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.tunnel.VolumeTunnel.UploadStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.Volume.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.VolumeFSFile.ItemType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.VolumeFSFile.ParamKey

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.aliyun.odps.account.Account.AccountProvider

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.datahub.DatahubClient.ShardState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.datahub.PackType.ReadMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.Instance.StageProgress.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.Instance.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.Instance.TaskStatus.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.LogType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.Project.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.Resource.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.task.copy.Datasource.Direction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.tunnel.InstanceTunnel.DownloadStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.tunnel.StreamClient.ShardState

Deprecated.

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.tunnel.TableTunnel.DownloadStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.tunnel.TableTunnel.UploadStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.tunnel.VolumeTunnel.DownloadStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.tunnel.VolumeTunnel.UploadStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.Volume.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.VolumeFSFile.ItemType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.VolumeFSFile.ParamKey

Returns an array containing the constants of this enum type, in the order they are declared.

VERSION - Static variable in interface com.aliyun.odps.datahub.DatahubConstants

VERSION - Static variable in interface com.aliyun.odps.tunnel.TunnelConstants

Volume - Class in com.aliyun.odps

Volume表示ODPS中的volume 暂未开放，仅限内部使用

Volume.Type - Enum in com.aliyun.odps

VolumeArchiveResource - Class in com.aliyun.odps

Created by nizheming on 15/8/12.

VolumeArchiveResource() - Constructor for class com.aliyun.odps.VolumeArchiveResource

VolumeException - Exception in com.aliyun.odps

Volume Exception

VolumeException(Throwable) - Constructor for exception com.aliyun.odps.VolumeException

VolumeException(String, Throwable) - Constructor for exception com.aliyun.odps.VolumeException

VolumeException(String, String) - Constructor for exception com.aliyun.odps.VolumeException

VolumeException(String) - Constructor for exception com.aliyun.odps.VolumeException

VolumeFile - Class in com.aliyun.odps

VolumeFile表示ODPS中的volume file 暂未开放，仅限内部使用

VolumeFileResource - Class in com.aliyun.odps

Created by nizheming on 15/8/3.

VolumeFileResource() - Constructor for class com.aliyun.odps.VolumeFileResource

VolumeFilter - Class in com.aliyun.odps

VolumeFilter用于查询所有Volume或partition时根据条件过滤Volume或partition 暂未开放，仅限内部使用

VolumeFilter() - Constructor for class com.aliyun.odps.VolumeFilter

VolumeFSErrorCode - Class in com.aliyun.odps.tunnel

Volume Filesystem Error Code

VolumeFSErrorCode() - Constructor for class com.aliyun.odps.tunnel.VolumeFSErrorCode

VolumeFSFile - Class in com.aliyun.odps

Volume File System File

VolumeFSFile.ItemType - Enum in com.aliyun.odps

VolumeFSFile.ParamKey - Enum in com.aliyun.odps

VolumeFSTunnel - Class in com.aliyun.odps.tunnel

Volume FileSystem Tunnel

VolumeFSTunnel(Odps) - Constructor for class com.aliyun.odps.tunnel.VolumeFSTunnel

VolumeMissing - Static variable in class com.aliyun.odps.tunnel.VolumeFSErrorCode

VolumePartition - Class in com.aliyun.odps

VolumePartition表示ODPS中的volume partition 暂未开放，仅限内部使用

VolumeResource - Class in com.aliyun.odps

Created by nizheming on 15/8/3.

VolumeResource() - Constructor for class com.aliyun.odps.VolumeResource

volumes() - Method in class com.aliyun.odps.Odps

获取表示ODPS所有Volumes的集合对象

Volumes - Class in com.aliyun.odps

Volumes表示ODPS中所有Volume的集合 暂未开放，仅限内部使用

VolumeTunnel - Class in com.aliyun.odps.tunnel

访问ODPS Volume Tunnel服务的入口类 暂未开放，仅限内部使用

VolumeTunnel(Odps) - Constructor for class com.aliyun.odps.tunnel.VolumeTunnel

构造此类对象

VolumeTunnel.DownloadSession - Class in com.aliyun.odps.tunnel

此类表示一个向ODPS中下载Volume的会话

VolumeTunnel.DownloadSession(String, String, String, String) - Constructor for class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

构造一个新的VolumeTunnel.DownloadSession。

VolumeTunnel.DownloadSession(String, String, String, String, String) - Constructor for class com.aliyun.odps.tunnel.VolumeTunnel.DownloadSession

根据已有downloadId构造一个VolumeTunnel.DownloadSession对象。

VolumeTunnel.DownloadStatus - Enum in com.aliyun.odps.tunnel

下载会话的状态
UNKNOWN 未知
NORMAL 正常
CLOSED 关闭
EXPIRED 过期

VolumeTunnel.UploadSession - Class in com.aliyun.odps.tunnel

UploadSession表示一个向ODPS表中上传数据的会话

VolumeTunnel.UploadSession(String, String, String) - Constructor for class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

构造一个新的VolumeTunnel.UploadSession对象。

VolumeTunnel.UploadSession(String, String, String, String) - Constructor for class com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

根据已有的uploadId构造一个VolumeTunnel.UploadSession对象。

VolumeTunnel.UploadStatus - Enum in com.aliyun.odps.tunnel

UploadStatus表示当前Upload的状态
UNKNOWN 未知
NORMAL 正常
CLOSING 关闭中
CLOSED 已关闭
CANCELED 已取消
EXPIRED 已过期
CRITICAL 严重错误

W

waitForShardLoad() - Method in class com.aliyun.odps.datahub.DatahubClient

同步等待 load shard 完成 默认超时时间为 120000ms

waitForShardLoad(long) - Method in class com.aliyun.odps.datahub.DatahubClient

同步等待 load shard 完成 最大超时时间为 120000ms

waitForShardLoad() - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

同步等待 load shard 完成 默认超时时间为 60s

waitForShardLoad(long) - Method in class com.aliyun.odps.tunnel.StreamClient

Deprecated.

同步等待 load shard 完成 最大超时时间为 60000ms

waitForSuccess() - Method in class com.aliyun.odps.Instance

阻塞当前线程, 直到Instance结束

waitForSuccess(long) - Method in class com.aliyun.odps.Instance

阻塞当前线程, 直到Instance结束

write(Record) - Method in interface com.aliyun.odps.data.RecordWriter

写入一条记录

write(DatahubRecordPack) - Method in class com.aliyun.odps.datahub.DatahubWriter

向ODPS hub服务的非分区表写入一个pack

write(DatahubRecordPack, byte[]) - Method in class com.aliyun.odps.datahub.DatahubWriter

向ODPS hub服务的非分区表写入一个pack

write(DatahubRecordPack, Map<String, String>) - Method in class com.aliyun.odps.datahub.DatahubWriter

向ODPS hub服务的非分区表写入一个pack

write(PartitionSpec, DatahubRecordPack, Map<String, String>) - Method in class com.aliyun.odps.datahub.DatahubWriter

向ODPS hub服务的非分区表写入一个pack

write(PartitionSpec, DatahubRecordPack) - Method in class com.aliyun.odps.datahub.DatahubWriter

向ODPS hub服务的分区表写入一个pack

write(DatahubRecordPack) - Method in class com.aliyun.odps.tunnel.StreamUploadWriter

向ODPS非分区表写入数据,第一次写入会自动load shard

write(PartitionSpec, DatahubRecordPack) - Method in class com.aliyun.odps.tunnel.StreamUploadWriter

向ODPS分区表写入数据,第一次写入会自动load shard

writeBlock(long, RecordPack) - Method in class com.aliyun.odps.tunnel.TableTunnel.UploadSession

打开http链接，写入pack数据，然后关闭链接，多次向同一个block写入时会覆盖之前数据

WritePackResult - Class in com.aliyun.odps.datahub

WritePackResult(String) - Constructor for class com.aliyun.odps.datahub.WritePackResult

X

XLibTask - Class in com.aliyun.odps.task

XDebug 开发时，提交计算任务用

XLibTask(String) - Constructor for class com.aliyun.odps.task.XLibTask

使用给定任务名构造一个XDebugTask实例。

XLibTask(String, String, String) - Constructor for class com.aliyun.odps.task.XLibTask

使用给定任务名和命令构造一个XDebugTask实例。

XmlPropertyMapAdapter - Class in com.aliyun.odps

XmlPropertyMapAdapter() - Constructor for class com.aliyun.odps.XmlPropertyMapAdapter

A B C D E F G H I J L M N O P Q R S T U V W X