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

Refactor TestLinearWriteSpeed to use array type for records

This commit is contained in:
Ubuntu 2025-10-06 22:20:38 +00:00
parent b4e5e6b1dd
commit 1940c321de
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -238,12 +238,12 @@ public class TestLinearWriteSpeed {
MemoryRecords messages;
UnifiedLog log;
Compression compression;
List<SimpleRecord> recordsList;
SimpleRecord[] records;
public LogWritable(File dir, LogConfig config, Scheduler scheduler, MemoryRecords messages, Compression compression, List<SimpleRecord> recordsList) throws IOException {
this.messages = messages;
this.compression = compression;
this.recordsList = recordsList;
this.records = recordsList.toArray(new SimpleRecord[0]);
Utils.delete(dir);
this.log = UnifiedLog.create(
dir,
@ -266,7 +266,7 @@ public class TestLinearWriteSpeed {
}
public int write() {
this.messages = MemoryRecords.withRecords(compression, recordsList.toArray(new SimpleRecord[0]));
this.messages = MemoryRecords.withRecords(compression, records);
log.appendAsLeader(
messages,
0,