public static FlushPolicy create(HRegion region, Configuration conf) throws IOException {
    Class<? extends FlushPolicy> clazz = getFlushPolicyClass(region.getTableDescriptor(), conf);
    FlushPolicy policy = ReflectionUtils.newInstance(clazz, conf);
    policy.configureForRegion(region);
    return policy;
  }
Create the FlushPolicy configured for the given table.
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushPolicyFactory.java