接口 com.aliyun.odps.data.RecordReader
的使用

使用RecordReader的程序包

程序包	说明
com.aliyun.odps	提供操作ODPS基本资源的类 ODPS基本资源包括: Table, Resource, Function等 Examples: Account account = new AliyunAccount("accessId", "accessKey"); Odps odps = new Odps(account); odps.setDefaultProject("my_project"); for (Table t : odps.tables()) { System.out.print(t.getName() + "\t" + t.getOwner()); }
com.aliyun.odps.data	提供表示ODPS中记录的数据结构定义
com.aliyun.odps.tunnel	ODPS Tunnel服务用于上传、下载数据到ODPS Examples: Account account = new AliyunAccount("accessId", "accessKey"); Odps odps = new Odps(account); odps.setDefaultProject("my_project"); DataTunnel tunnel = new DataTunnel(odps); UploadSession session = tunnel.createUploadSession("my_project", "my_table"); ....

com.aliyun.odps中RecordReader的使用

返回RecordReader的com.aliyun.odps中的方法

限定符和类型	方法和说明
RecordReader	Table.read(int limit) 读取表内的数据
RecordReader	Table.read(PartitionSpec partition, List<String> columns, int limit) 读取表内的数据 读取数据时，最多返回 1W 条记录，若超过，数据将被截断。

com.aliyun.odps.data中RecordReader的使用

实现RecordReader的com.aliyun.odps.data中的类

限定符和类型	类和说明
class	DefaultRecordReader 默认 RecordReader 的实现，用于读取 Record

返回RecordReader的com.aliyun.odps.data中的方法

限定符和类型	方法和说明
abstract RecordReader	RecordPack.getRecordReader() 返回一个RecordReader，里面包含了所有的记录

com.aliyun.odps.tunnel中RecordReader的使用

返回RecordReader的com.aliyun.odps.tunnel中的方法

限定符和类型	方法和说明
RecordReader	TableTunnel.DownloadSession.openRecordReader(long start, long count) 打开RecordReader用来读取记录
RecordReader	DownloadSession.openRecordReader(long start, long count) 已过时。 打开RecordReader用来读取记录
RecordReader	TableTunnel.DownloadSession.openRecordReader(long start, long count, boolean compress) 打开RecordReader用来读取记录
RecordReader	DownloadSession.openRecordReader(long start, long count, boolean compress) 已过时。 打开RecordReader用来读取记录
RecordReader	TableTunnel.DownloadSession.openRecordReader(long start, long count, boolean compress, List<Column> columns) 打开RecordReader用来读取记录
RecordReader	TableTunnel.DownloadSession.openRecordReader(long start, long count, com.aliyun.odps.tunnel.io.CompressOption compress) 打开RecordReader用来读取记录
RecordReader	TableTunnel.DownloadSession.openRecordReader(long start, long count, com.aliyun.odps.tunnel.io.CompressOption compress, List<Column> columns) 打开RecordReader用来读取记录