| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | StripeStoreFileManager.java | 299 Collection<StoreFile> compactedFiles, Collection<StoreFile> results) throws IOException { in addCompactionResults() argument
301 LOG.debug("Attempting to merge compaction results: " + compactedFiles.size() in addCompactionResults()
306 cmc.mergeResults(compactedFiles, results); in addCompactionResults()
650 private Collection<StoreFile> compactedFiles = null; field in StripeStoreFileManager.CompactionOrFlushMergeCopy
663 public void mergeResults(Collection<StoreFile> compactedFiles, Collection<StoreFile> results) in mergeResults() argument
665 assert this.compactedFiles == null && this.results == null; in mergeResults()
666 this.compactedFiles = compactedFiles; in mergeResults()
696 if (!isFlush) newAllFiles.removeAll(compactedFiles); in createNewState()
705 for (StoreFile sf : this.compactedFiles) { in updateMetadataMaps()
787 for (StoreFile oldFile : this.compactedFiles) { in removeCompactedFiles()
|
| H A D | DefaultStoreFileManager.java | 98 Collection<StoreFile> compactedFiles, Collection<StoreFile> results) { in addCompactionResults() argument
100 newStoreFiles.removeAll(compactedFiles); in addCompactionResults()
|
| H A D | StoreFileManager.java | 61 Collection<StoreFile> compactedFiles, Collection<StoreFile> results) throws IOException; in addCompactionResults() argument
|
| H A D | HStore.java | 1324 void replaceStoreFiles(final Collection<StoreFile> compactedFiles, in replaceStoreFiles() argument
1328 this.storeEngine.getStoreFileManager().addCompactionResults(compactedFiles, result); in replaceStoreFiles()
1329 filesCompacting.removeAll(compactedFiles); // safe bc: lock.writeLock(); in replaceStoreFiles()
1751 protected void completeCompaction(final Collection<StoreFile> compactedFiles) in completeCompaction() argument
1753 completeCompaction(compactedFiles, true); in completeCompaction()
1772 protected void completeCompaction(final Collection<StoreFile> compactedFiles, boolean removeFiles) in completeCompaction() argument
1786 for (StoreFile compactedFile : compactedFiles) { in completeCompaction()
1790 this.fs.removeStoreFiles(this.getColumnFamilyName(), compactedFiles); in completeCompaction() local
1795 ". Files we were trying to remove are " + compactedFiles.toString() + in completeCompaction()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/ |
| H A D | HFileArchiver.java | 195 Path tableDir, byte[] family, Collection<StoreFile> compactedFiles) throws IOException { in archiveStoreFiles() argument
201 deleteStoreFilesWithoutArchiving(compactedFiles); in archiveStoreFiles()
206 if (compactedFiles.size() == 0) { in archiveStoreFiles()
228 Collection<File> storeFiles = Collections2.transform(compactedFiles, getStorePath); in archiveStoreFiles()
471 private static void deleteStoreFilesWithoutArchiving(Collection<StoreFile> compactedFiles) in deleteStoreFilesWithoutArchiving() argument
475 for (StoreFile hsf : compactedFiles) { in deleteStoreFilesWithoutArchiving()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/ |
| H A D | TestIOFencing.java | 200 protected void completeCompaction(final Collection<StoreFile> compactedFiles, in completeCompaction() argument
208 super.completeCompaction(compactedFiles, removeFiles); in completeCompaction()
211 protected void completeCompaction(Collection<StoreFile> compactedFiles) throws IOException { in completeCompaction() argument
218 super.completeCompaction(compactedFiles); in completeCompaction()
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1225 final List<String> compactedFiles = in compactFiles() local
1228 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1275 final List<String> compactedFiles = in compactFiles() local
1278 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1275 final List<String> compactedFiles = in compactFiles() local
1278 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1275 final List<String> compactedFiles =
1278 assertThat(compactedFiles).isNotEmpty();
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1275 final List<String> compactedFiles = in compactFiles() local
1278 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1275 final List<String> compactedFiles = in compactFiles() local
1278 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1275 final List<String> compactedFiles = in compactFiles() local
1278 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1345 final List<String> compactedFiles = in compactFiles() local
1348 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/rocksdb/rocksdb-6.26.1/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1345 final List<String> compactedFiles = in compactFiles() local
1348 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1345 final List<String> compactedFiles = in compactFiles() local
1348 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1345 final List<String> compactedFiles = in compactFiles() local
1348 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RocksDBTest.java | 1345 final List<String> compactedFiles = in compactFiles() local
1348 assertThat(compactedFiles).isNotEmpty(); in compactFiles()
|