edu.sysu.pmglab.ccf

类 CCFWriter

java.lang.Object

edu.sysu.pmglab.ccf.CCFWriter

所有已实现的接口:

java.io.Closeable, java.lang.AutoCloseable

public class CCFWriter
extends java.lang.Object
implements java.lang.AutoCloseable, java.io.Closeable

CCF 文件写入器

另请参阅:

列字段格式声明

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	CCFWriter.Builder CCFWriter 构造器

方法概要

限定符和类型	方法和说明
void	close() 关闭文件流
void	flush() 刷新缓冲区 (将当前的缓冲数据写入一个新的块)
edu.sysu.pmglab.container.IndexableSet<java.lang.String>	getFieldNames() 获取当前列名
int	getFieldNum() 获取当前数据表包含的列数
FieldType	getFieldType(java.lang.String fieldName) 获取指定列名的数据类型
java.util.Map<java.lang.String,FieldType>	getFieldTypes() 获取当前列名及其数据类型
edu.sysu.pmglab.container.File	getOutputFile() 获取输出文件
IRecord	getRecord() 获取当前读取器绑定的记录类型
long	getRecordNum() 获取当前已写入的记录条目数
void	write(IRecord record) 写入一条数据记录
void	write(java.lang.Iterable<IRecord> records) 写入多条数据记录
CCFWriter	writeMeta(edu.sysu.pmglab.container.ByteCode key, edu.sysu.pmglab.container.ByteCode value) 写入一条 meta 注释
CCFWriter	writeMeta(CCFMeta meta) 写入 meta 注释
CCFWriter	writeMeta(java.lang.String key, java.lang.String value) 写入一条 meta 注释

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

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

方法详细资料

getRecord

public IRecord getRecord()

获取当前读取器绑定的记录类型

返回:

当前读取器绑定的记录类型

write

public void write(IRecord record)
           throws java.io.IOException

写入一条数据记录

参数:

record - Record (只读) 类型的数据记录

抛出:

java.io.IOException - 文件读取过程中产生的 IO 异常 (包括占用、指针异常、不存在等)

BrokenChunkedColumnarFormatException - 当任何一列包含的块数过多, 抛出文件异常

InvalidRecordException - 当记录的任意字段值为 null 或格式类型不匹配时, 抛出非法记录异常

write

public void write(java.lang.Iterable<IRecord> records)
           throws java.io.IOException

写入多条数据记录

参数:

records - Record (只读) 类型的数据记录

抛出:

java.io.IOException - 文件读取过程中产生的 IO 异常 (包括占用、指针异常、不存在等)

BrokenChunkedColumnarFormatException - 当任何一列包含的块数过多, 抛出文件异常

InvalidRecordException - 当记录的任意字段值为 null 或格式类型不匹配时, 抛出非法记录异常

writeMeta

public CCFWriter writeMeta(java.lang.String key,
                           java.lang.String value)

写入一条 meta 注释

参数:

key - 注释键

value - 注释值

返回:

本类

writeMeta

public CCFWriter writeMeta(edu.sysu.pmglab.container.ByteCode key,
                           edu.sysu.pmglab.container.ByteCode value)

写入一条 meta 注释

参数:

key - 注释键

value - 注释值

返回:

本类

writeMeta

public CCFWriter writeMeta(CCFMeta meta)

写入 meta 注释

参数:

meta - 注释键

返回:

本类

getOutputFile

public edu.sysu.pmglab.container.File getOutputFile()

获取输出文件

返回:

输出文件

flush

public void flush()
           throws java.io.IOException

刷新缓冲区 (将当前的缓冲数据写入一个新的块)

抛出:

java.io.IOException - 文件读取过程中产生的 IO 异常 (包括占用、指针异常、不存在等)

getRecordNum

public long getRecordNum()

获取当前已写入的记录条目数

返回:

当前已写入的记录条目数

getFieldNum

public int getFieldNum()

获取当前数据表包含的列数

返回:

当前数据表包含的列数

getFieldTypes

public java.util.Map<java.lang.String,FieldType> getFieldTypes()

获取当前列名及其数据类型

返回:

当前数据表包含的列名及其数据类型

getFieldNames

public edu.sysu.pmglab.container.IndexableSet<java.lang.String> getFieldNames()

获取当前列名

返回:

当前数据表包含的列名

getFieldType

public FieldType getFieldType(java.lang.String fieldName)

获取指定列名的数据类型

参数:

fieldName - 指定的列名

返回:

指定列名的数据类型, null 代表不存在该列

close

public void close()
           throws java.io.IOException

关闭文件流

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

抛出:

java.io.IOException