Skip to content

Commit 9d1c5d5

Browse files
authored
replace LinkedList by ArrayList in BufferedProducerKtImpl (#156)
1 parent 0cf5906 commit 9d1c5d5

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

client/build.gradle.kts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ tasks.withType<Javadoc> {
178178
(options as StandardJavadocDocletOptions).addBooleanOption("html5", true)
179179
(options as StandardJavadocDocletOptions).links(
180180
"https://docs.oracle.com/en/java/javase/11/docs/api/",
181-
"https://javadoc.io/doc/com.google.guava/guava/latest/"
181+
// "https://javadoc.io/doc/com.google.guava/guava/latest/"
182182
)
183183
exclude("io/hstream/impl/**", "io/hstream/util/**")
184184
}

client/src/main/kotlin/io/hstream/impl/BufferedProducerKtImpl.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,8 @@ class BufferedProducerKtImpl(
6666
val partitionKey = hStreamRecord.header.key
6767
val shardId = calculateShardIdByPartitionKey(partitionKey)
6868
if (!shardAppendBuffer.containsKey(shardId)) {
69-
shardAppendBuffer[shardId] = LinkedList()
70-
shardAppendFutures[shardId] = LinkedList()
69+
shardAppendBuffer[shardId] = ArrayList()
70+
shardAppendFutures[shardId] = ArrayList()
7171
shardAppendBytesSize[shardId] = 0
7272
if (batchSetting.ageLimit > 0) {
7373
timerServices[shardId] =

0 commit comments

Comments
 (0)