org.apache.hadoop.hive.ql.exec.spark

Class HashTableLoader

java.lang.Object

org.apache.hadoop.hive.ql.exec.spark.HashTableLoader

All Implemented Interfaces:

HashTableLoader

public class HashTableLoader
extends Object
implements HashTableLoader

HashTableLoader for Spark to load the hashtable for MapJoins.

Constructor Summary

Constructors

Constructor and Description
HashTableLoader()

Method Summary

Modifier and Type	Method and Description
void	init(ExecMapperContext context, MapredContext mrContext, org.apache.hadoop.conf.Configuration hconf, MapJoinOperator joinOp)
void	load(MapJoinTableContainer[] mapJoinTables, MapJoinTableContainerSerDe[] mapJoinTableSerdes)

Methods inherited from class java.lang.Object

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

Constructor Detail

HashTableLoader

public HashTableLoader()

Method Detail

init

public void init(ExecMapperContext context,
                 MapredContext mrContext,
                 org.apache.hadoop.conf.Configuration hconf,
                 MapJoinOperator joinOp)

Specified by:

init in interface HashTableLoader

load

public void load(MapJoinTableContainer[] mapJoinTables,
                 MapJoinTableContainerSerDe[] mapJoinTableSerdes)
          throws HiveException

Specified by:

load in interface HashTableLoader

Throws:

HiveException