[core] Introduce paimon-api module for light rest api, part 3

Author: JingsongLi

docs/content/concepts/rest/overview.md

@@ -62,3 +62,11 @@ RESTCatalog supports multiple access authentication methods, including the follo
 
 1. [Bear Token]({{< ref "concepts/rest/bear" >}}).
 2. [DLF Token]({{< ref "concepts/rest/dlf" >}}).
+
+## REST Open API
+
+See [REST API]({{< ref "concepts/rest/rest-api" >}}).
+
+## REST Java API
+
+See [REST Java API]({{< ref "program-api/rest-api" >}}).

docs/content/program-api/catalog-api.md

@@ -1,6 +1,6 @@
 ---
 title: "Catalog API"
-weight: 3
+weight: 4
 type: docs
 aliases:
 - /api/catalog-api.html

docs/content/program-api/flink-api.md

@@ -1,6 +1,6 @@
 ---
 title: "Flink API"
-weight: 1
+weight: 2
 type: docs
 aliases:
 - /api/flink-api.html

docs/content/program-api/java-api.md

@@ -1,6 +1,6 @@
 ---
 title: "Java API"
-weight: 2
+weight: 3
 type: docs
 aliases:
 - /api/java-api.html

docs/content/program-api/python-api.md

@@ -1,6 +1,6 @@
 ---
 title: "Python API"
-weight: 4
+weight: 5
 type: docs
 aliases:
 - /api/python-api.html

docs/content/program-api/rest-api.md

@@ -0,0 +1,78 @@
+---
+title: "REST API"
+weight: 1
+type: docs
+aliases:
+- /api/rest-api.html
+---
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements.  See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership.  The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License.  You may obtain a copy of the License at
+
+  http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied.  See the License for the
+specific language governing permissions and limitations
+under the License.
+-->
+
+# REST API
+
+This is Java API for [REST]({{< ref "concepts/rest/overview" >}}).
+
+## Dependency
+
+Maven dependency:
+
+```xml
+<dependency>
+  <groupId>org.apache.paimon</groupId>
+  <artifactId>paimon-api</artifactId>
+  <version>{{< version >}}</version>
+</dependency>
+```
+
+Or download the jar file:
+{{< stable >}}[Paimon API](https://repo.maven.apache.org/maven2/org/apache/paimon/paimon-api/{{< version >}}/paimon-api-{{< version >}}.jar).{{< /stable >}}
+{{< unstable >}}[Paimon API](https://repository.apache.org/snapshots/org/apache/paimon/paimon-api/{{< version >}}/).{{< /unstable >}}
+
+## RESTApi
+
+```java
+import org.apache.paimon.options.Options;
+import org.apache.paimon.rest.RESTApi;
+
+import java.util.List;
+
+import static org.apache.paimon.options.CatalogOptions.WAREHOUSE;
+import static org.apache.paimon.rest.RESTCatalogOptions.DLF_ACCESS_KEY_ID;
+import static org.apache.paimon.rest.RESTCatalogOptions.DLF_ACCESS_KEY_SECRET;
+import static org.apache.paimon.rest.RESTCatalogOptions.TOKEN_PROVIDER;
+import static org.apache.paimon.rest.RESTCatalogOptions.URI;
+
+public class RESTApiExample {
+
+    public static void main(String[] args) {
+        Options options = new Options();
+        options.set(URI, "<catalog server url>");
+        options.set(WAREHOUSE, "my_instance_name");
+        options.set(TOKEN_PROVIDER, "dlf");
+        options.set(DLF_ACCESS_KEY_ID, "<access-key-id>");
+        options.set(DLF_ACCESS_KEY_SECRET, "<access-key-secret>");
+
+        RESTApi api = new RESTApi(options);
+        List<String> tables = api.listTables("my_database");
+        System.out.println(tables);
+    }
+}
+```
+
+See more methods in `'RESTApi'`.

paimon-api/README.md

@@ -1,7 +1,7 @@
 ## Paimon API
 
-This module is for light API, aims to simplify dependencies as much as possible and avoid
+This module is for light SDK, aims to simplify dependencies as much as possible and avoid
 introducing dependencies such as Hadoop, including:
 
-1. Including types, table, view, function and etc.
-2. Including http client REST API.
+1. Including types, table, view, function etc.
+2. Including http client REST API, See `'RESTApi'`.

…in/java/org/apache/paimon/PagedList.java …in/java/org/apache/paimon/PagedList.javapaimon-common/src/main/java/org/apache/paimon/PagedList.java renamed to paimon-api/src/main/java/org/apache/paimon/PagedList.java paimon-common/src/main/java/org/apache/paimon/PagedList.java renamed to paimon-api/src/main/java/org/apache/paimon/PagedList.java

@@ -28,6 +28,7 @@
  * @since 1.1.0
  */
 public class PagedList<T> {
+
     private final List<T> elements;
 
     @Nullable private final String nextPageToken;

paimon-api/src/main/java/org/apache/paimon/rest/HttpClient.java

@@ -47,7 +47,6 @@
 import static okhttp3.ConnectionSpec.MODERN_TLS;
 import static org.apache.paimon.rest.LoggingInterceptor.DEFAULT_REQUEST_ID;
 import static org.apache.paimon.rest.LoggingInterceptor.REQUEST_ID_KEY;
-import static org.apache.paimon.rest.RESTObjectMapper.OBJECT_MAPPER;
 
 /** HTTP client for REST catalog. */
 public class HttpClient implements RESTClient {
@@ -125,7 +124,7 @@ public <T extends RESTResponse> T post(
             Class<T> responseType,
             RESTAuthFunction restAuthFunction) {
         try {
-            String bodyStr = OBJECT_MAPPER.writeValueAsString(body);
+            String bodyStr = RESTApi.toJson(body);
             Map<String, String> authHeaders = getHeaders(path, "POST", bodyStr, restAuthFunction);
             RequestBody requestBody = buildRequestBody(bodyStr);
             Request request =
@@ -156,7 +155,7 @@ public <T extends RESTResponse> T delete(String path, RESTAuthFunction restAuthF
     public <T extends RESTResponse> T delete(
             String path, RESTRequest body, RESTAuthFunction restAuthFunction) {
         try {
-            String bodyStr = OBJECT_MAPPER.writeValueAsString(body);
+            String bodyStr = RESTApi.toJson(body);
             Map<String, String> authHeaders = getHeaders(path, "DELETE", bodyStr, restAuthFunction);
             RequestBody requestBody = buildRequestBody(bodyStr);
             Request request =
@@ -190,7 +189,7 @@ private <T extends RESTResponse> T exec(Request request, Class<T> responseType)
             if (!response.isSuccessful()) {
                 ErrorResponse error;
                 try {
-                    error = OBJECT_MAPPER.readValue(responseBodyStr, ErrorResponse.class);
+                    error = RESTApi.fromJson(responseBodyStr, ErrorResponse.class);
                 } catch (JsonProcessingException e) {
                     error =
                             new ErrorResponse(
@@ -205,7 +204,7 @@ private <T extends RESTResponse> T exec(Request request, Class<T> responseType)
                 errorHandler.accept(error, requestId);
             }
             if (responseType != null && responseBodyStr != null) {
-                return OBJECT_MAPPER.readValue(responseBodyStr, responseType);
+                return RESTApi.fromJson(responseBodyStr, responseType);
             } else if (responseType == null) {
                 return null;
             } else {