com.aliyun.odps.datahub

Class DatahubRecordPack

java.lang.Object

com.aliyun.odps.datahub.DatahubRecordPack

public class DatahubRecordPack
extends Object

Constructor Summary

Constructors

Constructor and Description
DatahubRecordPack(TableSchema recordSchema) 新建一个DatahubRecordPack

Method Summary

Methods

Modifier and Type	Method and Description
void	append(Record r) 向DatahubRecordPack中append一条Record。
void	clear() 清空DatahubRecordPack
byte[]	getByteArray()
long	getRecordCount()

Methods inherited from class java.lang.Object

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

Constructor Detail

DatahubRecordPack

public DatahubRecordPack(TableSchema recordSchema)
                  throws IOException

新建一个DatahubRecordPack

Parameters:

recordSchema -

Throws:

IOException

Method Detail

append

public void append(Record r)
            throws IOException

向DatahubRecordPack中append一条Record。

Parameters:

r -

Throws:

IOException - 产生异常表示需要通过DatahubWriter将DatahubRecordPack中的数据发送到datahub

clear

public void clear()

清空DatahubRecordPack

getByteArray

public byte[] getByteArray()
                    throws IOException

Throws:

IOException

getRecordCount

public long getRecordCount()