org.apache.hadoop.typedbytes

类 TypedBytesRecordOutput

java.lang.Object

org.apache.hadoop.typedbytes.TypedBytesRecordOutput

所有已实现的接口:

RecordOutput

public class TypedBytesRecordOutput
extends Object
implements RecordOutput

Deserialized for records that reads typed bytes.

构造器概要

构造器

构造器和说明
TypedBytesRecordOutput(DataOutput out) Creates a new instance of TypedBytesRecordOutput.
TypedBytesRecordOutput(TypedBytesOutput out) Creates a new instance of TypedBytesRecordOutput.

方法概要

方法

限定符和类型	方法和说明
void	endMap(TreeMap m, String tag) Mark the end of a serialized map.
void	endRecord(Record r, String tag) Mark the end of a serialized record.
void	endVector(ArrayList v, String tag) Mark the end of a serialized vector.
static TypedBytesRecordOutput	get(DataOutput out) Get a thread-local typed bytes record output for the supplied DataOutput.
static TypedBytesRecordOutput	get(TypedBytesOutput out) Get a thread-local typed bytes record input for the supplied TypedBytesOutput.
void	startMap(TreeMap m, String tag) Mark the start of a map to be serialized.
void	startRecord(Record r, String tag) Mark the start of a record to be serialized.
void	startVector(ArrayList v, String tag) Mark the start of a vector to be serialized.
void	writeBool(boolean b, String tag) Write a boolean to serialized record.
void	writeBuffer(Buffer buf, String tag) Write a buffer to serialized record.
void	writeByte(byte b, String tag) Write a byte to serialized record.
void	writeDouble(double d, String tag) Write a double precision floating point number to serialized record.
void	writeFloat(float f, String tag) Write a single-precision float to serialized record.
void	writeInt(int i, String tag) Write an integer to serialized record.
void	writeLong(long l, String tag) Write a long integer to serialized record.
void	writeString(String s, String tag) Write a unicode string to serialized record.

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

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

构造器详细资料

TypedBytesRecordOutput

public TypedBytesRecordOutput(TypedBytesOutput out)

Creates a new instance of TypedBytesRecordOutput.

TypedBytesRecordOutput

public TypedBytesRecordOutput(DataOutput out)

Creates a new instance of TypedBytesRecordOutput.

方法详细资料

get

public static TypedBytesRecordOutput get(TypedBytesOutput out)

Get a thread-local typed bytes record input for the supplied TypedBytesOutput.

参数:

out - typed bytes output object

返回:

typed bytes record output corresponding to the supplied TypedBytesOutput.

get

public static TypedBytesRecordOutput get(DataOutput out)

Get a thread-local typed bytes record output for the supplied DataOutput.

参数:

out - data output object

返回:

typed bytes record output corresponding to the supplied DataOutput.

writeBool

public void writeBool(boolean b,
             String tag)
               throws IOException

从接口复制的说明: RecordOutput

Write a boolean to serialized record.

指定者:

writeBool 在接口中 RecordOutput

参数:

b - Boolean to be serialized

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

抛出:

IOException - Indicates error in serialization

writeBuffer

public void writeBuffer(Buffer buf,
               String tag)
                 throws IOException

从接口复制的说明: RecordOutput

Write a buffer to serialized record.

指定者:

writeBuffer 在接口中 RecordOutput

参数:

buf - Buffer to be serialized

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

抛出:

IOException - Indicates error in serialization

writeByte

public void writeByte(byte b,
             String tag)
               throws IOException

从接口复制的说明: RecordOutput

Write a byte to serialized record.

指定者:

writeByte 在接口中 RecordOutput

参数:

b - Byte to be serialized

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

抛出:

IOException - Indicates error in serialization

writeDouble

public void writeDouble(double d,
               String tag)
                 throws IOException

从接口复制的说明: RecordOutput

Write a double precision floating point number to serialized record.

指定者:

writeDouble 在接口中 RecordOutput

参数:

d - Double to be serialized

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

抛出:

IOException - Indicates error in serialization

writeFloat

public void writeFloat(float f,
              String tag)
                throws IOException

从接口复制的说明: RecordOutput

Write a single-precision float to serialized record.

指定者:

writeFloat 在接口中 RecordOutput

参数:

f - Float to be serialized

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

抛出:

IOException - Indicates error in serialization

writeInt

public void writeInt(int i,
            String tag)
              throws IOException

从接口复制的说明: RecordOutput

Write an integer to serialized record.

指定者:

writeInt 在接口中 RecordOutput

参数:

i - Integer to be serialized

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

抛出:

IOException - Indicates error in serialization

writeLong

public void writeLong(long l,
             String tag)
               throws IOException

从接口复制的说明: RecordOutput

Write a long integer to serialized record.

指定者:

writeLong 在接口中 RecordOutput

参数:

l - Long to be serialized

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

抛出:

IOException - Indicates error in serialization

writeString

public void writeString(String s,
               String tag)
                 throws IOException

从接口复制的说明: RecordOutput

Write a unicode string to serialized record.

指定者:

writeString 在接口中 RecordOutput

参数:

s - String to be serialized

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

抛出:

IOException - Indicates error in serialization

startRecord

public void startRecord(Record r,
               String tag)
                 throws IOException

从接口复制的说明: RecordOutput

Mark the start of a record to be serialized.

指定者:

startRecord 在接口中 RecordOutput

参数:

r - Record to be serialized

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

抛出:

IOException - Indicates error in serialization

startVector

public void startVector(ArrayList v,
               String tag)
                 throws IOException

从接口复制的说明: RecordOutput

Mark the start of a vector to be serialized.

指定者:

startVector 在接口中 RecordOutput

参数:

v - Vector to be serialized

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

抛出:

IOException - Indicates error in serialization

startMap

public void startMap(TreeMap m,
            String tag)
              throws IOException

从接口复制的说明: RecordOutput

Mark the start of a map to be serialized.

指定者:

startMap 在接口中 RecordOutput

参数:

m - Map to be serialized

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

抛出:

IOException - Indicates error in serialization

endRecord

public void endRecord(Record r,
             String tag)
               throws IOException

从接口复制的说明: RecordOutput

Mark the end of a serialized record.

指定者:

endRecord 在接口中 RecordOutput

参数:

r - Record to be serialized

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

抛出:

IOException - Indicates error in serialization

endVector

public void endVector(ArrayList v,
             String tag)
               throws IOException

从接口复制的说明: RecordOutput

Mark the end of a serialized vector.

指定者:

endVector 在接口中 RecordOutput

参数:

v - Vector to be serialized

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

抛出:

IOException - Indicates error in serialization

endMap

public void endMap(TreeMap m,
          String tag)
            throws IOException

从接口复制的说明: RecordOutput

Mark the end of a serialized map.

指定者:

endMap 在接口中 RecordOutput

参数:

m - Map to be serialized

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

抛出:

IOException - Indicates error in serialization