com.aliyun.odps.io

接口 OutputBlobWritable

所有超级接口:

Comparable, Writable, WritableComparable

public interface OutputBlobWritable
extends WritableComparable

OutputBlobWritable表示ODPS表或分区中列类型为blob的输出接口, 该接口只能用于 com.aliyun.odps.mapreduce.Reducer向 com.aliyun.odps.Record 中写入blob类型的列.

用法示例：

 @Override
 public void reduce(KEYIN key, Iterable<VALUEIN> values,
     MapContext<KEYIN, VALUEIN> context) throws IOException {
   Record outputRecord = context.createOutputRecord();
   OutputBlobWritable blob = outputRecord.get(0);
   BufferedOutputStream out = blob.getOutputStream();
   // 使用out.write向blob中写入数据
   out.close();
 }
 

从上面的示例看出, 从com.aliyun.odps.Record获得OutputBlobWritable接口, 调用OutputBlobWritable的 getOutputStream获得BufferedOutputStream后，即可进行写入数据.

方法概要

方法

限定符和类型	方法和说明
BufferedOutputStream	getOutputStream() getOutputStream方法获取可以写入blob的BufferedOutputStream接口

从接口继承的方法 com.aliyun.odps.io.Writable

readFields, write

从接口继承的方法 java.lang.Comparable

compareTo

方法详细资料

getOutputStream

BufferedOutputStream getOutputStream()
                                     throws IOException

getOutputStream方法获取可以写入blob的BufferedOutputStream接口

返回:

blob列对应的BufferedOutputStream

抛出:

IOException