com.aliyun.odps.datahub

类 DatahubRecordPack

java.lang.Object

com.aliyun.odps.datahub.DatahubRecordPack

public class DatahubRecordPack
extends Object

构造器概要

构造器

构造器和说明
DatahubRecordPack(TableSchema recordSchema) 新建一个DatahubRecordPack

方法概要

限定符和类型	方法和说明
boolean	append(Record r) 向DatahubRecordPack中append一条Record。
void	clear() 清空DatahubRecordPack
byte[]	getByteArray()
long	getRecordCount()

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

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

构造器详细资料

DatahubRecordPack

public DatahubRecordPack(TableSchema recordSchema)
                  throws IOException

新建一个DatahubRecordPack

参数:

recordSchema -

抛出:

IOException

方法详细资料

append

public boolean append(Record r)
               throws IOException

向DatahubRecordPack中append一条Record。插入成功返回true, 否则返回false,代表需要通过StreamWriter将DatahubRecordPack中的数据发送到tunnel

参数:

r -

抛出:

IOException

clear

public void clear()

清空DatahubRecordPack

getByteArray

public byte[] getByteArray()
                    throws IOException

抛出:

IOException

getRecordCount

public long getRecordCount()