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

Class MapJoinTableContainerSerDe

java.lang.Object

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

public class MapJoinTableContainerSerDe
extends Object

Constructor Summary

Constructors

Constructor and Description
MapJoinTableContainerSerDe(MapJoinObjectSerDeContext keyContext, MapJoinObjectSerDeContext valueContext)

Method Summary

Modifier and Type	Method and Description
MapJoinObjectSerDeContext	getKeyContext()
MapJoinObjectSerDeContext	getValueContext()
MapJoinTableContainer	load(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path folder, org.apache.hadoop.conf.Configuration hconf) Loads the table container from a folder.
MapJoinPersistableTableContainer	load(ObjectInputStream in)
MapJoinTableContainer	loadFastContainer(MapJoinDesc mapJoinDesc, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path folder, org.apache.hadoop.conf.Configuration hconf) Loads the small table into a VectorMapJoinFastTableContainer.
void	persist(ObjectOutputStream out, MapJoinPersistableTableContainer tableContainer)
static void	persistDummyTable(ObjectOutputStream out)

Methods inherited from class java.lang.Object

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

Constructor Detail

MapJoinTableContainerSerDe

public MapJoinTableContainerSerDe(MapJoinObjectSerDeContext keyContext,
                                  MapJoinObjectSerDeContext valueContext)

Method Detail

getKeyContext

public MapJoinObjectSerDeContext getKeyContext()

getValueContext

public MapJoinObjectSerDeContext getValueContext()

load

public MapJoinPersistableTableContainer load(ObjectInputStream in)
                                      throws HiveException

Throws:

HiveException

load

public MapJoinTableContainer load(org.apache.hadoop.fs.FileSystem fs,
                                  org.apache.hadoop.fs.Path folder,
                                  org.apache.hadoop.conf.Configuration hconf)
                           throws HiveException

Loads the table container from a folder. Only used on Spark path.

Parameters:

fs - FileSystem of the folder.

folder - The folder to load table container.

hconf - The hive configuration

Returns:

Loaded table.

Throws:

HiveException

loadFastContainer

public MapJoinTableContainer loadFastContainer(MapJoinDesc mapJoinDesc,
                                               org.apache.hadoop.fs.FileSystem fs,
                                               org.apache.hadoop.fs.Path folder,
                                               org.apache.hadoop.conf.Configuration hconf)
                                        throws HiveException

Loads the small table into a VectorMapJoinFastTableContainer. Only used on Spark path.

Parameters:

mapJoinDesc - The descriptor for the map join

fs - FileSystem of the folder.

folder - The folder to load table container.

hconf - The hive configuration

Returns:

Loaded table.

Throws:

HiveException

persist

public void persist(ObjectOutputStream out,
                    MapJoinPersistableTableContainer tableContainer)
             throws HiveException

Throws:

HiveException

persistDummyTable

public static void persistDummyTable(ObjectOutputStream out)
                              throws IOException

Throws:

IOException