Java 类org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner 实例源码

项目：ditb 文件：TestLogsCleaner.java

@Test(timeout=5000)
public void testZnodeCversionChange() throws Exception {
  Configuration conf = TEST_UTIL.getConfiguration();
  ReplicationLogCleaner cleaner = new ReplicationLogCleaner();
  cleaner.setConf(conf);

  ReplicationQueuesClient rqcMock = Mockito.mock(ReplicationQueuesClient.class);
  Mockito.when(rqcMock.getQueuesZNodeCversion()).thenReturn(1, 2, 3, 4);

  Field rqc = ReplicationLogCleaner.class.getDeclaredField("replicationQueues");
  rqc.setAccessible(true);

  rqc.set(cleaner, rqcMock);

  // This should return eventually when cversion stabilizes
  cleaner.getDeletableFiles(new LinkedList<FileStatus>());
}

项目：hbase 文件：HMaster.java

/**
 * This method modifies the master's configuration in order to inject replication-related features
 */
@VisibleForTesting
public static void decorateMasterConfiguration(Configuration conf) {
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
  if (ReplicationUtils.isReplicationForBulkLoadDataEnabled(conf)) {
    plugins = conf.get(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS);
    cleanerClass = ReplicationHFileCleaner.class.getCanonicalName();
    if (!plugins.contains(cleanerClass)) {
      conf.set(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS, plugins + "," + cleanerClass);
    }
  }
}

项目：ditb 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：LCIndex-HBase-0.94.16 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：pbase 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：HIndex 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：IRIndex 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：RStore 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  if (!plugins.contains(ReplicationLogCleaner.class.toString())) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS,
        plugins + "," + ReplicationLogCleaner.class.getCanonicalName());
  }
}

项目：PyroDB 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：c5 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：HBase-Research 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：hbase-0.94.8-qod 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：hbase-0.94.8-qod 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}

项目：DominoHBase 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  if (!plugins.contains(ReplicationLogCleaner.class.toString())) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS,
        plugins + "," + ReplicationLogCleaner.class.getCanonicalName());
  }
}

项目：hindex 文件：Replication.java

/**
 * This method modifies the master's configuration in order to inject
 * replication-related features
 * @param conf
 */
public static void decorateMasterConfiguration(Configuration conf) {
  if (!isReplication(conf)) {
    return;
  }
  String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);
  String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();
  if (!plugins.contains(cleanerClass)) {
    conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);
  }
}