org.apache.tephra.hbase.txprune

Class PruneUpperBoundWriterSupplier

java.lang.Object

org.apache.tephra.hbase.txprune.PruneUpperBoundWriterSupplier

All Implemented Interfaces:

com.google.common.base.Supplier<PruneUpperBoundWriter>, CacheSupplier<PruneUpperBoundWriter>

public class PruneUpperBoundWriterSupplier
extends Object
implements CacheSupplier<PruneUpperBoundWriter>

Supplies instances of PruneUpperBoundWriter implementations.

Constructor Summary

Constructors

Constructor and Description
PruneUpperBoundWriterSupplier(org.apache.hadoop.hbase.TableName tableName, DataJanitorState dataJanitorState, long pruneFlushInterval)

Method Summary

Methods

Modifier and Type	Method and Description
PruneUpperBoundWriter	get()
void	release() Release the object obtained through {code Supplier#get()}.

Methods inherited from class java.lang.Object

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

Constructor Detail

PruneUpperBoundWriterSupplier

public PruneUpperBoundWriterSupplier(org.apache.hadoop.hbase.TableName tableName,
                             DataJanitorState dataJanitorState,
                             long pruneFlushInterval)

Method Detail

get

public PruneUpperBoundWriter get()

Specified by:

get in interface com.google.common.base.Supplier<PruneUpperBoundWriter>

Specified by:

get in interface CacheSupplier<PruneUpperBoundWriter>

Returns:

Get an instance of T and if it is the first call, then the service will be started. Subsequent calls will get a reference to the same instance

release

public void release()

Description copied from interface: CacheSupplier

Release the object obtained through {code Supplier#get()}. If this is the last release call, then the service will be stopped.

Specified by:

release in interface CacheSupplier<PruneUpperBoundWriter>