summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHui Xiao <huixiao@fb.com>2024-02-05 13:35:19 -0800
committerFacebook GitHub Bot <facebook-github-bot@users.noreply.github.com>2024-02-05 13:35:19 -0800
commit1a885fe73078e6c195cd6d5cd98e6b62c8567a8c (patch)
tree97145b1286c623f94a15d1c6fc83ae0d8dfd7040
parent3a287796e3e6533f0f9d46cf13c2b0e97e7c3cdd (diff)
Remove deprecated Options::access_hint_on_compaction_start (#11654)
Summary: **Context:** `Options::access_hint_on_compaction_start ` is marked deprecated and now ready to be removed. Pull Request resolved: https://github.com/facebook/rocksdb/pull/11654 Test Plan: Multiple db_stress runs with pre-PR and post-PR binary randomly to ensure forward/backward compatibility on options https://github.com/ajkr/rocksdb/commit/36a5686ec012f35a4371e409aa85c404ca1c210d?fbclid=IwAR2IcdAUdTvw9O9V5GkHEYJRGMVR9p7Ei-LMa-9qiXlj3z80DxjkxlGnP1E `python3 tools/db_crashtest.py --simple blackbox --interval=30` Reviewed By: cbi42 Differential Revision: D47892459 Pulled By: hx235 fbshipit-source-id: a62f46a0377fe143be7638e218978d5431c15c56
-rw-r--r--db/c.cc29
-rw-r--r--db/c_test.c9
-rw-r--r--include/rocksdb/c.h4
-rw-r--r--include/rocksdb/options.h9
-rw-r--r--include/rocksdb/utilities/options_type.h6
-rw-r--r--java/CMakeLists.txt3
-rw-r--r--java/benchmark/src/main/java/org/rocksdb/benchmark/DbBenchmark.java3
-rw-r--r--java/rocksjni/options.cc48
-rw-r--r--java/rocksjni/portal.h42
-rw-r--r--java/src/main/java/org/rocksdb/AccessHint.java54
-rw-r--r--java/src/main/java/org/rocksdb/DBOptions.java18
-rw-r--r--java/src/main/java/org/rocksdb/DBOptionsInterface.java22
-rw-r--r--java/src/main/java/org/rocksdb/Options.java18
-rw-r--r--java/src/test/java/org/rocksdb/DBOptionsTest.java10
-rw-r--r--java/src/test/java/org/rocksdb/OptionsTest.java10
-rw-r--r--options/db_options.cc15
-rw-r--r--options/db_options.h1
-rw-r--r--options/options_helper.cc2
-rw-r--r--options/options_settable_test.cc1
-rw-r--r--tools/db_bench_tool.cc20
-rw-r--r--unreleased_history/public_api_changes/remove_access_hint_on_compaction_start1
21 files changed, 7 insertions, 318 deletions
diff --git a/db/c.cc b/db/c.cc
index 73360dfda..c445a2300 100644
--- a/db/c.cc
+++ b/db/c.cc
@@ -3516,35 +3516,6 @@ unsigned char rocksdb_options_get_advise_random_on_open(
return opt->rep.advise_random_on_open;
}
-void rocksdb_options_set_access_hint_on_compaction_start(rocksdb_options_t* opt,
- int v) {
- switch (v) {
- case 0:
- opt->rep.access_hint_on_compaction_start =
- ROCKSDB_NAMESPACE::Options::NONE;
- break;
- case 1:
- opt->rep.access_hint_on_compaction_start =
- ROCKSDB_NAMESPACE::Options::NORMAL;
- break;
- case 2:
- opt->rep.access_hint_on_compaction_start =
- ROCKSDB_NAMESPACE::Options::SEQUENTIAL;
- break;
- case 3:
- opt->rep.access_hint_on_compaction_start =
- ROCKSDB_NAMESPACE::Options::WILLNEED;
- break;
- default:
- assert(0);
- }
-}
-
-int rocksdb_options_get_access_hint_on_compaction_start(
- rocksdb_options_t* opt) {
- return opt->rep.access_hint_on_compaction_start;
-}
-
void rocksdb_options_set_use_adaptive_mutex(rocksdb_options_t* opt,
unsigned char v) {
opt->rep.use_adaptive_mutex = v;
diff --git a/db/c_test.c b/db/c_test.c
index f10accb0b..c2e30b04e 100644
--- a/db/c_test.c
+++ b/db/c_test.c
@@ -2039,8 +2039,6 @@ int main(int argc, char** argv) {
rocksdb_options_set_advise_random_on_open(o, 1);
CheckCondition(1 == rocksdb_options_get_advise_random_on_open(o));
- rocksdb_options_set_access_hint_on_compaction_start(o, 3);
- CheckCondition(3 == rocksdb_options_get_access_hint_on_compaction_start(o));
rocksdb_options_set_use_adaptive_mutex(o, 1);
CheckCondition(1 == rocksdb_options_get_use_adaptive_mutex(o));
@@ -2236,8 +2234,6 @@ int main(int argc, char** argv) {
CheckCondition(18 == rocksdb_options_get_stats_dump_period_sec(copy));
CheckCondition(5 == rocksdb_options_get_stats_persist_period_sec(copy));
CheckCondition(1 == rocksdb_options_get_advise_random_on_open(copy));
- CheckCondition(3 ==
- rocksdb_options_get_access_hint_on_compaction_start(copy));
CheckCondition(1 == rocksdb_options_get_use_adaptive_mutex(copy));
CheckCondition(19 == rocksdb_options_get_bytes_per_sync(copy));
CheckCondition(20 == rocksdb_options_get_wal_bytes_per_sync(copy));
@@ -2520,11 +2516,6 @@ int main(int argc, char** argv) {
CheckCondition(0 == rocksdb_options_get_advise_random_on_open(copy));
CheckCondition(1 == rocksdb_options_get_advise_random_on_open(o));
- rocksdb_options_set_access_hint_on_compaction_start(copy, 2);
- CheckCondition(2 ==
- rocksdb_options_get_access_hint_on_compaction_start(copy));
- CheckCondition(3 == rocksdb_options_get_access_hint_on_compaction_start(o));
-
rocksdb_options_set_use_adaptive_mutex(copy, 0);
CheckCondition(0 == rocksdb_options_get_use_adaptive_mutex(copy));
CheckCondition(1 == rocksdb_options_get_use_adaptive_mutex(o));
diff --git a/include/rocksdb/c.h b/include/rocksdb/c.h
index 8fd824a50..9aa395468 100644
--- a/include/rocksdb/c.h
+++ b/include/rocksdb/c.h
@@ -1505,10 +1505,6 @@ extern ROCKSDB_LIBRARY_API void rocksdb_options_set_advise_random_on_open(
rocksdb_options_t*, unsigned char);
extern ROCKSDB_LIBRARY_API unsigned char
rocksdb_options_get_advise_random_on_open(rocksdb_options_t*);
-extern ROCKSDB_LIBRARY_API void
-rocksdb_options_set_access_hint_on_compaction_start(rocksdb_options_t*, int);
-extern ROCKSDB_LIBRARY_API int
-rocksdb_options_get_access_hint_on_compaction_start(rocksdb_options_t*);
extern ROCKSDB_LIBRARY_API void rocksdb_options_set_use_adaptive_mutex(
rocksdb_options_t*, unsigned char);
extern ROCKSDB_LIBRARY_API unsigned char rocksdb_options_get_use_adaptive_mutex(
diff --git a/include/rocksdb/options.h b/include/rocksdb/options.h
index 8f0244623..9e35632ec 100644
--- a/include/rocksdb/options.h
+++ b/include/rocksdb/options.h
@@ -954,15 +954,6 @@ struct DBOptions {
// Default: null
std::shared_ptr<WriteBufferManager> write_buffer_manager = nullptr;
- // DEPRECATED
- // This flag has no effect on the behavior of compaction and we plan to delete
- // it in the future.
- // Specify the file access pattern once a compaction is started.
- // It will be applied to all input files of a compaction.
- // Default: NORMAL
- enum AccessHint { NONE, NORMAL, SEQUENTIAL, WILLNEED };
- AccessHint access_hint_on_compaction_start = NORMAL;
-
// If non-zero, we perform bigger reads when doing compaction. If you're
// running RocksDB on spinning disks, you should set this to at least 2MB.
// That way RocksDB's compaction is doing sequential instead of random reads.
diff --git a/include/rocksdb/utilities/options_type.h b/include/rocksdb/utilities/options_type.h
index 782b14e65..aea24526c 100644
--- a/include/rocksdb/utilities/options_type.h
+++ b/include/rocksdb/utilities/options_type.h
@@ -299,9 +299,9 @@ class OptionTypeInfo {
template <typename T>
static OptionTypeInfo Enum(
int offset, const std::unordered_map<std::string, T>* const map,
- OptionTypeFlags flags = OptionTypeFlags::kNone) {
- OptionTypeInfo info(offset, OptionType::kEnum,
- OptionVerificationType::kNormal, flags);
+ OptionTypeFlags flags = OptionTypeFlags::kNone,
+ OptionVerificationType verification = OptionVerificationType::kNormal) {
+ OptionTypeInfo info(offset, OptionType::kEnum, verification, flags);
info.SetParseFunc(
// Uses the map argument to convert the input string into
// its corresponding enum value. If value is found in the map,
diff --git a/java/CMakeLists.txt b/java/CMakeLists.txt
index ce6d13a3d..89fda2cff 100644
--- a/java/CMakeLists.txt
+++ b/java/CMakeLists.txt
@@ -115,7 +115,6 @@ set(JAVA_MAIN_CLASSES
src/main/java/org/rocksdb/AbstractTransactionNotifier.java
src/main/java/org/rocksdb/AbstractWalFilter.java
src/main/java/org/rocksdb/AbstractWriteBatch.java
- src/main/java/org/rocksdb/AccessHint.java
src/main/java/org/rocksdb/AdvancedColumnFamilyOptionsInterface.java
src/main/java/org/rocksdb/AdvancedMutableColumnFamilyOptionsInterface.java
src/main/java/org/rocksdb/BackgroundErrorReason.java
@@ -870,4 +869,4 @@ foreach (CLAZZ ${JAVA_TEST_RUNNING_CLASSES})
COMMAND ${Java_JAVA_EXECUTABLE} ${JVMARGS} -ea -Xcheck:jni -Djava.library.path=${PROJECT_BINARY_DIR}/java -classpath ${JAVA_RUN_TESTCLASSPATH}:${ROCKSDBJNI_CLASSES_TEST_JAR_FILE} org.rocksdb.test.RocksJunitRunner ${CLAZZ}
)
endif()
-endforeach(CLAZZ) \ No newline at end of file
+endforeach(CLAZZ)
diff --git a/java/benchmark/src/main/java/org/rocksdb/benchmark/DbBenchmark.java b/java/benchmark/src/main/java/org/rocksdb/benchmark/DbBenchmark.java
index 070f0fe75..8673b35fc 100644
--- a/java/benchmark/src/main/java/org/rocksdb/benchmark/DbBenchmark.java
+++ b/java/benchmark/src/main/java/org/rocksdb/benchmark/DbBenchmark.java
@@ -614,9 +614,6 @@ public class DbBenchmark {
(Integer)flags_.get(Flag.universal_compression_size_percent));
// TODO(yhchiang): add RocksDB.openForReadOnly() to enable Flag.readonly
// TODO(yhchiang): enable Flag.merge_operator by switch
- options.setAccessHintOnCompactionStart(
- (String)flags_.get(Flag.compaction_fadvice));
- // available values of fadvice are "NONE", "NORMAL", "SEQUENTIAL", "WILLNEED" for fadvice
*/
}
diff --git a/java/rocksjni/options.cc b/java/rocksjni/options.cc
index 364ddc6c4..d5dc2f067 100644
--- a/java/rocksjni/options.cc
+++ b/java/rocksjni/options.cc
@@ -1556,30 +1556,6 @@ jlong Java_org_rocksdb_Options_dbWriteBufferSize(JNIEnv*, jclass,
/*
* Class: org_rocksdb_Options
- * Method: setAccessHintOnCompactionStart
- * Signature: (JB)V
- */
-void Java_org_rocksdb_Options_setAccessHintOnCompactionStart(
- JNIEnv*, jclass, jlong jhandle, jbyte jaccess_hint_value) {
- auto* opt = reinterpret_cast<ROCKSDB_NAMESPACE::Options*>(jhandle);
- opt->access_hint_on_compaction_start =
- ROCKSDB_NAMESPACE::AccessHintJni::toCppAccessHint(jaccess_hint_value);
-}
-
-/*
- * Class: org_rocksdb_Options
- * Method: accessHintOnCompactionStart
- * Signature: (J)B
- */
-jbyte Java_org_rocksdb_Options_accessHintOnCompactionStart(JNIEnv*, jclass,
- jlong jhandle) {
- auto* opt = reinterpret_cast<ROCKSDB_NAMESPACE::Options*>(jhandle);
- return ROCKSDB_NAMESPACE::AccessHintJni::toJavaAccessHint(
- opt->access_hint_on_compaction_start);
-}
-
-/*
- * Class: org_rocksdb_Options
* Method: setCompactionReadaheadSize
* Signature: (JJ)V
*/
@@ -7086,30 +7062,6 @@ jlong Java_org_rocksdb_DBOptions_dbWriteBufferSize(JNIEnv*, jclass,
/*
* Class: org_rocksdb_DBOptions
- * Method: setAccessHintOnCompactionStart
- * Signature: (JB)V
- */
-void Java_org_rocksdb_DBOptions_setAccessHintOnCompactionStart(
- JNIEnv*, jclass, jlong jhandle, jbyte jaccess_hint_value) {
- auto* opt = reinterpret_cast<ROCKSDB_NAMESPACE::DBOptions*>(jhandle);
- opt->access_hint_on_compaction_start =
- ROCKSDB_NAMESPACE::AccessHintJni::toCppAccessHint(jaccess_hint_value);
-}
-
-/*
- * Class: org_rocksdb_DBOptions
- * Method: accessHintOnCompactionStart
- * Signature: (J)B
- */
-jbyte Java_org_rocksdb_DBOptions_accessHintOnCompactionStart(JNIEnv*, jclass,
- jlong jhandle) {
- auto* opt = reinterpret_cast<ROCKSDB_NAMESPACE::DBOptions*>(jhandle);
- return ROCKSDB_NAMESPACE::AccessHintJni::toJavaAccessHint(
- opt->access_hint_on_compaction_start);
-}
-
-/*
- * Class: org_rocksdb_DBOptions
* Method: setCompactionReadaheadSize
* Signature: (JJ)V
*/
diff --git a/java/rocksjni/portal.h b/java/rocksjni/portal.h
index 3f85a9805..8ee2f72b6 100644
--- a/java/rocksjni/portal.h
+++ b/java/rocksjni/portal.h
@@ -4730,48 +4730,6 @@ class CompactionPriorityJni {
}
};
-// The portal class for org.rocksdb.AccessHint
-class AccessHintJni {
- public:
- // Returns the equivalent org.rocksdb.AccessHint for the provided
- // C++ ROCKSDB_NAMESPACE::DBOptions::AccessHint enum
- static jbyte toJavaAccessHint(
- const ROCKSDB_NAMESPACE::DBOptions::AccessHint& access_hint) {
- switch (access_hint) {
- case ROCKSDB_NAMESPACE::DBOptions::AccessHint::NONE:
- return 0x0;
- case ROCKSDB_NAMESPACE::DBOptions::AccessHint::NORMAL:
- return 0x1;
- case ROCKSDB_NAMESPACE::DBOptions::AccessHint::SEQUENTIAL:
- return 0x2;
- case ROCKSDB_NAMESPACE::DBOptions::AccessHint::WILLNEED:
- return 0x3;
- default:
- // undefined/default
- return 0x1;
- }
- }
-
- // Returns the equivalent C++ ROCKSDB_NAMESPACE::DBOptions::AccessHint enum
- // for the provided Java org.rocksdb.AccessHint
- static ROCKSDB_NAMESPACE::DBOptions::AccessHint toCppAccessHint(
- jbyte jaccess_hint) {
- switch (jaccess_hint) {
- case 0x0:
- return ROCKSDB_NAMESPACE::DBOptions::AccessHint::NONE;
- case 0x1:
- return ROCKSDB_NAMESPACE::DBOptions::AccessHint::NORMAL;
- case 0x2:
- return ROCKSDB_NAMESPACE::DBOptions::AccessHint::SEQUENTIAL;
- case 0x3:
- return ROCKSDB_NAMESPACE::DBOptions::AccessHint::WILLNEED;
- default:
- // undefined/default
- return ROCKSDB_NAMESPACE::DBOptions::AccessHint::NORMAL;
- }
- }
-};
-
// The portal class for org.rocksdb.WALRecoveryMode
class WALRecoveryModeJni {
public:
diff --git a/java/src/main/java/org/rocksdb/AccessHint.java b/java/src/main/java/org/rocksdb/AccessHint.java
deleted file mode 100644
index b7ccadd84..000000000
--- a/java/src/main/java/org/rocksdb/AccessHint.java
+++ /dev/null
@@ -1,54 +0,0 @@
-// Copyright (c) 2011-present, Facebook, Inc. All rights reserved.
-// This source code is licensed under both the GPLv2 (found in the
-// COPYING file in the root directory) and Apache 2.0 License
-// (found in the LICENSE.Apache file in the root directory).
-
-package org.rocksdb;
-
-/**
- * File access pattern once a compaction has started
- */
-@Deprecated
-public enum AccessHint {
- NONE((byte)0x0),
- NORMAL((byte)0x1),
- SEQUENTIAL((byte)0x2),
- WILLNEED((byte)0x3);
-
- private final byte value;
-
- AccessHint(final byte value) {
- this.value = value;
- }
-
- /**
- * <p>Returns the byte value of the enumerations value.</p>
- *
- * @return byte representation
- */
- public byte getValue() {
- return value;
- }
-
- /**
- * <p>Get the AccessHint enumeration value by
- * passing the byte identifier to this method.</p>
- *
- * @param byteIdentifier of AccessHint.
- *
- * @return AccessHint instance.
- *
- * @throws IllegalArgumentException if the access hint for the byteIdentifier
- * cannot be found
- */
- public static AccessHint getAccessHint(final byte byteIdentifier) {
- for (final AccessHint accessHint : AccessHint.values()) {
- if (accessHint.getValue() == byteIdentifier) {
- return accessHint;
- }
- }
-
- throw new IllegalArgumentException(
- "Illegal value provided for AccessHint.");
- }
-}
diff --git a/java/src/main/java/org/rocksdb/DBOptions.java b/java/src/main/java/org/rocksdb/DBOptions.java
index d9cd403eb..60303dc5a 100644
--- a/java/src/main/java/org/rocksdb/DBOptions.java
+++ b/java/src/main/java/org/rocksdb/DBOptions.java
@@ -747,21 +747,6 @@ public class DBOptions extends RocksObject
}
@Override
- @Deprecated
- public DBOptions setAccessHintOnCompactionStart(final AccessHint accessHint) {
- assert(isOwningHandle());
- setAccessHintOnCompactionStart(nativeHandle_, accessHint.getValue());
- return this;
- }
-
- @Override
- @Deprecated
- public AccessHint accessHintOnCompactionStart() {
- assert(isOwningHandle());
- return AccessHint.getAccessHint(accessHintOnCompactionStart(nativeHandle_));
- }
-
- @Override
public DBOptions setCompactionReadaheadSize(final long compactionReadaheadSize) {
assert(isOwningHandle());
setCompactionReadaheadSize(nativeHandle_, compactionReadaheadSize);
@@ -1360,9 +1345,6 @@ public class DBOptions extends RocksObject
private static native void setWriteBufferManager(
final long dbOptionsHandle, final long writeBufferManagerHandle);
private static native long dbWriteBufferSize(final long handle);
- private static native void setAccessHintOnCompactionStart(
- final long handle, final byte accessHintOnCompactionStart);
- private static native byte accessHintOnCompactionStart(final long handle);
private static native void setCompactionReadaheadSize(
final long handle, final long compactionReadaheadSize);
private static native long compactionReadaheadSize(final long handle);
diff --git a/java/src/main/java/org/rocksdb/DBOptionsInterface.java b/java/src/main/java/org/rocksdb/DBOptionsInterface.java
index 5a351b4e4..a3a30dd5e 100644
--- a/java/src/main/java/org/rocksdb/DBOptionsInterface.java
+++ b/java/src/main/java/org/rocksdb/DBOptionsInterface.java
@@ -939,28 +939,6 @@ public interface DBOptionsInterface<T extends DBOptionsInterface<T>> {
long dbWriteBufferSize();
/**
- * Specify the file access pattern once a compaction is started.
- * It will be applied to all input files of a compaction.
- *
- * Default: {@link AccessHint#NORMAL}
- *
- * @param accessHint The access hint
- *
- * @return the reference to the current options.
- */
- @Deprecated T setAccessHintOnCompactionStart(final AccessHint accessHint);
-
- /**
- * Specify the file access pattern once a compaction is started.
- * It will be applied to all input files of a compaction.
- *
- * Default: {@link AccessHint#NORMAL}
- *
- * @return The access hint
- */
- @Deprecated AccessHint accessHintOnCompactionStart();
-
- /**
* This is a maximum buffer size that is used by WinMmapReadableFile in
* unbuffered disk I/O mode. We need to maintain an aligned buffer for
* reads. We allow the buffer to grow until the specified value and then
diff --git a/java/src/main/java/org/rocksdb/Options.java b/java/src/main/java/org/rocksdb/Options.java
index 0f6c53b66..d3f6bdea5 100644
--- a/java/src/main/java/org/rocksdb/Options.java
+++ b/java/src/main/java/org/rocksdb/Options.java
@@ -835,21 +835,6 @@ public class Options extends RocksObject
}
@Override
- @Deprecated
- public Options setAccessHintOnCompactionStart(final AccessHint accessHint) {
- assert(isOwningHandle());
- setAccessHintOnCompactionStart(nativeHandle_, accessHint.getValue());
- return this;
- }
-
- @Override
- @Deprecated
- public AccessHint accessHintOnCompactionStart() {
- assert(isOwningHandle());
- return AccessHint.getAccessHint(accessHintOnCompactionStart(nativeHandle_));
- }
-
- @Override
public Options setCompactionReadaheadSize(final long compactionReadaheadSize) {
assert(isOwningHandle());
setCompactionReadaheadSize(nativeHandle_, compactionReadaheadSize);
@@ -2268,9 +2253,6 @@ public class Options extends RocksObject
private static native void setWriteBufferManager(
final long handle, final long writeBufferManagerHandle);
private static native long dbWriteBufferSize(final long handle);
- private static native void setAccessHintOnCompactionStart(
- final long handle, final byte accessHintOnCompactionStart);
- private static native byte accessHintOnCompactionStart(final long handle);
private static native void setCompactionReadaheadSize(
final long handle, final long compactionReadaheadSize);
private static native long compactionReadaheadSize(final long handle);
diff --git a/java/src/test/java/org/rocksdb/DBOptionsTest.java b/java/src/test/java/org/rocksdb/DBOptionsTest.java
index cb7eabcfb..189acdb4a 100644
--- a/java/src/test/java/org/rocksdb/DBOptionsTest.java
+++ b/java/src/test/java/org/rocksdb/DBOptionsTest.java
@@ -453,16 +453,6 @@ public class DBOptionsTest {
}
}
- @SuppressWarnings("deprecated")
- @Test
- public void accessHintOnCompactionStart() {
- try(final DBOptions opt = new DBOptions()) {
- final AccessHint accessHint = AccessHint.SEQUENTIAL;
- opt.setAccessHintOnCompactionStart(accessHint);
- assertThat(opt.accessHintOnCompactionStart()).isEqualTo(accessHint);
- }
- }
-
@Test
public void compactionReadaheadSize() {
try(final DBOptions opt = new DBOptions()) {
diff --git a/java/src/test/java/org/rocksdb/OptionsTest.java b/java/src/test/java/org/rocksdb/OptionsTest.java
index 5de42a13e..9d2316737 100644
--- a/java/src/test/java/org/rocksdb/OptionsTest.java
+++ b/java/src/test/java/org/rocksdb/OptionsTest.java
@@ -699,16 +699,6 @@ public class OptionsTest {
}
}
- @SuppressWarnings("deprecated")
- @Test
- public void accessHintOnCompactionStart() {
- try (final Options opt = new Options()) {
- final AccessHint accessHint = AccessHint.SEQUENTIAL;
- opt.setAccessHintOnCompactionStart(accessHint);
- assertThat(opt.accessHintOnCompactionStart()).isEqualTo(accessHint);
- }
- }
-
@Test
public void compactionReadaheadSize() {
try (final Options opt = new Options()) {
diff --git a/options/db_options.cc b/options/db_options.cc
index 2d213f13f..c7d227254 100644
--- a/options/db_options.cc
+++ b/options/db_options.cc
@@ -35,12 +35,6 @@ static std::unordered_map<std::string, WALRecoveryMode>
{"kSkipAnyCorruptedRecords",
WALRecoveryMode::kSkipAnyCorruptedRecords}};
-static std::unordered_map<std::string, DBOptions::AccessHint>
- access_hint_string_map = {{"NONE", DBOptions::AccessHint::NONE},
- {"NORMAL", DBOptions::AccessHint::NORMAL},
- {"SEQUENTIAL", DBOptions::AccessHint::SEQUENTIAL},
- {"WILLNEED", DBOptions::AccessHint::WILLNEED}};
-
static std::unordered_map<std::string, CacheTier> cache_tier_string_map = {
{"kVolatileTier", CacheTier::kVolatileTier},
{"kNonVolatileBlockTier", CacheTier::kNonVolatileBlockTier}};
@@ -357,10 +351,8 @@ static std::unordered_map<std::string, OptionTypeInfo>
OptionType::kUInt64T, OptionVerificationType::kNormal,
OptionTypeFlags::kNone}},
{"access_hint_on_compaction_start",
- OptionTypeInfo::Enum<DBOptions::AccessHint>(
- offsetof(struct ImmutableDBOptions,
- access_hint_on_compaction_start),
- &access_hint_string_map)},
+ OptionTypeInfo::Enum<bool>(0, nullptr, OptionTypeFlags::kNone,
+ OptionVerificationType::kDeprecated)},
{"info_log_level",
OptionTypeInfo::Enum<InfoLogLevel>(
offsetof(struct ImmutableDBOptions, info_log_level),
@@ -724,7 +716,6 @@ ImmutableDBOptions::ImmutableDBOptions(const DBOptions& options)
advise_random_on_open(options.advise_random_on_open),
db_write_buffer_size(options.db_write_buffer_size),
write_buffer_manager(options.write_buffer_manager),
- access_hint_on_compaction_start(options.access_hint_on_compaction_start),
random_access_max_buffer_size(options.random_access_max_buffer_size),
use_adaptive_mutex(options.use_adaptive_mutex),
listeners(options.listeners),
@@ -862,8 +853,6 @@ void ImmutableDBOptions::Dump(Logger* log) const {
db_write_buffer_size);
ROCKS_LOG_HEADER(log, " Options.write_buffer_manager: %p",
write_buffer_manager.get());
- ROCKS_LOG_HEADER(log, " Options.access_hint_on_compaction_start: %d",
- static_cast<int>(access_hint_on_compaction_start));
ROCKS_LOG_HEADER(
log, " Options.random_access_max_buffer_size: %" ROCKSDB_PRIszt,
random_access_max_buffer_size);
diff --git a/options/db_options.h b/options/db_options.h
index 701a83feb..b0432df81 100644
--- a/options/db_options.h
+++ b/options/db_options.h
@@ -61,7 +61,6 @@ struct ImmutableDBOptions {
bool advise_random_on_open;
size_t db_write_buffer_size;
std::shared_ptr<WriteBufferManager> write_buffer_manager;
- DBOptions::AccessHint access_hint_on_compaction_start;
size_t random_access_max_buffer_size;
bool use_adaptive_mutex;
std::vector<std::shared_ptr<EventListener>> listeners;
diff --git a/options/options_helper.cc b/options/options_helper.cc
index 8cc671264..ef679861d 100644
--- a/options/options_helper.cc
+++ b/options/options_helper.cc
@@ -120,8 +120,6 @@ DBOptions BuildDBOptions(const ImmutableDBOptions& immutable_db_options,
options.advise_random_on_open = immutable_db_options.advise_random_on_open;
options.db_write_buffer_size = immutable_db_options.db_write_buffer_size;
options.write_buffer_manager = immutable_db_options.write_buffer_manager;
- options.access_hint_on_compaction_start =
- immutable_db_options.access_hint_on_compaction_start;
options.compaction_readahead_size =
mutable_db_options.compaction_readahead_size;
options.random_access_max_buffer_size =
diff --git a/options/options_settable_test.cc b/options/options_settable_test.cc
index 2f7493f32..37a6eb17b 100644
--- a/options/options_settable_test.cc
+++ b/options/options_settable_test.cc
@@ -344,7 +344,6 @@ TEST_F(OptionsSettableTest, DBOptionsAllFieldsSettable) {
"enable_write_thread_adaptive_yield=true;"
"write_thread_slow_yield_usec=5;"
"write_thread_max_yield_usec=1000;"
- "access_hint_on_compaction_start=NONE;"
"info_log_level=DEBUG_LEVEL;"
"dump_malloc_stats=false;"
"allow_2pc=false;"
diff --git a/tools/db_bench_tool.cc b/tools/db_bench_tool.cc
index 29fe3f8e1..1ac66a925 100644
--- a/tools/db_bench_tool.cc
+++ b/tools/db_bench_tool.cc
@@ -1592,11 +1592,6 @@ DEFINE_bool(advise_random_on_open,
ROCKSDB_NAMESPACE::Options().advise_random_on_open,
"Advise random access on table file open");
-DEFINE_string(compaction_fadvice, "NORMAL",
- "Access pattern advice when a file is compacted");
-static auto FLAGS_compaction_fadvice_e =
- ROCKSDB_NAMESPACE::Options().access_hint_on_compaction_start;
-
DEFINE_bool(use_tailing_iterator, false,
"Use tailing iterator to access a series of keys instead of get");
@@ -4616,7 +4611,6 @@ class Benchmark {
options.ttl = FLAGS_ttl_seconds;
// fill storage options
options.advise_random_on_open = FLAGS_advise_random_on_open;
- options.access_hint_on_compaction_start = FLAGS_compaction_fadvice_e;
options.use_adaptive_mutex = FLAGS_use_adaptive_mutex;
options.bytes_per_sync = FLAGS_bytes_per_sync;
options.wal_bytes_per_sync = FLAGS_wal_bytes_per_sync;
@@ -8654,20 +8648,6 @@ int db_bench_tool(int argc, char** argv) {
exit(1);
}
- if (!strcasecmp(FLAGS_compaction_fadvice.c_str(), "NONE")) {
- FLAGS_compaction_fadvice_e = ROCKSDB_NAMESPACE::Options::NONE;
- } else if (!strcasecmp(FLAGS_compaction_fadvice.c_str(), "NORMAL")) {
- FLAGS_compaction_fadvice_e = ROCKSDB_NAMESPACE::Options::NORMAL;
- } else if (!strcasecmp(FLAGS_compaction_fadvice.c_str(), "SEQUENTIAL")) {
- FLAGS_compaction_fadvice_e = ROCKSDB_NAMESPACE::Options::SEQUENTIAL;
- } else if (!strcasecmp(FLAGS_compaction_fadvice.c_str(), "WILLNEED")) {
- FLAGS_compaction_fadvice_e = ROCKSDB_NAMESPACE::Options::WILLNEED;
- } else {
- fprintf(stdout, "Unknown compaction fadvice:%s\n",
- FLAGS_compaction_fadvice.c_str());
- exit(1);
- }
-
FLAGS_value_size_distribution_type_e =
StringToDistributionType(FLAGS_value_size_distribution_type.c_str());
diff --git a/unreleased_history/public_api_changes/remove_access_hint_on_compaction_start b/unreleased_history/public_api_changes/remove_access_hint_on_compaction_start
new file mode 100644
index 000000000..8e6268d58
--- /dev/null
+++ b/unreleased_history/public_api_changes/remove_access_hint_on_compaction_start
@@ -0,0 +1 @@
+Removed deprecated option `access_hint_on_compaction_start`