| /rocksdb-6.9/java/src/test/java/org/rocksdb/util/ |
| D | JNIComparatorTest.java | 56 … final AbstractComparator comparator = builtinComparator == BuiltinComparator.BYTEWISE_COMPARATOR in java_comparator_equals_cpp_comparator()
61 storeWithJavaComparator(javaDbDir, comparator); in java_comparator_equals_cpp_comparator()
62 javaKeys = readAllWithJavaComparator(javaDbDir, comparator); in java_comparator_equals_cpp_comparator()
75 final AbstractComparator comparator) throws RocksDBException { in storeWithJavaComparator() argument
79 .setComparator(comparator); in storeWithJavaComparator()
114 final AbstractComparator comparator) throws RocksDBException { in readAllWithJavaComparator() argument
117 .setComparator(comparator); in readAllWithJavaComparator()
145 final BuiltinComparator comparator) throws RocksDBException { in readAllWithCppComparator() argument
148 .setComparator(comparator); in readAllWithCppComparator()
|
| D | BytewiseComparatorIntTest.java | 110 final BytewiseComparator comparator = new BytewiseComparator(options)) { in javaComparatorDefaultCf()
114 dbFolder.getRoot().getAbsolutePath()), comparator); in javaComparatorDefaultCf() local
125 final BytewiseComparator comparator = new BytewiseComparator(options)) { in javaComparatorNamedCf()
129 dbFolder.getRoot().getAbsolutePath()), comparator); in javaComparatorNamedCf() local
147 final AbstractComparator comparator) throws RocksDBException { in testRoundtrip() argument
150 .setComparator(comparator)) { in testRoundtrip()
197 final AbstractComparator comparator) throws RocksDBException { in testRoundtripCf() argument
203 .setComparator(comparator)) in testRoundtripCf()
|
| D | ReverseBytewiseComparatorIntTest.java | 111 final ReverseBytewiseComparator comparator = in javaComparatorDefaultCf()
116 dbFolder.getRoot().getAbsolutePath()), comparator); in javaComparatorDefaultCf() local
127 final ReverseBytewiseComparator comparator in javaComparatorNamedCf()
132 dbFolder.getRoot().getAbsolutePath()), comparator); in javaComparatorNamedCf() local
150 final AbstractComparator comparator) throws RocksDBException { in testRoundtrip() argument
153 .setComparator(comparator)) { in testRoundtrip()
200 final AbstractComparator comparator) throws RocksDBException { in testRoundtripCf() argument
206 .setComparator(comparator)) in testRoundtripCf()
|
| D | IntComparatorTest.java | 109 final IntComparator comparator = new IntComparator(options)) { in javaComparatorDefaultCf()
113 dbFolder.getRoot().getAbsolutePath()), comparator); in javaComparatorDefaultCf() local
124 final IntComparator comparator = new IntComparator(options)) { in javaComparatorNamedCf()
128 dbFolder.getRoot().getAbsolutePath()), comparator); in javaComparatorNamedCf() local
146 final AbstractComparator comparator) throws RocksDBException { in testRoundtrip() argument
149 .setComparator(comparator)) { in testRoundtrip()
196 final AbstractComparator comparator) throws RocksDBException { in testRoundtripCf() argument
202 .setComparator(comparator)) in testRoundtripCf()
|
| D | BytewiseComparatorTest.java | 81 final AbstractComparator comparator = new BytewiseComparator(copt); in java_vs_java_bytewiseComparator() argument
82 final RocksDB db = openDatabase(dbDir, comparator)) { in java_vs_java_bytewiseComparator()
141 final AbstractComparator comparator = new BytewiseComparator(copt); in java_vs_java_directBytewiseComparator() argument
142 final RocksDB db = openDatabase(dbDir, comparator)) { in java_vs_java_directBytewiseComparator()
201 final AbstractComparator comparator = new ReverseBytewiseComparator(copt); in java_vs_java_reverseBytewiseComparator() argument
202 final RocksDB db = openDatabase(dbDir, comparator)) { in java_vs_java_reverseBytewiseComparator()
393 private final java.util.Comparator<? super K> comparator;
402 this.comparator = map.comparator();
425 if(comparator.compare(entries.get(offset).getKey(),
436 if(comparator.compare(entries.get(offset).getKey(),
|
| /rocksdb-6.9/table/block_based/ |
| D | index_builder.cc | 29 const InternalKeyComparator* comparator, in CreateIndexBuilder() argument
37 comparator, table_opt.index_block_restart_interval, in CreateIndexBuilder()
46 comparator, int_key_slice_transform, in CreateIndexBuilder()
52 comparator, use_value_delta_encoding, table_opt); in CreateIndexBuilder()
56 comparator, table_opt.index_block_restart_interval, in CreateIndexBuilder()
68 const InternalKeyComparator* comparator, in CreateIndexBuilder() argument
71 return new PartitionedIndexBuilder(comparator, table_opt, in CreateIndexBuilder()
76 const InternalKeyComparator* comparator, in PartitionedIndexBuilder() argument
79 : IndexBuilder(comparator), in PartitionedIndexBuilder()
|
| D | index_builder.h | 39 const ROCKSDB_NAMESPACE::InternalKeyComparator* comparator,
52 explicit IndexBuilder(const InternalKeyComparator* comparator) in IndexBuilder() argument
53 : comparator_(comparator) {} in IndexBuilder()
124 const InternalKeyComparator* comparator, in ShortenedIndexBuilder() argument
129 : IndexBuilder(comparator), in ShortenedIndexBuilder()
258 const InternalKeyComparator* comparator, in HashIndexBuilder() argument
263 : IndexBuilder(comparator), in HashIndexBuilder()
264 primary_index_builder_(comparator, index_block_restart_interval, in HashIndexBuilder()
368 const ROCKSDB_NAMESPACE::InternalKeyComparator* comparator,
372 explicit PartitionedIndexBuilder(const InternalKeyComparator* comparator,
|
| D | block_test.cc | 101 options.comparator, options.comparator, kDisableGlobalSequenceNumber); in TEST_F()
114 iter = reader.NewDataIterator(options.comparator, options.comparator, in TEST_F()
385 options.comparator, options.comparator, kDisableGlobalSequenceNumber, in TEST_F()
417 options.comparator, options.comparator, kDisableGlobalSequenceNumber, in TEST_F()
452 options.comparator, options.comparator, kDisableGlobalSequenceNumber, in TEST_F()
577 options.comparator, options.comparator, kDisableGlobalSequenceNumber, in TEST_P()
598 iter = reader.NewIndexIterator(options.comparator, options.comparator, in TEST_P()
|
| D | block.h | 190 DataBlockIter* NewDataIterator(const Comparator* comparator,
209 IndexBlockIter* NewIndexIterator(const Comparator* comparator,
234 void InitializeBase(const Comparator* comparator, const char* data, in InitializeBase() argument
240 comparator_ = comparator; in InitializeBase()
364 DataBlockIter(const Comparator* comparator, const Comparator* user_comparator, in DataBlockIter() argument
370 Initialize(comparator, user_comparator, data, restarts, num_restarts, in DataBlockIter()
374 void Initialize(const Comparator* comparator, in Initialize() argument
381 InitializeBase(comparator, data, restarts, num_restarts, global_seqno, in Initialize()
494 void Initialize(const Comparator* comparator, in Initialize() argument
500 InitializeBase(key_includes_seq ? comparator : user_comparator, data, in Initialize()
|
| D | partitioned_filter_block.cc | 194 const InternalKeyComparator* const comparator = internal_comparator(); in GetFilterPartitionHandle() local
197 comparator, comparator->user_comparator(), in GetFilterPartitionHandle()
320 const InternalKeyComparator* const comparator = internal_comparator(); in CacheDependencies() local
323 comparator, comparator->user_comparator(), in CacheDependencies()
|
| D | full_filter_block.cc | 286 const SliceTransform* prefix_extractor, const Comparator* comparator, in RangeMayExist() argument
296 !IsFilterCompatible(iterate_upper_bound, prefix, comparator)) { in RangeMayExist()
309 const Comparator* comparator) const { in IsFilterCompatible()
320 if (!comparator->Equal(prefix, upper_bound_xform)) { in IsFilterCompatible()
328 !comparator->IsSameLengthImmediateSuccessor(prefix, in IsFilterCompatible()
|
| D | data_block_hash_index_test.cc | 404 options.comparator->Compare(iter->key(), ikey.Encode().ToString()), 0); in TEST()
418 ASSERT_EQ(options.comparator->Compare(ExtractUserKey(iter->key()), ukey), in TEST()
548 const InternalKeyComparator internal_comparator(options.comparator); in TestBoundary()
608 options.comparator = BytewiseComparator(); in TEST()
632 GetContext get_context(options.comparator, nullptr, nullptr, nullptr, in TEST()
657 GetContext get_context(options.comparator, nullptr, nullptr, nullptr, in TEST()
682 GetContext get_context(options.comparator, nullptr, nullptr, nullptr, in TEST()
707 GetContext get_context(options.comparator, nullptr, nullptr, nullptr, in TEST()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | AbstractComparatorJniBridge.java | 42 final AbstractComparator comparator, in compareInternal() argument
54 final int c = comparator.compare(a, b); in compareInternal()
87 final AbstractComparator comparator, in findShortestSeparatorInternal() argument
96 comparator.findShortestSeparator(start, limit); in findShortestSeparatorInternal()
117 final AbstractComparator comparator, in findShortSuccessorInternal() argument
122 comparator.findShortSuccessor(key); in findShortSuccessorInternal()
|
| D | SstFileWriter.java | 33 final AbstractComparator comparator) { in SstFileWriter() argument
35 envOptions.nativeHandle_, options.nativeHandle_, comparator.nativeHandle_, in SstFileWriter()
36 comparator.getComparatorType().getValue())); in SstFileWriter()
|
| /rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/jmh/ |
| D | ComparatorBenchmarks.java | 51 AbstractComparator comparator; field in ComparatorBenchmarks
97 comparator = new BytewiseComparator(comparatorOptions); in setup()
99 comparator = new ReverseBytewiseComparator(comparatorOptions); in setup()
102 options.setComparator(comparator); in setup()
114 if (comparator != null) { in cleanup()
115 comparator.close(); in cleanup()
|
| /rocksdb-6.9/table/ |
| D | iter_heap.h | 18 MaxIteratorComparator(const InternalKeyComparator* comparator) in MaxIteratorComparator() argument
19 : comparator_(comparator) {} in MaxIteratorComparator()
32 MinIteratorComparator(const InternalKeyComparator* comparator) in MinIteratorComparator() argument
33 : comparator_(comparator) {} in MinIteratorComparator()
|
| D | table_test.cc | 570 options.comparator = comparator_; in NewDB()
1461 options.comparator = &reverse_key_comparator; in TEST_P()
1805 options.comparator = BytewiseComparator(); in TEST_P()
1809 TableConstructor c(options.comparator); in TEST_P()
1846 options.comparator = BytewiseComparator(); in TEST_P()
1850 TableConstructor c(options.comparator); in TEST_P()
3347 InternalKeyComparator ikc(options.comparator); in TEST_F()
3400 InternalKeyComparator ikc(options.comparator); in TEST_F()
4477 metaindex_block.NewDataIterator(options.comparator, options.comparator, in TEST_P()
4571 options.comparator = BytewiseComparator(); in TEST_P()
[all …]
|
| /rocksdb-6.9/util/ |
| D | comparator.cc.d | 1 util/comparator.cc.d util/comparator.o: util/comparator.cc \
2 include/rocksdb/comparator.h include/rocksdb/rocksdb_namespace.h \
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | OptimisticTransactionOptionsTest.java | 30 public void comparator() { in comparator() method in OptimisticTransactionOptionsTest
34 final AbstractComparator comparator = new BytewiseComparator(copt)) { in comparator()
35 opt.setComparator(comparator); in comparator()
|
| D | SstFileWriterTest.java | 66 BytewiseComparator comparator = null; in newSstFile() local
69 comparator = new BytewiseComparator(comparatorOptions); in newSstFile()
70 options.setComparator(comparator); in newSstFile()
133 if (comparator != null) { in newSstFile()
134 comparator.close(); in newSstFile()
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index.cc | 36 const Comparator* comparator, in BaseDeltaIterator() argument
44 comparator_(comparator), in BaseDeltaIterator()
438 comparator(index_comparator, &write_batch), in Rep()
439 skip_list(comparator, &arena), in Rep()
445 WriteBatchEntryComparator comparator; member
521 comparator.SetComparatorForCF(cf_id, cf_cmp); in AddOrUpdateIndex()
560 new (&skip_list) WriteBatchEntrySkipList(comparator, &arena); in ClearIndex()
679 rep->comparator.default_comparator()); in NewIteratorWithBase()
774 &rep->comparator, value, rep->overwrite_key, &s); in GetFromBatch()
859 &rep->comparator, &batch_value, rep->overwrite_key, &s); in GetFromBatchAndDB()
[all …]
|
| /rocksdb-6.9/db/ |
| D | import_column_family_test.cc | 97 metadata.db_comparator_name = options.comparator->Name(); in TEST_F()
118 metadata.db_comparator_name = options.comparator->Name(); in TEST_F()
206 metadata.db_comparator_name = options.comparator->Name(); in TEST_F()
480 metadata.db_comparator_name = options.comparator->Name(); in TEST_F()
493 mismatch_options.comparator = ReverseBytewiseComparator(); in TEST_F()
504 metadata.db_comparator_name = mismatch_options.comparator->Name(); in TEST_F()
529 metadata.db_comparator_name = options.comparator->Name(); in TEST_F()
540 metadata.db_comparator_name = options.comparator->Name(); in TEST_F()
|
| D | table_properties_collector_test.cc | 349 test::PlainInternalKeyComparator ikc(options.comparator); in TEST_P()
395 test::PlainInternalKeyComparator pikc(options.comparator); in TestInternalKeyPropertiesCollector()
405 auto comparator = options.comparator; in TestInternalKeyPropertiesCollector() local
413 options.comparator = comparator; in TestInternalKeyPropertiesCollector()
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util_test.cc | 318 test::SimpleSuffixReverseComparator comparator; in TEST_F() local
320 auto* prev_comparator = cf_descs[2].options.comparator; in TEST_F()
321 cf_descs[2].options.comparator = &comparator; in TEST_F()
325 cf_descs[2].options.comparator = prev_comparator; in TEST_F()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | sst_file_writerjni.cc | 28 ROCKSDB_NAMESPACE::Comparator *comparator = nullptr; in Java_org_rocksdb_SstFileWriter_newSstFileWriter__JJJB() local
32 comparator = reinterpret_cast<ROCKSDB_NAMESPACE::ComparatorJniCallback *>( in Java_org_rocksdb_SstFileWriter_newSstFileWriter__JJJB()
38 comparator = in Java_org_rocksdb_SstFileWriter_newSstFileWriter__JJJB()
47 new ROCKSDB_NAMESPACE::SstFileWriter(*env_options, *options, comparator); in Java_org_rocksdb_SstFileWriter_newSstFileWriter__JJJB()
|