org.apache.lens.server.query

Class QueryResultPurger

java.lang.Object

org.apache.lens.server.query.QueryResultPurger

All Implemented Interfaces:

Runnable

public class QueryResultPurger
extends Object
implements Runnable

The Class QueryResultPurger - Purges old files in query resultset directory and hdfs output directory.

Field Summary

Fields

Modifier and Type	Field and Description
static String	QUERY_RESULT_PURGER_ERROR_COUNTER The Constant QUERY_RESULT_PURGER_COUNTER.

Constructor Summary

Constructors

Constructor and Description
QueryResultPurger()

Method Summary

Methods

Modifier and Type	Method and Description
void	awaitTermination(long timeout, TimeUnit unit)
void	init(org.apache.hadoop.conf.Configuration configuration)
boolean	isHealthy() Checks the status of executor service
void	purgePaths(org.apache.hadoop.fs.Path path, DateUtil.TimeDiff retention, boolean purgeDirectory)
void	run()
void	shutdown() Stops query result purger

Methods inherited from class java.lang.Object

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

Field Detail

QUERY_RESULT_PURGER_ERROR_COUNTER

public static final String QUERY_RESULT_PURGER_ERROR_COUNTER

The Constant QUERY_RESULT_PURGER_COUNTER.

See Also:

Constant Field Values

Constructor Detail

QueryResultPurger

public QueryResultPurger()

Method Detail

init

public void init(org.apache.hadoop.conf.Configuration configuration)

purgePaths

public void purgePaths(org.apache.hadoop.fs.Path path,
              DateUtil.TimeDiff retention,
              boolean purgeDirectory)
                throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

shutdown

public void shutdown()

Stops query result purger

isHealthy

public boolean isHealthy()

Checks the status of executor service

Returns:

awaitTermination

public void awaitTermination(long timeout,
                    TimeUnit unit)
                      throws InterruptedException

Throws:

InterruptedException