下面列出了怎么用org.apache.hadoop.hbase.regionserver.wal.IndexedHLogReader的API类实例代码及写法,或者点击链接到github查看源代码。
/**
* 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);
}
/**
* 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);
}
/**
* 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);
}