Java 类org.apache.hadoop.hbase.master.cleaner.TimeToLiveHFileCleaner 实例源码

public StorefileRefresherChore(int period, boolean onlyMetaRefresh, HRegionServer regionServer,
    Stoppable stoppable) {
  super("StorefileRefresherChore", stoppable, period);
  this.period = period;
  this.regionServer = regionServer;
  this.hfileTtl = this.regionServer.getConfiguration().getLong(
    TimeToLiveHFileCleaner.TTL_CONF_KEY, TimeToLiveHFileCleaner.DEFAULT_TTL);
  this.onlyMetaRefresh = onlyMetaRefresh;
  if (period > hfileTtl / 2) {
    throw new RuntimeException(REGIONSERVER_STOREFILE_REFRESH_PERIOD +
      " should be set smaller than half of " + TimeToLiveHFileCleaner.TTL_CONF_KEY);
  }
  lastRefreshTimes = new HashMap<String, Long>();
}

public StorefileRefresherChore(int period, HRegionServer regionServer, Stoppable stoppable) {
  super("StorefileRefresherChore", period, stoppable);
  this.period = period;
  this.regionServer = regionServer;
  this.hfileTtl = this.regionServer.getConfiguration().getLong(
    TimeToLiveHFileCleaner.TTL_CONF_KEY, TimeToLiveHFileCleaner.DEFAULT_TTL);
  if (period > hfileTtl / 2) {
    throw new RuntimeException(REGIONSERVER_STOREFILE_REFRESH_PERIOD +
      " should be set smaller than half of " + TimeToLiveHFileCleaner.TTL_CONF_KEY);
  }
  lastRefreshTimes = new HashMap<String, Long>();
}

public StorefileRefresherChore(int period, boolean onlyMetaRefresh, HRegionServer regionServer,
    Stoppable stoppable) {
  super("StorefileRefresherChore", stoppable, period);
  this.period = period;
  this.regionServer = regionServer;
  this.hfileTtl = this.regionServer.getConfiguration().getLong(
    TimeToLiveHFileCleaner.TTL_CONF_KEY, TimeToLiveHFileCleaner.DEFAULT_TTL);
  this.onlyMetaRefresh = onlyMetaRefresh;
  if (period > hfileTtl / 2) {
    throw new RuntimeException(REGIONSERVER_STOREFILE_REFRESH_PERIOD +
      " should be set smaller than half of " + TimeToLiveHFileCleaner.TTL_CONF_KEY);
  }
  lastRefreshTimes = new HashMap<>();
}

@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.getConfiguration().setLong(MobConstants.MOB_COMPACTION_MERGEABLE_THRESHOLD, 5000);
  TEST_UTIL.getConfiguration()
      .set(HConstants.CRYPTO_KEYPROVIDER_CONF_KEY, KeyProviderForTesting.class.getName());
  TEST_UTIL.getConfiguration().set(HConstants.CRYPTO_MASTERKEY_NAME_CONF_KEY, "hbase");
  TEST_UTIL.getConfiguration().setLong(TimeToLiveHFileCleaner.TTL_CONF_KEY, 0);
  TEST_UTIL.getConfiguration().setInt("hbase.client.retries.number", 1);
  TEST_UTIL.getConfiguration().setInt("hbase.hfile.compaction.discharger.interval", 100);
  TEST_UTIL.getConfiguration().setBoolean("hbase.online.schema.update.enable", true);
  TEST_UTIL.startMiniCluster(1);
  pool = createThreadPool(TEST_UTIL.getConfiguration());
  conn = ConnectionFactory.createConnection(TEST_UTIL.getConfiguration(), pool);
  fs = TEST_UTIL.getTestFileSystem();
  conf = TEST_UTIL.getConfiguration();
  admin = TEST_UTIL.getAdmin();

  // Initialize timestamps for these days
  Calendar calendar =  Calendar.getInstance();
  calendar.set(2015, 8, 7, 10, 20);
  tsFor20150907Monday = calendar.getTimeInMillis();

  calendar.set(2015, 10, 20, 10, 20);
  tsFor20151120Sunday = calendar.getTimeInMillis();

  calendar.set(2015, 10, 28, 10, 20);
  tsFor20151128Saturday = calendar.getTimeInMillis();

  calendar.set(2015, 10, 30, 10, 20);
  tsFor20151130Monday = calendar.getTimeInMillis();

  calendar.set(2015, 11, 1, 10, 20);
  tsFor20151201Tuesday = calendar.getTimeInMillis();

  calendar.set(2015, 11, 5, 10, 20);
  tsFor20151205Saturday = calendar.getTimeInMillis();

  calendar.set(2015, 11, 28, 10, 20);
  tsFor20151228Monday = calendar.getTimeInMillis();

  calendar.set(2015, 11, 31, 10, 20);
  tsFor20151231Thursday = calendar.getTimeInMillis();

  calendar.set(2016, 0, 1, 10, 20);
  tsFor20160101Friday = calendar.getTimeInMillis();

  calendar.set(2016, 0, 3, 10, 20);
  tsFor20160103Sunday = calendar.getTimeInMillis();
}

protected static void setupConfiguration() {
  TestCloneSnapshotFromClient.setupConfiguration();
  TEST_UTIL.getConfiguration().setLong(TimeToLiveHFileCleaner.TTL_CONF_KEY, 0);
  TEST_UTIL.getConfiguration().setInt(MobConstants.MOB_FILE_CACHE_SIZE_KEY, 0);
}