com.aliyun.odps.datahub

Class DatahubWriter

java.lang.Object

com.aliyun.odps.datahub.DatahubWriter

public class DatahubWriter
extends Object

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
WritePackResult	write(DatahubRecordPack recordPack) 向ODPS hub服务的非分区表写入一个pack
WritePackResult	write(DatahubRecordPack recordPack, byte[] meta) 向ODPS hub服务的非分区表写入一个pack
WritePackResult	write(DatahubRecordPack recordPack, Map<String,String> meta) 向ODPS hub服务的非分区表写入一个pack
WritePackResult	write(PartitionSpec partitionSpec, DatahubRecordPack recordPack) 向ODPS hub服务的分区表写入一个pack
WritePackResult	write(PartitionSpec partitionSpec, DatahubRecordPack recordPack, Map<String,String> meta) 向ODPS hub服务的非分区表写入一个pack

Methods inherited from class java.lang.Object

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

Constructor Detail

DatahubWriter

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

Method Detail

write

public WritePackResult write(DatahubRecordPack recordPack)
                      throws OdpsException,
                             IOException

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

Parameters:

recordPack - DatahubRecordPack 对象

Returns:

WritePackResult

Throws:

OdpsException, - IOexception

OdpsException

IOException

write

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

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

Parameters:

recordPack - DatahubRecordPack 对象

meta - pack 属性

Returns:

WritePackResult

Throws:

OdpsException, - IOexception

OdpsException

IOException

write

public WritePackResult write(DatahubRecordPack recordPack,
                    Map<String,String> meta)
                      throws OdpsException,
                             IOException

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

Parameters:

recordPack - DatahubRecordPack 对象

meta - pack 属性

Returns:

WritePackResult

Throws:

OdpsException, - IOexception

OdpsException

IOException

write

public WritePackResult write(PartitionSpec partitionSpec,
                    DatahubRecordPack recordPack,
                    Map<String,String> meta)
                      throws OdpsException,
                             IOException

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

Parameters:

partitionSpec - PartitionSpec 对象

recordPack - DatahubRecordPack 对象

meta - pack 属性

Returns:

WritePackResult

Throws:

OdpsException, - IOexception

OdpsException

IOException

write

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

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

Parameters:

partitionSpec - PartitionSpec 对象

recordPack - DatahubRecordPack 对象

Returns:

WritePackResult

Throws:

OdpsException, - IOexception

OdpsException

IOException