org.apache.hadoop.hive.ql.txn

Class AcidOpenTxnsCounterService

java.lang.Object

org.apache.hadoop.hive.ql.txn.compactor.HouseKeeperServiceBase

org.apache.hadoop.hive.ql.txn.AcidOpenTxnsCounterService

All Implemented Interfaces:

HouseKeeperService

public class AcidOpenTxnsCounterService
extends HouseKeeperServiceBase

Background running thread, periodically updating number of open transactions. Runs inside Hive Metastore Service.

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.txn.compactor.HouseKeeperServiceBase

hiveConf, isAliveCounter

Constructor Summary

Constructors

Constructor and Description
AcidOpenTxnsCounterService()

Method Summary

Modifier and Type	Method and Description
protected long	getIntervalMs() Determines how frequently the service is running its task.
protected Runnable	getScheduedAction(HiveConf hiveConf, AtomicInteger isAliveCounter) The actual task implementation.
String	getServiceDescription() Returns short description of services this module provides.
protected long	getStartDelayMs() Delay in millis before first run of the task of this service.

Methods inherited from class org.apache.hadoop.hive.ql.txn.compactor.HouseKeeperServiceBase

getIsAliveCounter, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

AcidOpenTxnsCounterService

public AcidOpenTxnsCounterService()

Method Detail

getStartDelayMs

protected long getStartDelayMs()

Description copied from class: HouseKeeperServiceBase

Delay in millis before first run of the task of this service.

Specified by:

getStartDelayMs in class HouseKeeperServiceBase

getIntervalMs

protected long getIntervalMs()

Description copied from class: HouseKeeperServiceBase

Determines how frequently the service is running its task.

Specified by:

getIntervalMs in class HouseKeeperServiceBase

getScheduedAction

protected Runnable getScheduedAction(HiveConf hiveConf,
                                     AtomicInteger isAliveCounter)

Description copied from class: HouseKeeperServiceBase

The actual task implementation. Must increment the counter on each iteration.

Specified by:

getScheduedAction in class HouseKeeperServiceBase

getServiceDescription

public String getServiceDescription()

Description copied from interface: HouseKeeperService

Returns short description of services this module provides.