com.aliyun.odps.data

类 DefaultRecordReader

java.lang.Object

com.aliyun.odps.data.DefaultRecordReader

所有已实现的接口:

RecordReader, Closeable, AutoCloseable

public class DefaultRecordReader
extends Object
implements RecordReader

默认 RecordReader 的实现，用于读取 Record

构造器概要

构造器

构造器和说明
DefaultRecordReader(InputStream is, TableSchema tableSchema) 构造一个 DefaultRecordReader

方法概要

方法

限定符和类型	方法和说明
void	close()
InputStream	getRawStream()
Column[]	getSchema()
Record	read() 读取一条记录
List<String>	readRaw()

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

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

构造器详细资料

DefaultRecordReader

public DefaultRecordReader(InputStream is,
                   TableSchema tableSchema)

构造一个 DefaultRecordReader

参数:

is - 输入流

tableSchema - TableSchema

方法详细资料

getRawStream

public InputStream getRawStream()

getSchema

public Column[] getSchema()
                   throws IOException

抛出:

IOException

read

public Record read()
            throws IOException

读取一条记录

指定者:

read 在接口中 RecordReader

返回:

成功读到记录返回Record对象, 读取完成返回null

抛出:

IOException - 读取过程发生异常, 发生异常后不可重试

readRaw

public List<String> readRaw()
                     throws IOException

抛出:

IOException

close

public void close()

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable