com.aliyun.odps.datahub

类 DatahubWriter

java.lang.Object

com.aliyun.odps.datahub.DatahubWriter

public class DatahubWriter
extends Object

构造器概要

构造器

构造器和说明
DatahubWriter(com.aliyun.odps.rest.RestClient datahubServiceClient, String path, HashMap<String,String> params, Map<String,String> headers)

方法概要

限定符和类型	方法和说明
WritePackResult	write(DatahubRecordPack recordPack) 向ODPS hub服务的非分区表写入一个pack
WritePackResult	write(DatahubRecordPack recordPack, byte[] meta) 向ODPS hub服务的非分区表写入一个pack
WritePackResult	write(PartitionSpec partitionSpec, DatahubRecordPack recordPack) 向ODPS hub服务的分区表写入一个pack
WritePackResult	write(PartitionSpec partitionSpec, DatahubRecordPack recordPack, byte[] meta) 向ODPS hub服务的分区表写入一个pack

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

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

构造器详细资料

DatahubWriter

public DatahubWriter(com.aliyun.odps.rest.RestClient datahubServiceClient,
                     String path,
                     HashMap<String,String> params,
                     Map<String,String> headers)

方法详细资料

write

public WritePackResult write(DatahubRecordPack recordPack)
                      throws OdpsException,
                             IOException

向ODPS hub服务的非分区表写入一个pack

参数:

recordPack - DatahubRecordPack 对象

返回:

WritePackResult

抛出:

OdpsException, - IOexception

OdpsException

IOException

write

public WritePackResult write(DatahubRecordPack recordPack,
                             byte[] meta)
                      throws OdpsException,
                             IOException

向ODPS hub服务的非分区表写入一个pack

参数:

recordPack - DatahubRecordPack 对象

meta - pack 属性

返回:

WritePackResult

抛出:

OdpsException, - IOexception

OdpsException

IOException

write

public WritePackResult write(PartitionSpec partitionSpec,
                             DatahubRecordPack recordPack)
                      throws OdpsException,
                             IOException

向ODPS hub服务的分区表写入一个pack

参数:

partitionSpec - PartitionSpec 对象

recordPack - DatahubRecordPack 对象

返回:

WritePackResult

抛出:

OdpsException, - IOexception

OdpsException

IOException

write

public WritePackResult write(PartitionSpec partitionSpec,
                             DatahubRecordPack recordPack,
                             byte[] meta)
                      throws OdpsException,
                             IOException

向ODPS hub服务的分区表写入一个pack

参数:

partitionSpec - PartitionSpec 对象

recordPack - DatahubRecordPack 对象

meta - pack 属性

返回:

WritePackResult

抛出:

OdpsException, - IOexception

OdpsException

IOException