com.aliyun.odps.data

Class DefaultRecordReader

java.lang.Object

com.aliyun.odps.data.DefaultRecordReader

All Implemented Interfaces:

RecordReader, Closeable, AutoCloseable

public class DefaultRecordReader
extends Object
implements RecordReader

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

Constructor Summary

Constructors

Constructor and Description
DefaultRecordReader(InputStream is, TableSchema tableSchema) 构造一个 DefaultRecordReader

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
InputStream	getRawStream()
Column[]	getSchema()
Record	read() 读取一条记录
List<String>	readRaw()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRecordReader

public DefaultRecordReader(InputStream is,
                   TableSchema tableSchema)

构造一个 DefaultRecordReader

Parameters:

is - 输入流

tableSchema - TableSchema

Method Detail

getRawStream

public InputStream getRawStream()

getSchema

public Column[] getSchema()
                   throws IOException

Throws:

IOException

read

public Record read()
            throws IOException

读取一条记录

Specified by:

read in interface RecordReader

Returns:

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

Throws:

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

readRaw

public List<String> readRaw()
                     throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable