com.aliyun.odps.tunnel

类 UploadSession

java.lang.Object

com.aliyun.odps.tunnel.UploadSession

已过时。

@Deprecated
public class UploadSession
extends Object

UploadSession表示一个向ODPS表中上传数据的会话

向ODPS表上传数据的流程如下:
1) 创建UploadSession
2) 上传Block
3) 提交

可以使用 TableTunnel.UploadSession 替代

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	UploadSession.Status 已过时。 Status表示当前Upload的状态 UNKNOWN 未知 NORMAL 正常 CLOSING 关闭中 CLOSED 已关闭 CANCELED 已取消 EXPIRED 已过期 CRITICAL 严重错误

方法概要

方法

限定符和类型	方法和说明
void	commit(Long[] blocks) 已过时。 提交本次上传的所有数据块 blcoks表示用户记录的已经成功上传的数据块列表，用来与服务器端做完整性校验
Long[]	getBlockList() 已过时。 获取当前会话已经上传成功的数据块列表
String	getId() 已过时。 获取会话ID
TableSchema	getSchema() 已过时。 获取表结构
UploadSession.Status	getStatus() 已过时。 获取会话状态
Record	newRecord() 已过时。 创建临时Record对象 创建一个临时的Record对象, 用于后续上传数据
RecordWriter	openRecordWriter(long blockId) 已过时。 打开RecordWriter用来写入数据 BlockId是由用户选取的0~19999之间的数值，标识本次上传数据块
RecordWriter	openRecordWriter(long blockId, boolean compress) 已过时。 打开RecordWriter用来写入数据

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

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

方法详细资料

openRecordWriter

public RecordWriter openRecordWriter(long blockId)
                              throws TunnelException,
                                     IOException

已过时。

打开RecordWriter用来写入数据

BlockId是由用户选取的0~19999之间的数值，标识本次上传数据块

参数:

blockId - 块标识

抛出:

TunnelException

IOException

openRecordWriter

public RecordWriter openRecordWriter(long blockId,
                            boolean compress)
                              throws TunnelException,
                                     IOException

已过时。

打开RecordWriter用来写入数据

参数:

blockId - 块标识

compress - 数据传输是否进行压缩

抛出:

TunnelException

IOException

commit

public void commit(Long[] blocks)
            throws TunnelException,
                   IOException

已过时。

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

blcoks表示用户记录的已经成功上传的数据块列表，用来与服务器端做完整性校验

参数:

blocks - 用户预期已经上传成功的数据块列表

抛出:

TunnelException - 如果提供的Block列表与Server端存在的Block不一致抛出异常

IOException

getId

public String getId()

已过时。

获取会话ID

getSchema

public TableSchema getSchema()

已过时。

获取表结构

返回:

TableSchema

getStatus

public UploadSession.Status getStatus()
                               throws TunnelException,
                                      IOException

已过时。

获取会话状态

返回:

UploadSession.Status

抛出:

TunnelException

IOException

newRecord

public Record newRecord()

已过时。

创建临时Record对象

创建一个临时的Record对象, 用于后续上传数据

返回:

Record

getBlockList

public Long[] getBlockList()
                    throws TunnelException,
                           IOException

已过时。

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

抛出:

TunnelException

IOException