Home
last modified time | relevance | path

Searched refs:ValueType (Results 1 – 25 of 48) sorted by relevance

12

/rocksdb-6.9/java/src/main/java/org/rocksdb/
DMutableColumnFamilyOptions.java83 write_buffer_size(ValueType.LONG),
84 arena_block_size(ValueType.LONG),
94 private final ValueType valueType;
100 public ValueType getValueType() { in getValueType()
114 max_compaction_bytes(ValueType.LONG),
120 ttl(ValueType.LONG);
122 private final ValueType valueType;
128 public ValueType getValueType() { in getValueType()
137 compression_type(ValueType.ENUM);
139 private final ValueType valueType;
[all …]
DMutableDBOptions.java83 max_background_jobs(ValueType.INT),
88 delayed_write_rate(ValueType.LONG),
89 max_total_wal_size(ValueType.LONG),
91 stats_dump_period_sec(ValueType.INT),
92 stats_persist_period_sec(ValueType.INT),
94 max_open_files(ValueType.INT),
95 bytes_per_sync(ValueType.LONG),
96 wal_bytes_per_sync(ValueType.LONG),
100 private final ValueType valueType;
101 DBOption(final ValueType valueType) { in DBOption()
[all …]
DAbstractMutableOptions.java98 if (key.getValueType() != MutableOptionKey.ValueType.DOUBLE) { in setDouble()
117 if(key.getValueType() != MutableOptionKey.ValueType.LONG) { in setLong()
136 if(key.getValueType() != MutableOptionKey.ValueType.INT) { in setInt()
155 if(key.getValueType() != MutableOptionKey.ValueType.BOOLEAN) { in setBoolean()
174 if(key.getValueType() != MutableOptionKey.ValueType.INT_ARRAY) { in setIntArray()
193 if(key.getValueType() != MutableOptionKey.ValueType.ENUM) { in setEnum()
DMutableOptionKey.java5 enum ValueType { enum
15 ValueType getValueType(); in getValueType()
/rocksdb-6.9/db/
Dexternal_sst_file_basic_test.cc507 {ValueType::kTypeValue, ValueType::kTypeMerge, ValueType::kTypeValue, in TEST_P()
508 ValueType::kTypeMerge, ValueType::kTypeValue, ValueType::kTypeMerge}, in TEST_P()
516 {ValueType::kTypeValue, ValueType::kTypeMerge, ValueType::kTypeValue, in TEST_P()
525 {ValueType::kTypeDeletion, ValueType::kTypeValue, in TEST_P()
534 {ValueType::kTypeDeletion, ValueType::kTypeMerge, in TEST_P()
557 {ValueType::kTypeValue, ValueType::kTypeMerge, in TEST_P()
566 {ValueType::kTypeValue, ValueType::kTypeMerge, ValueType::kTypeValue}, in TEST_P()
574 {ValueType::kTypeValue, ValueType::kTypeMerge, in TEST_P()
590 {ValueType::kTypeValue, ValueType::kTypeMerge, ValueType::kTypeValue}, in TEST_P()
598 {ValueType::kTypeValue, ValueType::kTypeDeletion, in TEST_P()
[all …]
Ddbformat.h44 enum ValueType : unsigned char { enum
76 extern const ValueType kValueTypeForSeek;
77 extern const ValueType kValueTypeForSeekForPrev;
81 inline bool IsValueType(ValueType t) { in IsValueType()
87 inline bool IsExtendedValueType(ValueType t) { in IsExtendedValueType()
102 ValueType type;
131 EntryType GetEntryType(ValueType value_type);
146 ValueType t);
186 return static_cast<ValueType>(c); in ExtractValueType()
302 result->type = static_cast<ValueType>(c); in ParseInternalKey()
[all …]
Dtable_properties_collector_test.cc249 std::map<std::pair<std::string, ValueType>, std::string> kvs = { in TestCustomizedTablePropertiesCollector()
380 InternalKey("A ", 0, ValueType::kTypeValue), in TestInternalKeyPropertiesCollector()
381 InternalKey("B ", 1, ValueType::kTypeValue), in TestInternalKeyPropertiesCollector()
382 InternalKey("C ", 2, ValueType::kTypeValue), in TestInternalKeyPropertiesCollector()
383 InternalKey("W ", 3, ValueType::kTypeDeletion), in TestInternalKeyPropertiesCollector()
384 InternalKey("X ", 4, ValueType::kTypeDeletion), in TestInternalKeyPropertiesCollector()
385 InternalKey("Y ", 5, ValueType::kTypeDeletion), in TestInternalKeyPropertiesCollector()
386 InternalKey("Z ", 6, ValueType::kTypeDeletion), in TestInternalKeyPropertiesCollector()
387 InternalKey("a ", 7, ValueType::kTypeSingleDeletion), in TestInternalKeyPropertiesCollector()
388 InternalKey("b ", 8, ValueType::kTypeMerge), in TestInternalKeyPropertiesCollector()
[all …]
Ddbformat.cc26 const ValueType kValueTypeForSeek = kTypeBlobIndex;
27 const ValueType kValueTypeForSeekForPrev = kTypeDeletion;
29 uint64_t PackSequenceAndType(uint64_t seq, ValueType t) { in PackSequenceAndType()
35 EntryType GetEntryType(ValueType value_type) { in GetEntryType()
65 void UnPackSequenceAndType(uint64_t packed, uint64_t* seq, ValueType* t) { in UnPackSequenceAndType()
67 *t = static_cast<ValueType>(packed & 0xff); in UnPackSequenceAndType()
88 ValueType t) { in AppendInternalKeyFooter()
Ddbformat_test.cc18 ValueType vt) { in IKey()
38 ValueType vt) { in TestKey()
179 ValueType new_val_type = kTypeDeletion; in TEST_F()
Dmemtable.cc471 bool MemTable::Add(SequenceNumber s, ValueType type, in Add()
654 ValueType type; in SaveValue()
966 ValueType type; in Update()
1025 ValueType type; in UpdateCallback()
1098 ValueType type; in CountSuccessiveMergeEntries()
Ddb_iter_stress_test.cc45 ValueType type; // kTypeValue, kTypeDeletion, kTypeMerge
438 for (ValueType prevalent_entry_type : in TEST_F()
464 const ValueType types[] = {kTypeValue, kTypeDeletion, in TEST_F()
Drange_del_aggregator.cc286 static_cast<ValueType>(0)); in IsRangeOverlapped()
287 ParsedInternalKey end_ikey(end, 0, static_cast<ValueType>(0)); in IsRangeOverlapped()
Dexternal_sst_file_ingestion_job.cc466 InternalKey("", 0, ValueType::kTypeValue); in GetIngestedFileInfo()
468 InternalKey("", 0, ValueType::kTypeValue); in GetIngestedFileInfo()
/rocksdb-6.9/table/
Dsst_file_writer.cc62 const ValueType value_type) { in Add()
80 case ValueType::kTypeValue: in Add()
82 ValueType::kTypeValue /* Put */); in Add()
84 case ValueType::kTypeMerge: in Add()
86 ValueType::kTypeMerge /* Merge */); in Add()
88 case ValueType::kTypeDeletion: in Add()
90 ValueType::kTypeDeletion /* Delete */); in Add()
262 return rep_->Add(user_key, value, ValueType::kTypeValue); in Add()
266 return rep_->Add(user_key, value, ValueType::kTypeValue); in Put()
270 return rep_->Add(user_key, value, ValueType::kTypeMerge); in Merge()
[all …]
Dmerger_test.cc28 ValueType::kTypeValue); in GenerateStrings()
48 ValueType::kTypeValue); in SeekToRandom()
Dget_context.cc21 void appendToReplayLog(std::string* replay_log, ValueType type, Slice value) { in appendToReplayLog()
364 auto type = static_cast<ValueType>(*s.data()); in replayGetContextLog()
/rocksdb-6.9/table/block_based/
Dblock.cc365 if (value_type != ValueType::kTypeValue && in SeekForGetImpl()
366 value_type != ValueType::kTypeDeletion && in SeekForGetImpl()
367 value_type != ValueType::kTypeSingleDeletion && in SeekForGetImpl()
368 value_type != ValueType::kTypeBlobIndex) { in SeekForGetImpl()
540 assert(value_type == ValueType::kTypeValue || in ParseNextDataKey()
541 value_type == ValueType::kTypeMerge || in ParseNextDataKey()
542 value_type == ValueType::kTypeDeletion || in ParseNextDataKey()
649 assert(value_type == ValueType::kTypeValue || in DecodeCurrentValue()
650 value_type == ValueType::kTypeMerge || in DecodeCurrentValue()
651 value_type == ValueType::kTypeDeletion || in DecodeCurrentValue()
[all …]
Dpartitioned_filter_block_test.cc169 auto ikey = InternalKey(key, 0, ValueType::kTypeValue); in VerifyReader()
177 auto ikey = InternalKey(keys[0], 0, ValueType::kTypeValue); in VerifyReader()
185 auto ikey = InternalKey(key, 0, ValueType::kTypeValue); in VerifyReader()
263 std::string(*InternalKey(user_key, 0, ValueType::kTypeValue).rep()); in CutABlock()
272 std::string(*InternalKey(user_key, 0, ValueType::kTypeValue).rep()); in CutABlock()
274 *InternalKey(next_user_key, 0, ValueType::kTypeValue).rep()); in CutABlock()
341 auto ikey = InternalKey(key, 0, ValueType::kTypeValue); in TEST_P()
351 auto ikey = InternalKey(key, 0, ValueType::kTypeValue); in TEST_P()
389 auto ikey = InternalKey(prefix, 0, ValueType::kTypeValue); in TEST_P()
/rocksdb-6.9/include/rocksdb/
Dcompaction_filter.h37 enum ValueType { enum
157 virtual Decision FilterV2(int level, const Slice& key, ValueType value_type, in FilterV2()
161 case ValueType::kValue: { in FilterV2()
169 case ValueType::kMergeOperand: { in FilterV2()
173 case ValueType::kBlobIndex: in FilterV2()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator_test.cc44 Decision FilterV2(int /*level*/, const Slice& key, ValueType /*type*/, in FilterV2() argument
378 Decision FilterV2(int /*level*/, const Slice& key, ValueType t, in TEST_P()
387 EXPECT_EQ(ValueType::kValue, t); in TEST_P()
392 EXPECT_EQ(ValueType::kValue, t); in TEST_P()
398 EXPECT_EQ(ValueType::kMergeOperand, t); in TEST_P()
404 EXPECT_EQ(ValueType::kMergeOperand, t); in TEST_P()
408 EXPECT_EQ(ValueType::kMergeOperand, t); in TEST_P()
414 EXPECT_EQ(ValueType::kValue, t); in TEST_P()
419 EXPECT_EQ(ValueType::kMergeOperand, t); in TEST_P()
570 EXPECT_EQ(ValueType::kMergeOperand, t); in TEST_P()
[all …]
Dcompaction_iterator.cc196 CompactionFilter::ValueType value_type = in InvokeFilterIfNeeded()
197 ikey_.type == kTypeValue ? CompactionFilter::ValueType::kValue in InvokeFilterIfNeeded()
198 : CompactionFilter::ValueType::kBlobIndex; in InvokeFilterIfNeeded()
/rocksdb-6.9/utilities/cassandra/
Dcassandra_compaction_filter.cc19 int /*level*/, const Slice& /*key*/, ValueType value_type, in FilterV2()
30 if (value_type == ValueType::kValue) { in FilterV2()
Dcassandra_compaction_filter.h33 virtual Decision FilterV2(int level, const Slice& key, ValueType value_type,
/rocksdb-6.9/tools/
Dsst_dump_test.cc31 InternalKey key(std::string(buf), 0, ValueType::kTypeValue); in MakeKey()
38 InternalKey key(std::string(buf), 0, ValueType::kTypeValue); in MakeValue()
/rocksdb-6.9/utilities/blob_db/
Dblob_compaction_filter.h52 Decision FilterV2(int /*level*/, const Slice& key, ValueType value_type,

12