org.apache.hadoop.hbase.regionserver

Class FlushPolicyFactory

java.lang.Object

org.apache.hadoop.hbase.regionserver.FlushPolicyFactory

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class FlushPolicyFactory
extends Object

The class that creates a flush policy from a conf and HTableDescriptor.

The default flush policy is FlushLargeStoresPolicy. And for 0.98, the default flush policy is FlushAllStoresPolicy.

Field Summary

Fields

Modifier and Type	Field and Description
private static Class<? extends FlushPolicy>	DEFAULT_FLUSH_POLICY_CLASS
static String	HBASE_FLUSH_POLICY_KEY
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
FlushPolicyFactory()

Method Summary

Modifier and Type	Method and Description
static FlushPolicy	create(HRegion region, org.apache.hadoop.conf.Configuration conf) Create the FlushPolicy configured for the given table.
static Class<? extends FlushPolicy>	getFlushPolicyClass(TableDescriptor htd, org.apache.hadoop.conf.Configuration conf) Get FlushPolicy class for the given table.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

HBASE_FLUSH_POLICY_KEY

public static final String HBASE_FLUSH_POLICY_KEY

See Also:

Constant Field Values

DEFAULT_FLUSH_POLICY_CLASS

private static final Class<? extends FlushPolicy> DEFAULT_FLUSH_POLICY_CLASS

Constructor Detail

FlushPolicyFactory

public FlushPolicyFactory()

Method Detail

create

public static FlushPolicy create(HRegion region,
                                 org.apache.hadoop.conf.Configuration conf)
                          throws IOException

Create the FlushPolicy configured for the given table.

Throws:

IOException

getFlushPolicyClass

public static Class<? extends FlushPolicy> getFlushPolicyClass(TableDescriptor htd,
                                                               org.apache.hadoop.conf.Configuration conf)
                                                        throws IOException

Get FlushPolicy class for the given table.

Throws:

IOException