org.apache.hadoop.hive.ql.cache.results

Class QueryResultsCache.CacheEntry

java.lang.Object

org.apache.hadoop.hive.ql.cache.results.QueryResultsCache.CacheEntry

Enclosing class:

QueryResultsCache

public static class QueryResultsCache.CacheEntry
extends Object

Constructor Summary

Constructors

Constructor and Description
CacheEntry()

Method Summary

Modifier and Type	Method and Description
boolean	addReader()
org.apache.hadoop.fs.Path	getCachedResultsPath()
FetchWork	getFetchWork()
QueryResultsCache.QueryInfo	getQueryInfo()
QueryResultsCache.CacheEntryStatus	getStatus()
java.util.stream.Stream<String>	getTableNames()
void	releaseReader()
String	toString()
boolean	waitForValidStatus() Wait for the cache entry to go from PENDING to VALID status.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheEntry

public CacheEntry()

Method Detail

releaseReader

public void releaseReader()

toString

public String toString()

Overrides:

toString in class Object

addReader

public boolean addReader()

getStatus

public QueryResultsCache.CacheEntryStatus getStatus()

getFetchWork

public FetchWork getFetchWork()

getQueryInfo

public QueryResultsCache.QueryInfo getQueryInfo()

getCachedResultsPath

public org.apache.hadoop.fs.Path getCachedResultsPath()

waitForValidStatus

public boolean waitForValidStatus()

Wait for the cache entry to go from PENDING to VALID status.

Returns:

true if the cache entry successfully changed to VALID status, false if the status changes from PENDING to INVALID

getTableNames

public java.util.stream.Stream<String> getTableNames()