Searched defs:importer (Results 1 - 5 of 5) sorted by relevance

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DID2ChildrenCount.java107 void importPut(Importer importer, EntryID entryID, long total) argument
110 importPut0(importer, entryID, total);
113 void importPutTotalCount(Importer importer, long total) argument
115 importPut0(importer, TOTAL_COUNT_ENTRY_ID, total);
118 private void importPut0(Importer importer, EntryID entryID, final long delta) argument
120 counter.importPut(importer, toKey(entryID), delta);
H A DShardedCounter.java109 void importPut(Importer importer, ByteSequence key, long delta) argument
113 importer.put(getName(), getShardedKey(key), encodeValue(delta));
H A DTracedStorage.java197 private final Importer importer; field in class:TracedStorage.TracedImporter
199 private TracedImporter(final Importer importer) argument
201 this.importer = importer;
218 importer.clearTree(name);
226 importer.put(name, key, value);
234 final ByteString value = importer.read(name, key);
243 importer.close();
256 SequentialCursor<ByteString, ByteString> cursor = importer.openCursor(name);
521 final Importer importer
[all...]
H A DVLVIndex.java178 void importCount(Importer importer, long count) argument
180 counter.importPut(importer, COUNT_KEY, count);
H A DOnDiskMergeImporter.java150 * {@link RootContainer} with this importer inner workings.
196 final OnDiskMergeImporter importer;
211 importer = new OnDiskMergeImporter(PHASE2_IMPORTER_THREAD_NAME, importStrategy);
212 importer.doImport(source);
218 logger.info(NOTE_IMPORT_PHASE_STATS, importer.getTotalTimeInMillis() / 1000, importer.getPhaseOneTimeInMillis()
219 / 1000, importer.getPhaseTwoTimeInMillis() / 1000);
227 logger.info(NOTE_IMPORT_FINAL_STATUS, source.getEntriesRead(), importer.getImportedCount(), source
310 final OnDiskMergeImporter importer;
317 importer
688 private final Importer importer; field in class:OnDiskMergeImporter.ID2EntrySource
694 ID2EntrySource(EntryContainer entryContainer, Importer importer, String threadNameTemplate, int nbThread, long nbTotalEntries) argument
935 protected final Importer importer; field in class:OnDiskMergeImporter.AbstractTwoPhaseImportStrategy
939 AbstractTwoPhaseImportStrategy(Collection<EntryContainer> entryContainers, Importer importer, File tempDir, BufferPool bufferPool, Executor sorter) argument
1028 SortAndImportWithoutDNValidation(Collection<EntryContainer> entryContainers, Importer importer, File tempDir, BufferPool bufferPool, Executor sorter) argument
1083 SortAndImportWithDNValidation(Collection<EntryContainer> entryContainers, Importer importer, File tempDir, BufferPool bufferPool, Executor sorter) argument
1167 RebuildIndexStrategy(Collection<EntryContainer> entryContainers, Importer importer, File tempDir, BufferPool bufferPool, Executor sorter, Collection<String> indexNames) argument
2202 asChunk(TreeName treeName, Importer importer) argument
2280 private final Importer importer; field in class:OnDiskMergeImporter.DN2IDImporterTask
2289 DN2IDImporterTask(PhaseTwoProgressReporter progressReporter, Importer importer, File tempDir, BufferPool bufferPool, DN2ID dn2id, Chunk dn2IdChunk, ID2ChildrenCount id2count, Collector<?, ByteString> id2countCollector, boolean dn2idAlreadyImported) argument
2332 private final Importer importer; field in class:OnDiskMergeImporter.DN2IDImporterTask.ID2CountTreeVisitorImporter
2334 ID2CountTreeVisitorImporter(Importer importer) argument
2386 private final Importer importer; field in class:OnDiskMergeImporter.ImporterToChunkAdapter
2389 ImporterToChunkAdapter(TreeName treeName, Importer importer) argument
3452 setTrust(boolean trustValue, Importer importer) argument
3493 deleteDatabase(Importer importer) argument
3501 private final Importer importer; field in class:OnDiskMergeImporter.DeleteDatabase
3503 DeleteDatabase(Importer importer) argument
3698 asWriteableTransaction(Importer importer) argument
3706 private final Importer importer; field in class:OnDiskMergeImporter.ImporterToWriteableTransactionAdapter
3708 ImporterToWriteableTransactionAdapter(Importer importer) argument
[all...]

Completed in 34 milliseconds