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

Methods

Modifier and Type	Method and Description
MapJoinObjectSerDeContext	getKeyContext()
MapJoinObjectSerDeContext	getValueContext()
MapJoinPersistableTableContainer	load(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path folder) Loads the table container from a folder.
MapJoinPersistableTableContainer	load(ObjectInputStream in)
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 MapJoinPersistableTableContainer load(org.apache.hadoop.fs.FileSystem fs,
                                    org.apache.hadoop.fs.Path folder)
                                      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.

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