root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

KAFKA-12832 remove deprecated methods in RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter (#16813) 

Reviewers: Josep Prat <josep.prat@aiven.io>
This commit is contained in:
Ken Huang 2024-08-09 17:49:28 +08:00 committed by GitHub
parent ed0e1086a9
commit 1ff7cf3d36
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
View File

@ -321,12 +321,6 @@ public class RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter extends
return this; return this;
} }
@Deprecated
@Override
public int maxBackgroundCompactions() {
return dbOptions.maxBackgroundCompactions();
}
@Override @Override
public Options setStatistics(final Statistics statistics) { public Options setStatistics(final Statistics statistics) {
dbOptions.setStatistics(statistics); dbOptions.setStatistics(statistics);
@ -338,16 +332,6 @@ public class RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter extends
return dbOptions.statistics(); return dbOptions.statistics();
} }
@Deprecated
public void setBaseBackgroundCompactions(final int baseBackgroundCompactions) {
final String message = "This method has been removed from the underlying RocksDB. " +
"It was not affecting compaction even in earlier versions. " +
"It is currently a no-op method. " +
"RocksDB decides the number of background compactions based on the maxBackgroundJobs(...) method";
log.warn(message);
// no-op
}
@Deprecated @Deprecated
public int baseBackgroundCompactions() { public int baseBackgroundCompactions() {
final String message = "This method has been removed from the underlying RocksDB. " + final String message = "This method has been removed from the underlying RocksDB. " +
@ -356,13 +340,6 @@ public class RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter extends
return -1; return -1;
} }
@Deprecated
@Override
public Options setMaxBackgroundCompactions(final int maxBackgroundCompactions) {
dbOptions.setMaxBackgroundCompactions(maxBackgroundCompactions);
return this;
}
@Override @Override
public Options setMaxSubcompactions(final int maxSubcompactions) { public Options setMaxSubcompactions(final int maxSubcompactions) {
dbOptions.setMaxSubcompactions(maxSubcompactions); dbOptions.setMaxSubcompactions(maxSubcompactions);
@ -374,19 +351,6 @@ public class RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter extends
return dbOptions.maxSubcompactions(); return dbOptions.maxSubcompactions();
} }
@Deprecated
@Override
public int maxBackgroundFlushes() {
return dbOptions.maxBackgroundFlushes();
}
@Deprecated
@Override
public Options setMaxBackgroundFlushes(final int maxBackgroundFlushes) {
dbOptions.setMaxBackgroundFlushes(maxBackgroundFlushes);
return this;
}
@Override @Override
public int maxBackgroundJobs() { public int maxBackgroundJobs() {
return dbOptions.maxBackgroundJobs(); return dbOptions.maxBackgroundJobs();