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

Class SmallTableCache

java.lang.Object

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

public class SmallTableCache
extends Object

Constructor Summary

Constructors

Constructor and Description
SmallTableCache()

Method Summary

Modifier and Type	Method and Description
static void	cache(org.apache.hadoop.fs.Path path, MapJoinTableContainer tableContainer)
static MapJoinTableContainer	get(org.apache.hadoop.fs.Path path)
static void	initialize(org.apache.hadoop.conf.Configuration conf) Check if this is a new query.

Methods inherited from class java.lang.Object

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

Constructor Detail

SmallTableCache

public SmallTableCache()

Method Detail

initialize

public static void initialize(org.apache.hadoop.conf.Configuration conf)

Check if this is a new query. If so, clean up the cache that is for the previous query, and reset the current query id.

cache

public static void cache(org.apache.hadoop.fs.Path path,
                         MapJoinTableContainer tableContainer)

get

public static MapJoinTableContainer get(org.apache.hadoop.fs.Path path)