com.aliyun.odps.tunnel

类 VolumeTunnel.UploadSession

java.lang.Object

com.aliyun.odps.tunnel.VolumeTunnel.UploadSession

封闭类:

VolumeTunnel

public class VolumeTunnel.UploadSession
extends Object

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

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

构造器概要

构造器

构造器和说明
VolumeTunnel.UploadSession(String projectName, String volumeName, String partitionSpec) 构造一个新的UploadSession对象。
VolumeTunnel.UploadSession(String projectName, String volumeName, String partitionSpec, String uploadId) 根据已有的uploadId构造一个UploadSession对象。

方法概要

方法

限定符和类型	方法和说明
void	commit(String[] files) 提交本次上传的所有file
Long	getFileLength(String fileName)
String[]	getFileList() 获取当前UploadSession已成功上传的files
String	getId() 获取当前UploadSession的唯一标识符
VolumeTunnel.UploadStatus	getStatus() 获取当前UploadSession的Status
OutputStream	openOutputStream(String fileName) 创建OutputStream用来将数据流入到指定File。
OutputStream	openOutputStream(String fileName, boolean compress) 创建OutputStream用来将数据流入到指定File。
OutputStream	openOutputStream(String fileName, boolean compress, boolean append) 创建OutputStream用来将数据流入到指定File。

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

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

构造器详细资料

VolumeTunnel.UploadSession

public VolumeTunnel.UploadSession(String projectName,
                          String volumeName,
                          String partitionSpec)
                           throws TunnelException

构造一个新的UploadSession对象。

参数:

projectName - 上传File所在的project名称。

volumeName - 上传File所在Volume名称。

partitionSpec - 上传File的partition描述，格式如下: pt=xxx,dt=xxx。

抛出:

TunnelException

VolumeTunnel.UploadSession

public VolumeTunnel.UploadSession(String projectName,
                          String volumeName,
                          String partitionSpec,
                          String uploadId)
                           throws TunnelException

根据已有的uploadId构造一个UploadSession对象。

参数:

projectName - 上传File所在的project名称。

volumeName - 上传File所在Volume名称。

partitionSpec - 上传File的partition描述，格式如下: pt=xxx,dt=xxx。

uploadId - UploadSession的唯一标识符

抛出:

TunnelException

方法详细资料

openOutputStream

public OutputStream openOutputStream(String fileName)
                              throws TunnelException,
                                     IOException

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

参数:

fileName - 指定File的名称。

抛出:

TunnelException

IOException

openOutputStream

public OutputStream openOutputStream(String fileName,
                            boolean compress)
                              throws TunnelException,
                                     IOException

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

参数:

fileName - 指定File的名称。

compress - 设置压缩参数对传输数据进行压缩

抛出:

TunnelException

IOException

openOutputStream

public OutputStream openOutputStream(String fileName,
                            boolean compress,
                            boolean append)
                              throws TunnelException,
                                     IOException

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

参数:

fileName - 指定File的名称。

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

append - 是否采用断点续传

抛出:

TunnelException

IOException

commit

public void commit(String[] files)
            throws TunnelException,
                   IOException

提交本次上传的所有file

参数:

files - 已经成功上传的Files列表

抛出:

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

IOException

getId

public String getId()

获取当前UploadSession的唯一标识符

getStatus

public VolumeTunnel.UploadStatus getStatus()
                                    throws TunnelException

获取当前UploadSession的Status

抛出:

TunnelException

getFileList

public String[] getFileList()
                     throws TunnelException,
                            IOException

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

抛出:

TunnelException

IOException

getFileLength

public Long getFileLength(String fileName)
                   throws TunnelException,
                          IOException

抛出:

TunnelException

IOException