org.apache.hadoop.hive.contrib.util.typedbytes

Class TypedBytesWritableInput

java.lang.Object

org.apache.hadoop.hive.contrib.util.typedbytes.TypedBytesWritableInput

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class TypedBytesWritableInput
extends Object
implements org.apache.hadoop.conf.Configurable

Provides functionality for reading typed bytes as Writable objects.

See Also:

TypedBytesInput

Constructor Summary

Constructors

Constructor and Description
TypedBytesWritableInput(DataInput din) Creates a new instance of TypedBytesWritableInput.
TypedBytesWritableInput(TypedBytesInput in) Creates a new instance of TypedBytesWritableInput.

Method Summary

Methods

Modifier and Type	Method and Description
static TypedBytesWritableInput	get(DataInput in) Get a thread-local typed bytes writable input for the supplied DataInput.
static TypedBytesWritableInput	get(TypedBytesInput in) Get a thread-local typed bytes writable input for the supplied TypedBytesInput.
org.apache.hadoop.conf.Configuration	getConf()
org.apache.hadoop.io.Writable	read()
org.apache.hadoop.io.ArrayWritable	readArray()
org.apache.hadoop.io.ArrayWritable	readArray(org.apache.hadoop.io.ArrayWritable aw)
org.apache.hadoop.io.BooleanWritable	readBoolean()
org.apache.hadoop.io.BooleanWritable	readBoolean(org.apache.hadoop.io.BooleanWritable bw)
ByteWritable	readByte()
ByteWritable	readByte(ByteWritable bw)
org.apache.hadoop.io.BytesWritable	readBytes()
org.apache.hadoop.io.BytesWritable	readBytes(org.apache.hadoop.io.BytesWritable bw)
DoubleWritable	readDouble()
DoubleWritable	readDouble(DoubleWritable dw)
org.apache.hadoop.io.FloatWritable	readFloat()
org.apache.hadoop.io.FloatWritable	readFloat(org.apache.hadoop.io.FloatWritable fw)
org.apache.hadoop.io.IntWritable	readInt()
org.apache.hadoop.io.IntWritable	readInt(org.apache.hadoop.io.IntWritable iw)
org.apache.hadoop.io.LongWritable	readLong()
org.apache.hadoop.io.LongWritable	readLong(org.apache.hadoop.io.LongWritable lw)
org.apache.hadoop.io.MapWritable	readMap()
org.apache.hadoop.io.MapWritable	readMap(org.apache.hadoop.io.MapWritable mw)
ShortWritable	readShort()
ShortWritable	readShort(ShortWritable sw)
org.apache.hadoop.io.SortedMapWritable	readSortedMap()
org.apache.hadoop.io.SortedMapWritable	readSortedMap(org.apache.hadoop.io.SortedMapWritable mw)
org.apache.hadoop.io.Text	readText()
org.apache.hadoop.io.Text	readText(org.apache.hadoop.io.Text t)
Class<? extends org.apache.hadoop.io.Writable>	readType()
Type	readTypeCode()
org.apache.hadoop.io.VIntWritable	readVInt()
org.apache.hadoop.io.VIntWritable	readVInt(org.apache.hadoop.io.VIntWritable iw)
org.apache.hadoop.io.VLongWritable	readVLong()
org.apache.hadoop.io.VLongWritable	readVLong(org.apache.hadoop.io.VLongWritable lw)
org.apache.hadoop.io.Writable	readWritable()
org.apache.hadoop.io.Writable	readWritable(org.apache.hadoop.io.Writable writable)
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

TypedBytesWritableInput

public TypedBytesWritableInput(TypedBytesInput in)

Creates a new instance of TypedBytesWritableInput.

TypedBytesWritableInput

public TypedBytesWritableInput(DataInput din)

Creates a new instance of TypedBytesWritableInput.

Method Detail

get

public static TypedBytesWritableInput get(TypedBytesInput in)

Get a thread-local typed bytes writable input for the supplied TypedBytesInput.

Parameters:

in - typed bytes input object

Returns:

typed bytes writable input corresponding to the supplied TypedBytesInput.

get

public static TypedBytesWritableInput get(DataInput in)

Get a thread-local typed bytes writable input for the supplied DataInput.

Parameters:

in - data input object

Returns:

typed bytes writable input corresponding to the supplied DataInput.

read

public org.apache.hadoop.io.Writable read()
                                   throws IOException

Throws:

IOException

readTypeCode

public Type readTypeCode()
                  throws IOException

Throws:

IOException

readType

public Class<? extends org.apache.hadoop.io.Writable> readType()
                                                        throws IOException

Throws:

IOException

readBytes

public org.apache.hadoop.io.BytesWritable readBytes(org.apache.hadoop.io.BytesWritable bw)
                                             throws IOException

Throws:

IOException

readBytes

public org.apache.hadoop.io.BytesWritable readBytes()
                                             throws IOException

Throws:

IOException

readByte

public ByteWritable readByte(ByteWritable bw)
                      throws IOException

Throws:

IOException

readByte

public ByteWritable readByte()
                      throws IOException

Throws:

IOException

readBoolean

public org.apache.hadoop.io.BooleanWritable readBoolean(org.apache.hadoop.io.BooleanWritable bw)
                                                 throws IOException

Throws:

IOException

readBoolean

public org.apache.hadoop.io.BooleanWritable readBoolean()
                                                 throws IOException

Throws:

IOException

readInt

public org.apache.hadoop.io.IntWritable readInt(org.apache.hadoop.io.IntWritable iw)
                                         throws IOException

Throws:

IOException

readInt

public org.apache.hadoop.io.IntWritable readInt()
                                         throws IOException

Throws:

IOException

readShort

public ShortWritable readShort(ShortWritable sw)
                        throws IOException

Throws:

IOException

readShort

public ShortWritable readShort()
                        throws IOException

Throws:

IOException

readVInt

public org.apache.hadoop.io.VIntWritable readVInt(org.apache.hadoop.io.VIntWritable iw)
                                           throws IOException

Throws:

IOException

readVInt

public org.apache.hadoop.io.VIntWritable readVInt()
                                           throws IOException

Throws:

IOException

readLong

public org.apache.hadoop.io.LongWritable readLong(org.apache.hadoop.io.LongWritable lw)
                                           throws IOException

Throws:

IOException

readLong

public org.apache.hadoop.io.LongWritable readLong()
                                           throws IOException

Throws:

IOException

readVLong

public org.apache.hadoop.io.VLongWritable readVLong(org.apache.hadoop.io.VLongWritable lw)
                                             throws IOException

Throws:

IOException

readVLong

public org.apache.hadoop.io.VLongWritable readVLong()
                                             throws IOException

Throws:

IOException

readFloat

public org.apache.hadoop.io.FloatWritable readFloat(org.apache.hadoop.io.FloatWritable fw)
                                             throws IOException

Throws:

IOException

readFloat

public org.apache.hadoop.io.FloatWritable readFloat()
                                             throws IOException

Throws:

IOException

readDouble

public DoubleWritable readDouble(DoubleWritable dw)
                          throws IOException

Throws:

IOException

readDouble

public DoubleWritable readDouble()
                          throws IOException

Throws:

IOException

readText

public org.apache.hadoop.io.Text readText(org.apache.hadoop.io.Text t)
                                   throws IOException

Throws:

IOException

readText

public org.apache.hadoop.io.Text readText()
                                   throws IOException

Throws:

IOException

readArray

public org.apache.hadoop.io.ArrayWritable readArray(org.apache.hadoop.io.ArrayWritable aw)
                                             throws IOException

Throws:

IOException

readArray

public org.apache.hadoop.io.ArrayWritable readArray()
                                             throws IOException

Throws:

IOException

readMap

public org.apache.hadoop.io.MapWritable readMap(org.apache.hadoop.io.MapWritable mw)
                                         throws IOException

Throws:

IOException

readMap

public org.apache.hadoop.io.MapWritable readMap()
                                         throws IOException

Throws:

IOException

readSortedMap

public org.apache.hadoop.io.SortedMapWritable readSortedMap(org.apache.hadoop.io.SortedMapWritable mw)
                                                     throws IOException

Throws:

IOException

readSortedMap

public org.apache.hadoop.io.SortedMapWritable readSortedMap()
                                                     throws IOException

Throws:

IOException

readWritable

public org.apache.hadoop.io.Writable readWritable(org.apache.hadoop.io.Writable writable)
                                           throws IOException

Throws:

IOException

readWritable

public org.apache.hadoop.io.Writable readWritable()
                                           throws IOException

Throws:

IOException

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable