类org.apache.hadoop.hbase.regionserver.wal.IndexedHLogReader源码实例Demo

下面列出了怎么用org.apache.hadoop.hbase.regionserver.wal.IndexedHLogReader的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: phoenix   文件: TestIndexManagementUtil.java
/**
 * We cannot support WAL Compression with the IndexedHLogReader
 * @throws Exception
 */
@Test(expected = IllegalStateException.class)
public void testCompressedWALWithHLogReader() throws Exception {
  Configuration conf = new Configuration(false);
  conf.setBoolean(HConstants.ENABLE_WAL_COMPRESSION, true);
  // works with WALEditcodec
  conf.set(IndexManagementUtil.HLOG_READER_IMPL_KEY, IndexedHLogReader.class.getName());
  IndexManagementUtil.ensureMutableIndexingCorrectlyConfigured(conf);
}
 
源代码2 项目: phoenix   文件: TestIndexManagementUtil.java
/**
 * We cannot support WAL Compression with the IndexedHLogReader
 * @throws Exception
 */
@Test(expected = IllegalStateException.class)
public void testCompressedWALWithHLogReader() throws Exception {
  Configuration conf = new Configuration(false);
  conf.setBoolean(HConstants.ENABLE_WAL_COMPRESSION, true);
  // works with WALEditcodec
  conf.set(IndexManagementUtil.HLOG_READER_IMPL_KEY, IndexedHLogReader.class.getName());
  IndexManagementUtil.ensureMutableIndexingCorrectlyConfigured(conf);
}
 
源代码3 项目: phoenix   文件: TestIndexManagementUtil.java
/**
 * We cannot support WAL Compression with the IndexedHLogReader
 * @throws Exception
 */
@Test(expected = IllegalStateException.class)
public void testCompressedWALWithHLogReader() throws Exception {
  Configuration conf = new Configuration(false);
  conf.setBoolean(HConstants.ENABLE_WAL_COMPRESSION, true);
  // works with WALEditcodec
  conf.set(IndexManagementUtil.HLOG_READER_IMPL_KEY, IndexedHLogReader.class.getName());
  IndexManagementUtil.ensureMutableIndexingCorrectlyConfigured(conf);
}
 
 类所在包
 同包方法