Package org.apache.hadoop.hbase.regionserver

Class FlushPolicyFactory

java.lang.Object

org.apache.hadoop.hbase.regionserver.FlushPolicyFactory

@LimitedPrivate("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	Description
private static final Class<? extends FlushPolicy>	DEFAULT_FLUSH_POLICY_CLASS
static final String	HBASE_FLUSH_POLICY_KEY
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
FlushPolicyFactory()

Method Summary

Modifier and Type	Method	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 Details

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 Details

FlushPolicyFactory

public FlushPolicyFactory()

Method Details

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