org.apache.hadoop.record

类 CsvRecordInput

java.lang.Object

org.apache.hadoop.record.CsvRecordInput

所有已实现的接口:

RecordInput

public class CsvRecordInput
extends Object
implements RecordInput

构造器概要

构造器

构造器和说明
CsvRecordInput(InputStream in) Creates a new instance of CsvRecordInput

方法概要

方法

限定符和类型	方法和说明
void	endMap(String tag) Check the mark for end of the serialized map.
void	endRecord(String tag) Check the mark for end of the serialized record.
void	endVector(String tag) Check the mark for end of the serialized vector.
boolean	readBool(String tag) Read a boolean from serialized record.
Buffer	readBuffer(String tag) Read byte array from serialized record.
byte	readByte(String tag) Read a byte from serialized record.
double	readDouble(String tag) Read a double-precision number from serialized record.
float	readFloat(String tag) Read a single-precision float from serialized record.
int	readInt(String tag) Read an integer from serialized record.
long	readLong(String tag) Read a long integer from serialized record.
String	readString(String tag) Read a UTF-8 encoded string from serialized record.
Index	startMap(String tag) Check the mark for start of the serialized map.
void	startRecord(String tag) Check the mark for start of the serialized record.
Index	startVector(String tag) Check the mark for start of the serialized vector.

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

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

构造器详细资料

CsvRecordInput

public CsvRecordInput(InputStream in)

Creates a new instance of CsvRecordInput

方法详细资料

readByte

public byte readByte(String tag)
              throws IOException

从接口复制的说明: RecordInput

Read a byte from serialized record.

指定者:

readByte 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

value read from serialized record.

抛出:

IOException

readBool

public boolean readBool(String tag)
                 throws IOException

从接口复制的说明: RecordInput

Read a boolean from serialized record.

指定者:

readBool 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

value read from serialized record.

抛出:

IOException

readInt

public int readInt(String tag)
            throws IOException

从接口复制的说明: RecordInput

Read an integer from serialized record.

指定者:

readInt 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

value read from serialized record.

抛出:

IOException

readLong

public long readLong(String tag)
              throws IOException

从接口复制的说明: RecordInput

Read a long integer from serialized record.

指定者:

readLong 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

value read from serialized record.

抛出:

IOException

readFloat

public float readFloat(String tag)
                throws IOException

从接口复制的说明: RecordInput

Read a single-precision float from serialized record.

指定者:

readFloat 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

value read from serialized record.

抛出:

IOException

readDouble

public double readDouble(String tag)
                  throws IOException

从接口复制的说明: RecordInput

Read a double-precision number from serialized record.

指定者:

readDouble 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

value read from serialized record.

抛出:

IOException

readString

public String readString(String tag)
                  throws IOException

从接口复制的说明: RecordInput

Read a UTF-8 encoded string from serialized record.

指定者:

readString 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

value read from serialized record.

抛出:

IOException

readBuffer

public Buffer readBuffer(String tag)
                  throws IOException

从接口复制的说明: RecordInput

Read byte array from serialized record.

指定者:

readBuffer 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

value read from serialized record.

抛出:

IOException

startRecord

public void startRecord(String tag)
                 throws IOException

从接口复制的说明: RecordInput

Check the mark for start of the serialized record.

指定者:

startRecord 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

抛出:

IOException

endRecord

public void endRecord(String tag)
               throws IOException

从接口复制的说明: RecordInput

Check the mark for end of the serialized record.

指定者:

endRecord 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

抛出:

IOException

startVector

public Index startVector(String tag)
                  throws IOException

从接口复制的说明: RecordInput

Check the mark for start of the serialized vector.

指定者:

startVector 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

Index that is used to count the number of elements.

抛出:

IOException

endVector

public void endVector(String tag)
               throws IOException

从接口复制的说明: RecordInput

Check the mark for end of the serialized vector.

指定者:

endVector 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

抛出:

IOException

startMap

public Index startMap(String tag)
               throws IOException

从接口复制的说明: RecordInput

Check the mark for start of the serialized map.

指定者:

startMap 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

返回:

Index that is used to count the number of map entries.

抛出:

IOException

endMap

public void endMap(String tag)
            throws IOException

从接口复制的说明: RecordInput

Check the mark for end of the serialized map.

指定者:

endMap 在接口中 RecordInput

参数:

tag - Used by tagged serialization formats (such as XML)

抛出:

IOException