com.aliyun.odps.datahub

类 DatahubReader

java.lang.Object

com.aliyun.odps.datahub.DatahubReader

public class DatahubReader
extends Object

构造器概要

构造器

构造器和说明
DatahubReader(com.aliyun.odps.rest.RestClient datahubServiceClient, TableSchema tableSchema, String path, Map<String,String> params, Map<String,String> headers)
DatahubReader(com.aliyun.odps.rest.RestClient datahubServiceClient, TableSchema tableSchema, String path, Map<String,String> params, Map<String,String> headers, String packId)

方法概要

限定符和类型	方法和说明
String	getLastPackId() 获取当前从服务端读取的pack的packId
Record	read() 从指定的shard读取一条记录
byte[]	readMeta()
SeekPackResult	seek(long timeStamp)
void	skipPack() 跳过某条Record不进行数据读取

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

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

构造器详细资料

DatahubReader

public DatahubReader(com.aliyun.odps.rest.RestClient datahubServiceClient,
                     TableSchema tableSchema,
                     String path,
                     Map<String,String> params,
                     Map<String,String> headers)

DatahubReader

public DatahubReader(com.aliyun.odps.rest.RestClient datahubServiceClient,
                     TableSchema tableSchema,
                     String path,
                     Map<String,String> params,
                     Map<String,String> headers,
                     String packId)

方法详细资料

read

public Record read()
            throws OdpsException,
                   IOException

从指定的shard读取一条记录

返回:

Record

抛出:

OdpsException, - IOException

OdpsException

IOException

skipPack

public void skipPack()

跳过某条Record不进行数据读取

getLastPackId

public String getLastPackId()

获取当前从服务端读取的pack的packId

返回:

String PackId

seek

public SeekPackResult seek(long timeStamp)
                    throws OdpsException,
                           IOException

抛出:

OdpsException

IOException

readMeta

public byte[] readMeta()
                throws OdpsException,
                       IOException

抛出:

OdpsException

IOException