FIX: improve refineTrimmedKeys method using Java 8 removeIf

Author: junhyeongkim2

.github/workflows/ci.yml

@@ -7,6 +7,11 @@ on:
   pull_request:
     branches:
     - develop
+    types:
+    - opened
+    - synchronize
+    - reopened
+    - ready_for_review
 
 concurrency:
   group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }}
@@ -18,9 +23,12 @@ jobs:
     runs-on: ${{ matrix.os }}
     strategy:
       matrix:
-        jdk: [ 8, 11, 17 ]
-        os: [ ubuntu-20.04 ]
+        jdk: [ 8, 21 ]
+        os: [ ubuntu-latest ]
       fail-fast: true
+    if: |
+      (github.event_name == 'pull_request' && github.event.pull_request.draft == false) ||
+      (github.event_name == 'push' && github.ref == 'refs/heads/master')
     steps:
       - uses: actions/checkout@v4
       - name: Set up JDK ${{ matrix.jdk }}
@@ -35,9 +43,9 @@ jobs:
         run: |
           # clone
           git clone https://github.com/naver/arcus.git $HOME/arcus
-          
+
           # build server
-          cd ~/arcus && docker compose up -d 
+          cd ~/arcus && docker compose up -d
 
       - name: Test ARCUS Client Without ZK
         run: mvn clean verify -DUSE_ZK=false -Dtest=ObserverTest,ArcusClientCreateTest

ChangeLog

@@ -1,50 +1,46 @@
 # 2024-07-31 [version 1.14.0]
 ## 🐣 New Features
-* Bulk methods using varargs keys are deprecated. Instead, methods using collection keys are still available.
-* ArcusClient factory methods without zookeeper address are deprecated.
-* Provide shutdown(long, TimeUnit) method for ArcusClient.
-* Add auto import setting.
-* Add DNS cache TTL verification.
-* Add ArcusClient factory methods without ConnectionFactoryBuilder.
-* Add async mop upsert method.
-
+  - Bulk methods using varargs keys are deprecated. Instead, methods using collection keys are still available.
+  - ArcusClient factory methods without zookeeper address are deprecated.
+  - Provide shutdown(long, TimeUnit) method for ArcusClient.
+  - Add auto import setting.
+  - Add DNS cache TTL verification.
+  - Add ArcusClient factory methods without ConnectionFactoryBuilder.
+  - Add async mop upsert method.
 ## 🔧 Enhancements
-* Add connection information and elapsed time into TimeoutException message.
-* Add all operations at once in broadcast methods.
-* Return GetFuture instead of OperationFuture in asyncGets method.
-* Use GetResult class instead of setting results into future directly in collection get methods.
-* Use List#sublist method instead of using nested collection when split operations in bulk methods.
-* Refactor redundant concurrent data structure and unnecessary modifier.
-* Change the way ArcusClient is named.
-* Change MBean name of ArcusClient to make more readable.
-* Remove Transcoder argument in LocalCacheManager.
-* Remove unused methods/variables and redundant generic type.
-* Remove unused TimeoutException constructors.
-* Remove TranscoderService field in MemcachedClient and BulkService properties in ConnectionFactoryBuilder. Decoding value with transcoder will be done in user thread, such as tomcat thread.
-
+  - Add connection information and elapsed time into TimeoutException message.
+  - Add all operations at once in broadcast methods.
+  - Return GetFuture instead of OperationFuture in asyncGets method.
+  - Use GetResult class instead of setting results into future directly in collection get methods.
+  - Use List#sublist method instead of using nested collection when split operations in bulk methods.
+  - Refactor redundant concurrent data structure and unnecessary modifier.
+  - Change the way ArcusClient is named.
+  - Change MBean name of ArcusClient to make more readable.
+  - Remove Transcoder argument in LocalCacheManager.
+  - Remove unused methods/variables and redundant generic type.
+  - Remove unused TimeoutException constructors.
+  - Remove TranscoderService field in MemcachedClient and BulkService properties in ConnectionFactoryBuilder.
+    Decoding value with transcoder will be done in user thread, such as tomcat thread.
 ## 🐛 Bug Fixes
-* Make different results from InetSocketAddress.toString() same across JDK versions
-* Throw exception when bop get bulk count is lower than 1.
-* Fix invalid isTimeout value when creating BulkGetFuture with another object.
-* Set default value of shouldOptimize to false in DefaultConnectionFactory.
-* Consider optimizedOp when drain all of operations from the writeQ.
-* Make sure to create readonly copy of locator that has same shape with original one.
-
+  - Make different results from InetSocketAddress.toString() same across JDK versions
+  - Throw exception when bop get bulk count is lower than 1.
+  - Fix invalid isTimeout value when creating BulkGetFuture with another object.
+  - Set default value of shouldOptimize to false in DefaultConnectionFactory.
+  - Consider optimizedOp when drain all of operations from the writeQ.
+  - Make sure to create readonly copy of locator that has same shape with original one.
 ## 📝 Documentation
-* Fix wrong information.
-* Add DNS cache TTL information.
-* Add mop upsert API description.
-
+  - Fix wrong information.
+  - Add DNS cache TTL information.
+  - Add mop upsert API description.
 ## ✅ Testing
-* Upgrade CI setup python version to 2.7.
-* Use docker compose in CI tests.
-* Fix various test cases which could be failed sometimes.
-* Stop CI test when at least one test fails.
-
+  - Upgrade CI setup python version to 2.7.
+  - Use docker compose in CI tests.
+  - Fix various test cases which could be failed sometimes.
+  - Stop CI test when at least one test fails.
 ## ⬆️ Dependency Upgrades
-* Upgrade Java version to 8.
-* Upgrade log4j version to 2.23.1.
-* Upgrade slf4j version to 2.0.12.
+  - Upgrade Java version to 8.
+  - Upgrade log4j version to 2.23.1.
+  - Upgrade slf4j version to 2.0.12.
 
 2023-09-25 [version 1.13.4]
 	* [FEATURE] shutdown client after all of operations are processed

checkstyle.xml

@@ -161,7 +161,7 @@
         </module>
         -->
         <module name="JavadocMethod">
-            <property name="scope" value="public"/>
+            <property name="accessModifiers" value="public"/>
             <property name="allowMissingParamTags" value="true"/>
             <property name="allowMissingReturnTag" value="true"/>
             <property name="allowedAnnotations" value="Override, Test"/>

docs/arcus-java-client-getting-started.md

@@ -63,12 +63,17 @@ $ mvn eclipse:eclipse // 이클립스 IDE를 사용하는 경우 실행하여 
     </properties>
 
     <dependencies>
-        <!-- 편의상 JUnit 버전을 4.x로 변경합니다. -->
         <dependency>
-            <groupId>junit</groupId>
-            <artifactId>junit</artifactId>
-            <version>4.4</version>
-            <scope>test</scope>
+          <groupId>org.junit.jupiter</groupId>
+          <artifactId>junit-jupiter-api</artifactId>
+          <version>5.10.2</version>
+          <scope>test</scope>
+        </dependency>
+        <dependency>
+          <groupId>org.junit.jupiter</groupId>
+          <artifactId>junit-jupiter-engine</artifactId>
+          <version>5.10.2</version>
+          <scope>test</scope>
         </dependency>
 
         <!-- ARCUS 클라이언트 의존성을 추가합니다. -->
@@ -109,23 +114,22 @@ $ mvn eclipse:eclipse // 이클립스 IDE를 사용하는 경우 실행하여 
 // HelloArcusTest.java
 package com.navercorp.arcus;
 
-import org.junit.Assert;
+import org.junit.jupiter.api.BeforeEach;
 
-import org.junit.Before;
-import org.junit.Test;
+import static org.junit.jupiter.api.Assertions.assertEquals;
 
 public class HelloArcusTest {
 
     HelloArcus helloArcus = new HelloArcus("127.0.0.1:2181", "test");
 
-    @Before
-    public void sayHello() {
+    @BeforeEach
+    protected void sayHello() {
         helloArcus.sayHello();
     }
 
     @Test
     public void listenHello() {
-        Assert.assertEquals("Hello, Arcus!", helloArcus.listenHello());
+        assertEquals("Hello, Arcus!", helloArcus.listenHello());
     }
 
 }

docs/user_guide/02-arcus-java-client.md

@@ -518,7 +518,7 @@ ArcusClient client = new ArcusClient(SERVICE_CODE, factory);
   명령어의 내용을 담는 operation 큐를 생성한다. 기본적으로 크기가 16,384인 큐를 사용한다.
   큐의 크기를 1000으로 변경하고 싶다면 setOpQueueFactory(new ArrayOperationQueueFactory(1000))으로 설정하면 된다.
 
-- setTranscoder(Transcoder<Object> t)
+- setTranscoder(Transcoder\<Object\> t)
 
   캐시의 데이터 영역에 대한 character set과 압축 기준을 설정한다.
   GZip 압축을 사용하며, 기본값은 UTF-8과 16,384 byte이다.
@@ -533,6 +533,11 @@ ArcusClient client = new ArcusClient(SERVICE_CODE, factory);
   trans.setCompressionThreshold(4096);
   setTranscoder(trans);
   ```
+  직접 ClassLoader 객체를 지정해 사용할 수 있다. Spring Devtools와 같이 클래스로더를 별도로 두는
+  라이브러리를 사용할 때 캐시에서 조회하여 역직렬화 할 때 사용하는 클래스 로더와 프로세스에서 사용되고 있는 클래스 로더를 일치시키기 위해 사용한다.
+  ```java
+  SerializingTranscoder tc = new SerializingTranscoder(CachedData.MAX_SIZE, this.getClass().getClassLoader());
+  ```
 
 - setShouldOptimize(boolean o)
 

docs/user_guide/03-key-value-API.md

@@ -66,9 +66,9 @@ Future<Map<String, OperationStatus>> asyncStoreBulk(StoreType type, List<String>
 Future<Map<String, OperationStatus>> asyncStoreBulk(StoreType type, Map<String, Object> map, int exp)
 ```
 
-- 다수의 key-value item을 한번에 저장한다.
-  - 전자 API는 key list의 모든 key에 대해 동일한 obj로 저장 연산을 한번에 수행한다.  
-  - 후자 API는 map에 있는 모든 \<key, obj\>에 대해 저장 연산을 한번에 수행한다.
+- 다수의 key-value item을 한 번에 저장한다.
+  - 전자 API는 key list의 모든 key에 대해 동일한 obj로 저장 연산을 한 번에 수행한다.  
+  - 후자 API는 map에 있는 모든 \<key, obj\>에 대해 저장 연산을 한 번에 수행한다.
 - 저장된 key-value item들은 모두 exp 초 이후에 삭제된다.
 - StoreType은 연산의 저장 유형을 지정한다. 아래의 유형이 있다.
   - StoreType.set
@@ -106,7 +106,7 @@ future.get(key).getStatusCode() | 설명
 --------------------------------| ---------
 StatusCode.SUCCESS              | 조회 성공(key에 해당하는 item 존재하지 않아도 성공)
 
-여러 key들의 value를 한번에 조회하는 bulk API를 제공한다.
+여러 key들의 value를 한 번에 조회하는 bulk API를 제공한다.
 
 ```java
 BulkFuture<Map<String, Object>> asyncGetBulk(Collection<String> keys)
@@ -130,7 +130,7 @@ future.get(key).getStatusCode() | 설명
 --------------------------------| ---------
 StatusCode.SUCCESS              | 조회 성공(key에 해당하는 item 존재하지 않아도 성공)
 
-여러 key들의 CASValue를 한번에 조회하는 bulk API를 제공한다.
+여러 key들의 CASValue를 한 번에 조회하는 bulk API를 제공한다.
 
 ```java
 BulkFuture<Map<String, CASValue<Object>>> asyncGetsBulk(Collection<String> keys)
@@ -176,7 +176,7 @@ StatusCode.ERR_NOT_FOUND                    | 증감 실패 (Key miss, 주어진
 ## Key-Value Item 삭제
 
 하나의 key에 대한 item을 삭제하는 API와
-여러 key들의 item들을 한번에 삭제하는 bulk API를 제공한다.
+여러 key들의 item들을 한 번에 삭제하는 bulk API를 제공한다.
 
 ```java
 OperationFuture<Boolean> delete(String key)
@@ -196,7 +196,7 @@ Future<Map<String, OperationStatus>> asyncDeleteBulk(List<String> key)
 Future<Map<String, OperationStatus>> asyncDeleteBulk(String... key)
 ```
 
-- 다수의 key-value item을 한번에 delete한다.
+- 다수의 key-value item을 한 번에 delete한다.
 - 다수 key들은 String 유형의 List이거나 String 유형의 나열된 key 목록일 수 있다.
 
 delete 실패한 키와 실패 원인은 future 객체를 통해 Map 형태로 조회할 수 있다.

docs/user_guide/04-list-API.md

@@ -16,7 +16,7 @@ List item에 대해 수행가능한 기본 연산들은 아래와 같다.
 - [List Element 삭제](04-list-API.md#list-element-삭제) 
 - [List Element 조회](04-list-API.md#list-element-조회)
 
-여러 list element들에 대해 한번에 일괄 수행하는 연산은 다음과 같다.
+여러 list element들에 대해 한 번에 일괄 수행하는 연산은 다음과 같다.
 
 - [List Element 일괄 삽입](04-list-API.md#list-element-일괄-삽입)
 

docs/user_guide/05-set-API.md

@@ -16,7 +16,7 @@ Set item에 수행가능한 기본 연산들은 다음과 같다.
 - [Set Element 존재여부 확인](05-set-API.md#set-element-존재여부-확인)
 - [Set Element 조회](05-set-API.md#set-element-조회)
 
-여러 set element들에 대해 한번에 일괄 수행하는 연산은 다음과 같다.
+여러 set element들에 대해 한 번에 일괄 수행하는 연산은 다음과 같다.
 
 - [Set Element 일괄 삽입](05-set-API.md#set-element-일괄-삽입)
 - [Set Element 일괄 존재여부 확인](05-set-API.md#set-element-일괄-존재여부-확인)
@@ -352,7 +352,7 @@ try {
 
 ## Set Element 일괄 삽입
 
-Set에 여러 element를 한번에 삽입하는 함수는 두 가지가 있다.
+Set에 여러 element를 한 번에 삽입하는 함수는 두 가지가 있다.
 
 첫째, 하나의 key가 가리키는 set에 다수의 element를 삽입하는 함수이다.
 
@@ -440,7 +440,7 @@ try {
 
 ## Set Element 일괄 존재여부 확인
 
-Set에서 여러 element의 존재여부를 한번에 확인하는 함수이다.
+Set에서 여러 element의 존재여부를 한 번에 확인하는 함수이다.
 
 ```java
 CollectionFuture<Map<Object, Boolean>> asyncSopPipedExistBulk(String key, List<Object> values)

docs/user_guide/06-map-API.md

@@ -17,7 +17,7 @@ Map item에 대해 수행가능한 기본 연산은 다음과 같다.
 - [Map Element 삭제](06-map-API.md#map-element-삭제)
 - [Map Element 조회](06-map-API.md#map-element-조회)
 
-여러 map element들에 대해 한번에 일괄 수행하는 연산은 다음과 같다.
+여러 map element들에 대해 한 번에 일괄 수행하는 연산은 다음과 같다.
 
 - [Map Element 일괄 삽입](06-map-API.md#map-element-일괄-삽입)
 - [Map Element 일괄 변경](06-map-API.md#map-element-일괄-변경)
@@ -416,7 +416,7 @@ try {
 }
 ```
 
-1. map에서 mkey1, mkey2를 한번에 조회하기 위해 List에 add하고 mkeyList를 조회했다.
+1. map에서 mkey1, mkey2를 한 번에 조회하기 위해 List에 add하고 mkeyList를 조회했다.
 2. timeout은 1초로 지정했다. 지정한 시간에 조회 결과가 넘어 오지 않거나
    JVM의 과부하로 operation queue에서 처리되지 않을 경우 TimeoutException이 발생한다.
    반환되는 Map 인터페이스의 구현체는 HashMap이며, 그 결과는 다음 중의 하나이다.
@@ -428,7 +428,7 @@ try {
 
 ## Map Element 일괄 삽입
 
-Map에 여러 element를 한번에 삽입하는 함수는 두 유형이 있다.
+Map에 여러 element를 한 번에 삽입하는 함수는 두 유형이 있다.
 
 첫째, 하나의 key가 가리키는 Map에 다수의 element를 삽입하는 함수이다.
 

docs/user_guide/07-btree-API.md

@@ -29,7 +29,7 @@ B+tree item에 대해 수행가능한 기본 연산은 다음과 같다.
 - [B+Tree Element 개수 계산](07-btree-API.md#btree-element-개수-계산)
 - [B+Tree Element 조회](07-btree-API.md#btree-element-조회)
 
-여러 b+tree element들에 대해 한번에 일괄 수행하는 연산은 다음과 같다.
+여러 b+tree element들에 대해 한 번에 일괄 수행하는 연산은 다음과 같다.
 
 - [B+Tree Element 일괄 삽입](07-btree-API.md#btree-element-일괄-삽입)
 - [B+Tree Element 일괄 변경](07-btree-API.md#btree-element-일괄-변경)
@@ -953,7 +953,7 @@ try {
 
 ## B+Tree Element 일괄 삽입
 
-B+tree에 여러 element를 한번에 삽입하는 함수는 두 유형이 있다.
+B+tree에 여러 element를 한 번에 삽입하는 함수는 두 유형이 있다.
 
 첫째, 하나의 key가 가리키는 b+tree에 다수의 element를 삽입하는 함수이다.
 

docs/user_guide/10-log-message.md

@@ -8,7 +8,7 @@ Java client에서 남기는 로그들과 그것들이 의미하는 바는 아래
 ARCUS client가 정상적으로 초기화 되면 다음과 같은 로그를 남긴다.
 
 ```java
-INFO net.spy.memcached.CacheManager: CacheManager started. ([mailto:dev@dev.arcuscloud.nhncorp.com:17288 dev@dev.arcuscloud.nhncorp.com:17288])
+INFO net.spy.memcached.CacheManager: CacheManager started. ([mailto:dev@dev.arcuscloud.jam2in.com:2181 dev@dev.arcuscloud.jam2in.com:2181])
 
 WARN net.spy.memcached.CacheMonitor: Cache list has been changed : From=null, To=[127.0.0.1:11211-hostname, xxx.xxx.xxx.xxx:xxxx-hostname] : [serviceCode=dev]