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

Rewrite the Options class using a record

This commit is contained in:
Ubuntu 2025-09-25 18:02:10 +00:00
parent cbb2a9c4c3
commit 381ec4fd16
1 changed files with 6 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java
View File

@ -283,50 +283,12 @@ public class TestLinearWriteSpeed {
}
}
private static class Options {
private final OptionSpec<String> dirOpt;
private final OptionSpec<Long> bytesOpt;
private final OptionSpec<Integer> sizeOpt;
private final OptionSpec<Integer> messageSizeOpt;
private final OptionSpec<Integer> filesOpt;
private final OptionSpec<Long> reportingIntervalOpt;
private final OptionSpec<Integer> maxThroughputOpt;
private final OptionSpec<Long> flushIntervalOpt;
private final OptionSpec<String> compressionCodecOpt;
private final OptionSpec<Integer> compressionLevelOpt;
private final OptionSpec<Void> channelOpt;
private final OptionSpec<Void> logOpt;
private final OptionSpec<Void> mmapOpt;
private Options(
OptionSpec<String> dirOpt,
OptionSpec<Long> bytesOpt,
OptionSpec<Integer> sizeOpt,
OptionSpec<Integer> messageSizeOpt,
OptionSpec<Integer> filesOpt,
OptionSpec<Long> reportingIntervalOpt,
OptionSpec<Integer> maxThroughputOpt,
OptionSpec<Long> flushIntervalOpt,
OptionSpec<String> compressionCodecOpt,
OptionSpec<Integer> compressionLevelOpt,
OptionSpec<Void> channelOpt,
OptionSpec<Void> logOpt,
OptionSpec<Void> mmapOpt
) {
this.dirOpt = dirOpt;
this.bytesOpt = bytesOpt;
this.sizeOpt = sizeOpt;
this.messageSizeOpt = messageSizeOpt;
this.filesOpt = filesOpt;
this.reportingIntervalOpt = reportingIntervalOpt;
this.maxThroughputOpt = maxThroughputOpt;
this.flushIntervalOpt = flushIntervalOpt;
this.compressionCodecOpt = compressionCodecOpt;
this.compressionLevelOpt = compressionLevelOpt;
this.channelOpt = channelOpt;
this.logOpt = logOpt;
this.mmapOpt = mmapOpt;
}
private record Options(OptionSpec<String> dirOpt, OptionSpec<Long> bytesOpt, OptionSpec<Integer> sizeOpt,
OptionSpec<Integer> messageSizeOpt, OptionSpec<Integer> filesOpt,
OptionSpec<Long> reportingIntervalOpt, OptionSpec<Integer> maxThroughputOpt,
OptionSpec<Long> flushIntervalOpt, OptionSpec<String> compressionCodecOpt,
OptionSpec<Integer> compressionLevelOpt, OptionSpec<Void> channelOpt,
OptionSpec<Void> logOpt, OptionSpec<Void> mmapOpt) {
}
private static Options createOptions(OptionParser parser) {