com.aliyun.odps.io

类 DataInputBuffer

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

java.io.DataInputStream

com.aliyun.odps.io.DataInputBuffer

所有已实现的接口:

Closeable, DataInput, AutoCloseable

public class DataInputBuffer
extends DataInputStream

DataInputBuffer 提供一个可复用的 DataInput 实现.

DataInputBuffer 继承自 DataInputStream ，提供了 DataInput 的实现，可以方便的将内存数据作为输入，并提供 reset 系列方法支持对象复用。

代码示例：

 DataInputBuffer buffer = new DataInputBuffer();
 while (... loop condition ...) {
   byte[] data = ... get data ...;
   int dataLength = ... get data length ...;
   buffer.reset(data, dataLength); //重用 buffer，无需再new 对象
   ... read buffer using DataInput methods ...
 }
 

另请参阅:

Writable.readFields(DataInput), DataOutputBuffer

构造器概要

构造器

构造器和说明
DataInputBuffer() 构建一个空 DataInputBuffer

方法概要

方法

限定符和类型	方法和说明
byte[]	getData() 获取当前数据内容的字节数组
int	getLength() 获取数据输入的内容长度
int	getPosition() 获取数据输入流的当前位置
void	reset(byte[] input, int length) 重置内存数据输入.
void	reset(byte[] input, int start, int length) 重置内存数据输入.

从类继承的方法 java.io.DataInputStream

read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes

从类继承的方法 java.io.FilterInputStream

available, close, mark, markSupported, read, reset, skip

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

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

构造器详细资料

DataInputBuffer

public DataInputBuffer()

构建一个空 DataInputBuffer

方法详细资料

reset

public void reset(byte[] input,
         int length)

重置内存数据输入.

将 input[0,...,length-1] 作为数据输入

参数:

input - 字节数组

length - 数据内容长度

reset

public void reset(byte[] input,
         int start,
         int length)

重置内存数据输入.

将 input[start,...,start+length-1] 作为数据输入

参数:

input - 字节数组

start - 数据起始位置

length - 数据内容长度

getData

public byte[] getData()

获取当前数据内容的字节数组

返回:

当前数据内容的字节数组

getPosition

public int getPosition()

获取数据输入流的当前位置

返回:

数据输入流的当前位置

getLength

public int getLength()

获取数据输入的内容长度

返回:

数据输入的内容长度