Package | Description |
---|---|
org.apache.hadoop.hbase.mob | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.compactions |
Modifier and Type | Method and Description |
---|---|
static StoreFile.Writer |
MobUtils.createDelFileWriter(Configuration conf,
FileSystem fs,
HColumnDescriptor family,
java.lang.String date,
Path basePath,
long maxKeyCount,
Compression.Algorithm compression,
byte[] startKey,
CacheConfig cacheConfig,
Encryption.Context cryptoContext)
Creates a writer for the del file in temp directory.
|
static StoreFile.Writer |
MobUtils.createRefFileWriter(Configuration conf,
FileSystem fs,
HColumnDescriptor family,
Path basePath,
long maxKeyCount,
CacheConfig cacheConfig,
Encryption.Context cryptoContext)
Creates a writer for the ref file in temp directory.
|
static StoreFile.Writer |
MobUtils.createWriter(Configuration conf,
FileSystem fs,
HColumnDescriptor family,
java.lang.String date,
Path basePath,
long maxKeyCount,
Compression.Algorithm compression,
byte[] startKey,
CacheConfig cacheConfig,
Encryption.Context cryptoContext)
Creates a writer for the mob file in temp directory.
|
static StoreFile.Writer |
MobUtils.createWriter(Configuration conf,
FileSystem fs,
HColumnDescriptor family,
java.lang.String date,
Path basePath,
long maxKeyCount,
Compression.Algorithm compression,
java.lang.String startKey,
CacheConfig cacheConfig,
Encryption.Context cryptoContext)
Creates a writer for the mob file in temp directory.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultMobStoreFlusher.performMobFlush(MemStoreSnapshot snapshot,
long cacheFlushId,
InternalScanner scanner,
StoreFile.Writer writer,
MonitoredTask status)
Flushes the cells in the mob store.
|
protected static void |
MobTestUtil.writeStoreFile(StoreFile.Writer writer,
java.lang.String caseName) |
Modifier and Type | Field and Description |
---|---|
protected java.util.List<StoreFile.Writer> |
StripeMultiFileWriter.existingWriters |
Modifier and Type | Method and Description |
---|---|
StoreFile.Writer |
StoreFile.WriterBuilder.build()
Create a store file writer.
|
StoreFile.Writer |
HMobStore.createDelFileWriterInTmp(java.util.Date date,
long maxKeyCount,
Compression.Algorithm compression,
byte[] startKey)
Creates the writer for the del file in temp directory.
|
StoreFile.Writer |
AbstractMultiFileWriter.WriterFactory.createWriter() |
StoreFile.Writer |
HMobStore.createWriterInTmp(java.util.Date date,
long maxKeyCount,
Compression.Algorithm compression,
byte[] startKey)
Creates the writer for the mob file in temp directory.
|
StoreFile.Writer |
HStore.createWriterInTmp(long maxKeyCount,
Compression.Algorithm compression,
boolean isCompaction,
boolean includeMVCCReadpoint,
boolean includesTag) |
StoreFile.Writer |
Store.createWriterInTmp(long maxKeyCount,
Compression.Algorithm compression,
boolean isCompaction,
boolean includeMVCCReadpoint,
boolean includesTags) |
StoreFile.Writer |
HMobStore.createWriterInTmp(MobFileName mobFileName,
Path basePath,
long maxKeyCount,
Compression.Algorithm compression)
Creates the writer for the mob file in temp directory.
|
StoreFile.Writer |
HMobStore.createWriterInTmp(java.lang.String date,
Path basePath,
long maxKeyCount,
Compression.Algorithm compression,
byte[] startKey)
Creates the writer for the mob file in temp directory.
|
Modifier and Type | Method and Description |
---|---|
protected abstract java.util.Collection<StoreFile.Writer> |
AbstractMultiFileWriter.writers() |
protected java.util.Collection<StoreFile.Writer> |
DateTieredMultiFileWriter.writers() |
protected java.util.Collection<StoreFile.Writer> |
StripeMultiFileWriter.writers() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMultiFileWriter.preCloseWriter(StoreFile.Writer writer)
Subclasses override this method to be called before we close the give writer.
|
protected void |
StripeMultiFileWriter.preCloseWriter(StoreFile.Writer writer) |
Modifier and Type | Method and Description |
---|---|
StoreFile.Writer |
TestCompactor.StoreFileWritersCapture.answer(InvocationOnMock invocation) |
protected StoreFile.Writer |
Compactor.createTmpWriter(Compactor.FileDetails fd,
boolean shouldDropBehind)
Creates a writer for a new file in a temporary directory.
|
protected StoreFile.Writer |
DefaultCompactor.createTmpWriter(Compactor.FileDetails fd,
long smallestReadPoint)
Creates a writer for a new file in a temporary directory.
|
StoreFile.Writer |
TestCompactor.StoreFileWritersCapture.createWriter() |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultCompactor.abortWriter(StoreFile.Writer writer) |
protected void |
Compactor.appendMetadataAndCloseWriter(StoreFile.Writer writer,
Compactor.FileDetails fd,
boolean isMajor)
Appends the metadata and closes the writer.
|
protected java.util.List<Path> |
DefaultCompactor.commitWriter(StoreFile.Writer writer,
Compactor.FileDetails fd,
CompactionRequest request) |