Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.io | |
org.apache.hadoop.hbase.io.hfile |
Provides implementations of
HFile and HFile
BlockCache . |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.tmpl.regionserver | |
org.apache.hadoop.hbase.util | |
org.apache.hadoop.hbase.util.hbck |
Modifier and Type | Method and Description |
---|---|
StoreFile.Reader |
RegionObserver.postStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r,
StoreFile.Reader reader)
Called after the creation of Reader for a store file.
|
StoreFile.Reader |
BaseRegionObserver.postStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r,
StoreFile.Reader reader) |
StoreFile.Reader |
RegionObserver.preStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r,
StoreFile.Reader reader)
Called before creation of Reader for a store file.
|
StoreFile.Reader |
BaseRegionObserver.preStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r,
StoreFile.Reader reader) |
Constructor and Description |
---|
HalfStoreFileReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
CacheConfig cacheConf,
Reference r,
org.apache.hadoop.conf.Configuration conf)
Creates a half file reader for a normal hfile.
|
HalfStoreFileReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r,
org.apache.hadoop.conf.Configuration conf)
Creates a half file reader for a hfile referred to by an hfilelink.
|
Modifier and Type | Field and Description |
---|---|
protected CacheConfig |
AbstractHFileReader.cacheConf
Block cache configuration.
|
protected CacheConfig |
AbstractHFileWriter.cacheConf
Cache configuration for caching data on write.
|
private CacheConfig |
HFileBlockIndex.BlockIndexWriter.cacheConf
CacheConfig, or null if cache-on-write is disabled
|
protected CacheConfig |
HFile.WriterFactory.cacheConf |
Modifier and Type | Method and Description |
---|---|
static HFile.Reader |
HFile.createReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
CacheConfig cacheConf,
org.apache.hadoop.conf.Configuration conf) |
static HFile.Reader |
HFile.createReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
FSDataInputStreamWrapper fsdis,
long size,
CacheConfig cacheConf,
org.apache.hadoop.conf.Configuration conf)
The sockets and the file descriptors held by the method parameter
FSDataInputStreamWrapper passed will be freed after its usage so caller needs to ensure
that no other threads have access to the same passed reference. |
(package private) static HFile.Reader |
HFile.createReaderFromStream(org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.FSDataInputStream fsdis,
long size,
CacheConfig cacheConf,
org.apache.hadoop.conf.Configuration conf)
This factory method is used only by unit tests.
|
HFileBlock |
HFileBlock.Writer.getBlockForCaching(CacheConfig cacheConf)
Creates a new HFileBlock.
|
static HFile.WriterFactory |
HFile.getWriterFactory(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf)
Returns the factory to be used to create
HFile writers |
private static HFile.Reader |
HFile.openReader(org.apache.hadoop.fs.Path path,
FSDataInputStreamWrapper fsdis,
long size,
CacheConfig cacheConf,
HFileSystem hfs,
org.apache.hadoop.conf.Configuration conf)
Method returns the reader given the specified arguments.
|
Constructor and Description |
---|
AbstractHFileReader(org.apache.hadoop.fs.Path path,
FixedFileTrailer trailer,
long fileSize,
CacheConfig cacheConf,
HFileSystem hfs,
org.apache.hadoop.conf.Configuration conf) |
AbstractHFileWriter(CacheConfig cacheConf,
org.apache.hadoop.fs.FSDataOutputStream outputStream,
org.apache.hadoop.fs.Path path,
KeyValue.KVComparator comparator,
HFileContext fileContext) |
CacheConfig(CacheConfig cacheConf)
Constructs a cache configuration copied from the specified configuration.
|
HFile.WriterFactory(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf) |
HFileBlockIndex.BlockIndexWriter(HFileBlock.Writer blockWriter,
CacheConfig cacheConf,
String nameForCaching)
Creates a multi-level block index writer.
|
HFileReaderV2(org.apache.hadoop.fs.Path path,
FixedFileTrailer trailer,
FSDataInputStreamWrapper fsdis,
long size,
CacheConfig cacheConf,
HFileSystem hfs,
org.apache.hadoop.conf.Configuration conf)
Opens a HFile.
|
HFileReaderV3(org.apache.hadoop.fs.Path path,
FixedFileTrailer trailer,
FSDataInputStreamWrapper fsdis,
long size,
CacheConfig cacheConf,
HFileSystem hfs,
org.apache.hadoop.conf.Configuration conf)
Opens a HFile.
|
HFileWriterV2.WriterFactoryV2(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf) |
HFileWriterV2(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.FSDataOutputStream ostream,
KeyValue.KVComparator comparator,
HFileContext context)
Constructor that takes a path, creates and closes the output stream.
|
HFileWriterV3.WriterFactoryV3(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf) |
HFileWriterV3(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.FSDataOutputStream ostream,
KeyValue.KVComparator comparator,
HFileContext fileContext)
Constructor that takes a path, creates and closes the output stream.
|
Modifier and Type | Field and Description |
---|---|
private CacheConfig |
HStore.cacheConf |
private CacheConfig |
StoreFile.cacheConf |
private CacheConfig |
StoreFile.WriterBuilder.cacheConf |
protected CacheConfig |
HRegionServer.cacheConfig |
Modifier and Type | Method and Description |
---|---|
(package private) CacheConfig |
StoreFile.getCacheConf() |
CacheConfig |
Store.getCacheConfig()
Used for tests.
|
CacheConfig |
HStore.getCacheConfig() |
CacheConfig |
HRegionServer.getCacheConfig() |
Modifier and Type | Method and Description |
---|---|
StoreFile.Reader |
StoreFileInfo.open(org.apache.hadoop.fs.FileSystem fs,
CacheConfig cacheConf,
boolean canUseDropBehind)
Open a Reader for the StoreFile
|
StoreFile.Reader |
RegionCoprocessorHost.postStoreFileReaderOpen(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r,
StoreFile.Reader reader) |
StoreFile.Reader |
RegionCoprocessorHost.preStoreFileReaderOpen(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r) |
Constructor and Description |
---|
StoreFile.Reader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
CacheConfig cacheConf,
org.apache.hadoop.conf.Configuration conf) |
StoreFile.Reader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
org.apache.hadoop.conf.Configuration conf) |
StoreFile.Writer(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf,
KeyValue.KVComparator comparator,
BloomType bloomType,
long maxKeys,
InetSocketAddress[] favoredNodes,
HFileContext fileContext,
boolean shouldDropCacheBehind)
Creates an HFile.Writer that also write helpful meta data.
|
StoreFile.WriterBuilder(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf,
org.apache.hadoop.fs.FileSystem fs) |
StoreFile(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf,
BloomType cfBloomType)
Constructor, loads a reader and it's indices, etc.
|
StoreFile(org.apache.hadoop.fs.FileSystem fs,
StoreFileInfo fileInfo,
org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf,
BloomType cfBloomType)
Constructor, loads a reader and it's indices, etc.
|
Modifier and Type | Field and Description |
---|---|
private CacheConfig |
BlockCacheViewTmplImpl.cacheConfig |
private CacheConfig |
BlockCacheTmplImpl.cacheConfig |
private CacheConfig |
BlockCacheTmpl.ImplData.m_cacheConfig |
private CacheConfig |
BlockCacheViewTmpl.ImplData.m_cacheConfig |
Modifier and Type | Method and Description |
---|---|
CacheConfig |
BlockCacheTmpl.ImplData.getCacheConfig() |
CacheConfig |
BlockCacheViewTmpl.ImplData.getCacheConfig() |
Modifier and Type | Method and Description |
---|---|
private void |
BlockCacheTmplImpl.__jamon_innerUnit__bc_baseInfo(Writer jamonWriter,
CacheConfig cacheConfig,
String bcUrl,
String bcName) |
private void |
BlockCacheTmplImpl.__jamon_innerUnit__bc_config(Writer jamonWriter,
CacheConfig cacheConfig) |
private void |
BlockCacheTmplImpl.__jamon_innerUnit__bc_stats(Writer jamonWriter,
CacheConfig cacheConfig) |
org.jamon.Renderer |
BlockCacheTmpl.makeRenderer(CacheConfig cacheConfig,
org.apache.hadoop.conf.Configuration config) |
org.jamon.Renderer |
BlockCacheViewTmpl.makeRenderer(CacheConfig cacheConfig,
org.apache.hadoop.conf.Configuration conf,
String bcn,
String bcv) |
void |
BlockCacheTmpl.render(Writer jamonWriter,
CacheConfig cacheConfig,
org.apache.hadoop.conf.Configuration config) |
void |
BlockCacheViewTmpl.render(Writer jamonWriter,
CacheConfig cacheConfig,
org.apache.hadoop.conf.Configuration conf,
String bcn,
String bcv) |
void |
BlockCacheTmpl.renderNoFlush(Writer jamonWriter,
CacheConfig cacheConfig,
org.apache.hadoop.conf.Configuration config) |
void |
BlockCacheViewTmpl.renderNoFlush(Writer jamonWriter,
CacheConfig cacheConfig,
org.apache.hadoop.conf.Configuration conf,
String bcn,
String bcv) |
void |
BlockCacheTmpl.ImplData.setCacheConfig(CacheConfig cacheConfig) |
void |
BlockCacheViewTmpl.ImplData.setCacheConfig(CacheConfig cacheConfig) |
Modifier and Type | Method and Description |
---|---|
static BloomFilterWriter |
BloomFilterFactory.createDeleteBloomAtWrite(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf,
int maxKeys,
HFile.Writer writer)
Creates a new Delete Family Bloom filter at the time of
StoreFile writing. |
static BloomFilterWriter |
BloomFilterFactory.createGeneralBloomAtWrite(org.apache.hadoop.conf.Configuration conf,
CacheConfig cacheConf,
BloomType bloomType,
int maxKeys,
HFile.Writer writer)
Creates a new general (Row or RowCol) Bloom filter at the time of
StoreFile writing. |
Modifier and Type | Field and Description |
---|---|
(package private) CacheConfig |
HFileCorruptionChecker.cacheConf |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.