1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.util.HBaseFsck.PrintingErrorReporter

Java 类org.apache.hadoop.hbase.util.HBaseFsck.PrintingErrorReporter 实例源码

项目：ditb    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test (timeout=180000)
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：LCIndex-HBase-0.94.16    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：pbase    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test (timeout=180000)
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：HIndex    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：IRIndex    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：PyroDB    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：c5    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：HBase-Research    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：hbase-0.94.8-qod    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：hbase-0.94.8-qod    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：DominoHBase    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}
项目：hindex    文件：TestHBaseFsck.java    
/**
 * Test pluggable error reporter. It can be plugged in
 * from system property or configuration.
 */
@Test
public void testErrorReporter() throws Exception {
  try {
    MockErrorReporter.calledCount = 0;
    doFsck(conf, false);
    assertEquals(MockErrorReporter.calledCount, 0);

    conf.set("hbasefsck.errorreporter", MockErrorReporter.class.getName());
    doFsck(conf, false);
    assertTrue(MockErrorReporter.calledCount > 20);
  } finally {
    conf.set("hbasefsck.errorreporter",
      PrintingErrorReporter.class.getName());
    MockErrorReporter.calledCount = 0;
  }
}