org.apache.hadoop.hive.ql.exec.persistence

Class MapJoinBytesTableContainer.DirectKeyValueWriter

java.lang.Object

org.apache.hadoop.hive.ql.exec.persistence.MapJoinBytesTableContainer.DirectKeyValueWriter

All Implemented Interfaces:

MemoryEstimate, BytesBytesMultiHashMap.KvSource, MapJoinBytesTableContainer.KeyValueHelper

Enclosing class:

MapJoinBytesTableContainer

protected static class MapJoinBytesTableContainer.DirectKeyValueWriter
extends Object
implements MapJoinBytesTableContainer.KeyValueHelper

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DirectKeyValueWriter()

Method Summary

Modifier and Type	Method and Description
long	getEstimatedMemorySize() Returns estimated memory size based JavaDataModel
int	getHashFromKey() Get hash value from the key.
void	setKeyValue(org.apache.hadoop.io.Writable key, org.apache.hadoop.io.Writable val)
byte	updateStateByte(Byte previousValue) Provide updated value for state byte for a key.
void	writeKey(ByteStream.RandomAccessOutput dest) Write key into output.
void	writeValue(ByteStream.RandomAccessOutput dest) Write value into output.

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectKeyValueWriter

protected DirectKeyValueWriter()

Method Detail

setKeyValue

public void setKeyValue(org.apache.hadoop.io.Writable key,
                        org.apache.hadoop.io.Writable val)
                 throws SerDeException

Specified by:

setKeyValue in interface MapJoinBytesTableContainer.KeyValueHelper

Throws:

SerDeException

writeKey

public void writeKey(ByteStream.RandomAccessOutput dest)
              throws SerDeException

Description copied from interface: BytesBytesMultiHashMap.KvSource

Write key into output.

Specified by:

writeKey in interface BytesBytesMultiHashMap.KvSource

Throws:

SerDeException

writeValue

public void writeValue(ByteStream.RandomAccessOutput dest)
                throws SerDeException

Description copied from interface: BytesBytesMultiHashMap.KvSource

Write value into output.

Specified by:

writeValue in interface BytesBytesMultiHashMap.KvSource

Throws:

SerDeException

updateStateByte

public byte updateStateByte(Byte previousValue)

Description copied from interface: BytesBytesMultiHashMap.KvSource

Provide updated value for state byte for a key.

Specified by:

updateStateByte in interface BytesBytesMultiHashMap.KvSource

Parameters:

previousValue - Previous value; null if this is the first call per key.

Returns:

The updated value.

getHashFromKey

public int getHashFromKey()
                   throws SerDeException

Description copied from interface: MapJoinBytesTableContainer.KeyValueHelper

Get hash value from the key.

Specified by:

getHashFromKey in interface MapJoinBytesTableContainer.KeyValueHelper

Throws:

SerDeException

getEstimatedMemorySize

public long getEstimatedMemorySize()

Description copied from interface: MemoryEstimate

Returns estimated memory size based JavaDataModel

Specified by:

getEstimatedMemorySize in interface MemoryEstimate

Returns:

estimated memory size in bytes