| 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,
                   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,
            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,
            String date,
            Path basePath,
            long maxKeyCount,
            Compression.Algorithm compression,
            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,
              String caseName)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected 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(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(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(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 Collection<StoreFile.Writer> | 
AbstractMultiFileWriter.writers()  | 
protected Collection<StoreFile.Writer> | 
DateTieredMultiFileWriter.writers()  | 
protected 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)  | 
static void | 
TestStoreFile.writeStoreFile(StoreFile.Writer writer,
              byte[] fam,
              byte[] qualifier)  | 
| 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 List<Path> | 
DefaultCompactor.commitWriter(StoreFile.Writer writer,
            Compactor.FileDetails fd,
            CompactionRequest request)  |