@Deprecated public class DownloadSession extends Object
向ODPS表上传数据的流程如下:
1) 创建DownloadSession
2) 下载数据
TableTunnel.DownloadSession 替代| 限定符和类型 | 类和说明 |
|---|---|
static class |
DownloadSession.Status
已过时。
下载会话的状态
UNKNOWN 未知 NORMAL 正常 CLOSED 关闭 EXPIRED 过期 |
| 限定符和类型 | 方法和说明 |
|---|---|
String |
getId()
已过时。
获取会话ID
|
long |
getRecordCount()
已过时。
获取可下载的记录总数
|
TableSchema |
getSchema()
已过时。
获取数据对应的表结构
|
DownloadSession.Status |
getStatus()
已过时。
获取会话状态
|
RecordReader |
openRecordReader(long start,
long count)
已过时。
打开
RecordReader用来读取记录 |
RecordReader |
openRecordReader(long start,
long count,
boolean compress)
已过时。
打开
RecordReader用来读取记录 |
public RecordReader openRecordReader(long start, long count) throws TunnelException, IOException
RecordReader用来读取记录start - 本次要读取记录的起始位置count - 本次要读取记录的数量TunnelExceptionIOExceptionpublic RecordReader openRecordReader(long start, long count, boolean compress) throws TunnelException, IOException
RecordReader用来读取记录start - 本次要读取记录的起始位置count - 本次要读取记录的数量compress - 数据传输是否进行压缩;即使设置了压缩选项,如果server 不支持压缩,传输数据也不会被压缩TunnelExceptionIOExceptionpublic TableSchema getSchema()
TableSchemapublic long getRecordCount()
public String getId()
public DownloadSession.Status getStatus() throws TunnelException, IOException
Copyright © 2015 Alibaba Cloud Computing. All rights reserved.