org.apache.paimon.rest

Class RESTApi

java.lang.Object

org.apache.paimon.rest.RESTApi

@Public
public class RESTApi
extends Object

REST API for REST Catalog.

This API class only includes interaction with REST Server and does not have file read and write operations, which makes this API lightweight enough to avoid introducing dependencies such as Hadoop and file systems.

The following example show how to use the RESTApi:

 Options options = new Options();
 options.set(URI, "<rest 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);
 

This class also provide util methods for serializing json toJson(T) and deserializing json fromJson(java.lang.String, java.lang.Class<T>).

Since:

1.2.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATABASE_NAME_PATTERN
static String	HEADER_PREFIX
static String	MAX_RESULTS
static org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.ObjectMapper	OBJECT_MAPPER
static String	PAGE_TOKEN
static String	PARTITION_NAME_PATTERN
static String	TABLE_NAME_PATTERN
static long	TOKEN_EXPIRATION_SAFE_TIME_MILLIS
static String	VIEW_NAME_PATTERN

Constructor Summary

Constructors

Constructor and Description
RESTApi(Options options) Initializes a newly created RESTApi object.
RESTApi(Options options, boolean configRequired) Initializes a newly created RESTApi object.

Method Summary

Modifier and Type	Method and Description
void	alterDatabase(String name, List<String> removals, Map<String,String> updates) Alter a database.
void	alterFunction(Identifier identifier, List<FunctionChange> changes) Alter a function.
void	alterTable(Identifier identifier, List<SchemaChange> changes) Alter table.
void	alterView(Identifier identifier, List<ViewChange> viewChanges) Alter view.
List<String>	authTableQuery(Identifier identifier, List<String> select) Auth table query.
boolean	commitSnapshot(Identifier identifier, Snapshot snapshot, List<PartitionStatistics> statistics) Commit snapshot for table.
void	createBranch(Identifier identifier, String branch, String fromTag) Create branch for table.
void	createDatabase(String name, Map<String,String> properties) Create a database.
void	createFunction(Identifier identifier, Function function) Create a function.
void	createTable(Identifier identifier, Schema schema) Create table.
void	createView(Identifier identifier, ViewSchema schema) Create view.
void	dropBranch(Identifier identifier, String branch) Drop branch for table.
void	dropDatabase(String name) Drop a database.
void	dropFunction(Identifier identifier) Drop a function.
void	dropTable(Identifier identifier) Drop table.
void	dropView(Identifier identifier) Drop view.
void	fastForward(Identifier identifier, String branch) Forward branch for table.
static <T> T	fromJson(String json, Class<T> clazz) Util method to deserialize object from json.
GetDatabaseResponse	getDatabase(String name) Get a database.
GetFunctionResponse	getFunction(Identifier identifier) Get a function by identifier.
GetTableResponse	getTable(Identifier identifier) Get table.
GetViewResponse	getView(Identifier identifier) Get view.
List<String>	listBranches(Identifier identifier) List branches for table.
List<String>	listDatabases() List databases.
PagedList<String>	listDatabasesPaged(Integer maxResults, String pageToken, String databaseNamePattern) List databases.
List<String>	listFunctions(String databaseName) List functions for database.
List<Partition>	listPartitions(Identifier identifier) List partitions for table.
PagedList<Partition>	listPartitionsPaged(Identifier identifier, Integer maxResults, String pageToken, String partitionNamePattern) List partitions for a table.
PagedList<GetTableResponse>	listTableDetailsPaged(String databaseName, Integer maxResults, String pageToken, String tableNamePattern) List table details for a database.
List<String>	listTables(String databaseName) List tables for a database.
PagedList<String>	listTablesPaged(String databaseName, Integer maxResults, String pageToken, String tableNamePattern) List tables for a database.
PagedList<String>	listTablesPagedGlobally(String databaseNamePattern, String tableNamePattern, Integer maxResults, String pageToken) List table for a catalog.
PagedList<GetViewResponse>	listViewDetailsPaged(String databaseName, Integer maxResults, String pageToken, String viewNamePattern) List view details.
List<String>	listViews(String databaseName) List views for a database.
PagedList<String>	listViewsPaged(String databaseName, Integer maxResults, String pageToken, String viewNamePattern) List views.
PagedList<String>	listViewsPagedGlobally(String databaseNamePattern, String viewNamePattern, Integer maxResults, String pageToken) List views for a catalog.
TableSnapshot	loadSnapshot(Identifier identifier) Load latest snapshot for table.
GetTableTokenResponse	loadTableToken(Identifier identifier) Load token for File System of this table.
void	markDonePartitions(Identifier identifier, List<Map<String,String>> partitions) Mark done partitions for table.
Options	options() Get the configured options which has been merged from REST Server.
void	renameTable(Identifier fromTable, Identifier toTable) Rename table.
void	renameView(Identifier fromView, Identifier toView) Rename view.
void	rollbackTo(Identifier identifier, Instant instant) Rollback instant for table.
static <T> String	toJson(T t) Util method to serialize object to json.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

HEADER_PREFIX

public static final String HEADER_PREFIX

See Also:

Constant Field Values

MAX_RESULTS

public static final String MAX_RESULTS

See Also:

Constant Field Values

PAGE_TOKEN

public static final String PAGE_TOKEN

See Also:

Constant Field Values

DATABASE_NAME_PATTERN

public static final String DATABASE_NAME_PATTERN

See Also:

Constant Field Values

TABLE_NAME_PATTERN

public static final String TABLE_NAME_PATTERN

See Also:

Constant Field Values

VIEW_NAME_PATTERN

public static final String VIEW_NAME_PATTERN

See Also:

Constant Field Values

PARTITION_NAME_PATTERN

public static final String PARTITION_NAME_PATTERN

See Also:

Constant Field Values

TOKEN_EXPIRATION_SAFE_TIME_MILLIS

public static final long TOKEN_EXPIRATION_SAFE_TIME_MILLIS

See Also:

Constant Field Values

OBJECT_MAPPER

public static final org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER

Constructor Detail

RESTApi

public RESTApi(Options options)

Initializes a newly created RESTApi object.

By default, configRequired is true, this means that there will be one REST request to merge configurations during initialization.

Parameters:

options - contains authentication and catalog information for REST Server

RESTApi

public RESTApi(Options options,
               boolean configRequired)

Initializes a newly created RESTApi object.

If the options are already obtained through options(), you can configure configRequired to be false.

Parameters:

options - contains authentication and catalog information for REST Server

configRequired - is there one REST request to merge configurations during initialization

Method Detail

options

public Options options()

Get the configured options which has been merged from REST Server.

listDatabases

public List<String> listDatabases()

List databases.

Gets an array of databases for a catalog. There is no guarantee of a specific ordering of the elements in the array.

listDatabasesPaged

public PagedList<String> listDatabasesPaged(@Nullable
                                            Integer maxResults,
                                            @Nullable
                                            String pageToken,
                                            @Nullable
                                            String databaseNamePattern)

List databases.

Gets an array of databases for a catalog. There is no guarantee of a specific ordering of the elements in the array.

Parameters:

maxResults - Optional parameter indicating the maximum number of results to include in the result. If maxResults is not specified or set to 0, will return the default number of max results.

pageToken - Optional parameter indicating the next page token allows list to be start from a specific point.

Returns:

PagedList: elements and nextPageToken.

createDatabase

public void createDatabase(String name,
                           Map<String,String> properties)

Create a database.

Parameters:

name - name of this database

Throws:

AlreadyExistsException - Exception thrown on HTTP 409 means a database already exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

getDatabase

public GetDatabaseResponse getDatabase(String name)

Get a database.

Parameters:

name - name of this database

Returns:

GetDatabaseResponse

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

dropDatabase

public void dropDatabase(String name)

Drop a database.

Parameters:

name - name of this database

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

alterDatabase

public void alterDatabase(String name,
                          List<String> removals,
                          Map<String,String> updates)

Alter a database.

Parameters:

name - name of this database

removals - options to be removed

updates - options to be updated or added

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

listTables

public List<String> listTables(String databaseName)

List tables for a database.

Parameters:

databaseName - name of this database

Returns:

a list of table names

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

listTablesPaged

public PagedList<String> listTablesPaged(String databaseName,
                                         @Nullable
                                         Integer maxResults,
                                         @Nullable
                                         String pageToken,
                                         @Nullable
                                         String tableNamePattern)

List tables for a database.

Gets an array of tables for a database. There is no guarantee of a specific ordering of the elements in the array.

Parameters:

databaseName - name of database.

maxResults - Optional parameter indicating the maximum number of results to include in the result. If maxResults is not specified or set to 0, will return the default number of max results.

pageToken - Optional parameter indicating the next page token allows list to be start from a specific point.

tableNamePattern - A sql LIKE pattern (%) for table names. All tables will be returned if not set or empty. Currently, only prefix matching is supported.

Returns:

PagedList: elements and nextPageToken.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

listTableDetailsPaged

public PagedList<GetTableResponse> listTableDetailsPaged(String databaseName,
                                                         @Nullable
                                                         Integer maxResults,
                                                         @Nullable
                                                         String pageToken,
                                                         @Nullable
                                                         String tableNamePattern)

List table details for a database.

Gets an array of table details for a database. There is no guarantee of a specific ordering of the elements in the array.

Parameters:

databaseName - name of database.

maxResults - Optional parameter indicating the maximum number of results to include in the result. If maxResults is not specified or set to 0, will return the default number of max results.

pageToken - Optional parameter indicating the next page token allows list to be start from a specific point.

tableNamePattern - A sql LIKE pattern (%) for table names. All tables will be returned if not set or empty. Currently, only prefix matching is supported.

Returns:

PagedList: elements and nextPageToken.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

listTablesPagedGlobally

public PagedList<String> listTablesPagedGlobally(@Nullable
                                                 String databaseNamePattern,
                                                 @Nullable
                                                 String tableNamePattern,
                                                 @Nullable
                                                 Integer maxResults,
                                                 @Nullable
                                                 String pageToken)

List table for a catalog.

Gets an array of table for a catalog. There is no guarantee of a specific ordering of the elements in the array.

Parameters:

databaseNamePattern - A sql LIKE pattern (%) for database names. All databases will be returned if not set or empty. Currently, only prefix matching is supported.

tableNamePattern - A sql LIKE pattern (%) for table names. All tables will be returned if not set or empty. Currently, only prefix matching is supported.

maxResults - Optional parameter indicating the maximum number of results to include in the result. If maxResults is not specified or set to 0, will return the default number of max results.

pageToken - Optional parameter indicating the next page token allows list to be start from a specific point.

Returns:

PagedList: elements and nextPageToken.

Throws:

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

getTable

public GetTableResponse getTable(Identifier identifier)

Get table.

Parameters:

identifier - database name and table name.

Returns:

GetTableResponse

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

loadSnapshot

public TableSnapshot loadSnapshot(Identifier identifier)

Load latest snapshot for table.

Parameters:

identifier - database name and table name.

Returns:

TableSnapshot Optional snapshot.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table or the latest snapshot not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

commitSnapshot

public boolean commitSnapshot(Identifier identifier,
                              Snapshot snapshot,
                              List<PartitionStatistics> statistics)

Commit snapshot for table.

Parameters:

identifier - database name and table name.

snapshot - snapshot for committing

statistics - statistics for this snapshot incremental

Returns:

true if commit success

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

rollbackTo

public void rollbackTo(Identifier identifier,
                       Instant instant)

Rollback instant for table.

Parameters:

identifier - database name and table name.

instant - instant to rollback

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table or the snapshot or the tag not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

createTable

public void createTable(Identifier identifier,
                        Schema schema)

Create table.

Parameters:

identifier - database name and table name.

schema - schema to create table

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

AlreadyExistsException - Exception thrown on HTTP 409 means a table already exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for creating table

renameTable

public void renameTable(Identifier fromTable,
                        Identifier toTable)

Rename table.

Parameters:

fromTable - from table

toTable - to table

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the fromTable not exists

AlreadyExistsException - Exception thrown on HTTP 409 means the toTable already exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for renaming table

alterTable

public void alterTable(Identifier identifier,
                       List<SchemaChange> changes)

Alter table.

Parameters:

identifier - database name and table name.

changes - changes to alter table

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

authTableQuery

public List<String> authTableQuery(Identifier identifier,
                                   @Nullable
                                   List<String> select)

Auth table query.

Parameters:

identifier - database name and table name.

select - select columns, null if select all

Returns:

additional filter for row level access control

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

dropTable

public void dropTable(Identifier identifier)

Drop table.

Parameters:

identifier - database name and table name.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

markDonePartitions

public void markDonePartitions(Identifier identifier,
                               List<Map<String,String>> partitions)

Mark done partitions for table.

Parameters:

identifier - database name and table name.

partitions - partitions to be marked done

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

listPartitions

public List<Partition> listPartitions(Identifier identifier)

List partitions for table.

Parameters:

identifier - database name and table name.

Returns:

a list for partitions

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

listPartitionsPaged

public PagedList<Partition> listPartitionsPaged(Identifier identifier,
                                                @Nullable
                                                Integer maxResults,
                                                @Nullable
                                                String pageToken,
                                                @Nullable
                                                String partitionNamePattern)

List partitions for a table.

Gets an array of partitions for a table. There is no guarantee of a specific ordering of the elements in the array.

Parameters:

identifier - database name and table name.

maxResults - Optional parameter indicating the maximum number of results to include in the result. If maxResults is not specified or set to 0, will return the default number of max results.

pageToken - Optional parameter indicating the next page token allows list to be start from a specific point.

partitionNamePattern - A sql LIKE pattern (%) for partition names. All partitions will be returned if not set or empty. Currently, only prefix matching is supported.

Returns:

PagedList: elements and nextPageToken.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

createBranch

public void createBranch(Identifier identifier,
                         String branch,
                         @Nullable
                         String fromTag)

Create branch for table.

Parameters:

identifier - database name and table name.

branch - branch name

fromTag - optional from tag

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table or fromTag not exists

AlreadyExistsException - Exception thrown on HTTP 409 means the branch already exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

dropBranch

public void dropBranch(Identifier identifier,
                       String branch)

Drop branch for table.

Parameters:

identifier - database name and table name.

branch - branch name

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the branch not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

fastForward

public void fastForward(Identifier identifier,
                        String branch)

Forward branch for table.

Parameters:

identifier - database name and table name.

branch - branch name

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the branch or table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

listBranches

public List<String> listBranches(Identifier identifier)

List branches for table.

Parameters:

identifier - database name and table name.

Returns:

a list of branches

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

listFunctions

public List<String> listFunctions(String databaseName)

List functions for database.

Parameters:

databaseName - database name

Returns:

a list of function name

getFunction

public GetFunctionResponse getFunction(Identifier identifier)

Get a function by identifier.

Parameters:

identifier - the identifier of the function to retrieve

Returns:

the function response object

Throws:

NoSuchResourceException - if the function does not exist

ForbiddenException - if the user lacks permission to access the function

createFunction

public void createFunction(Identifier identifier,
                           Function function)

Create a function.

Parameters:

identifier - database name and function name.

function - the function to be created

Throws:

AlreadyExistsException - Exception thrown on HTTP 409 means a function already exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for creating function

dropFunction

public void dropFunction(Identifier identifier)

Drop a function.

Parameters:

identifier - database name and function name.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the function not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this function

alterFunction

public void alterFunction(Identifier identifier,
                          List<FunctionChange> changes)

Alter a function.

Parameters:

identifier - database name and function name.

changes - list of function changes to apply

Throws:

NoSuchResourceException - if the function does not exist

ForbiddenException - if the user lacks permission to modify the function

getView

public GetViewResponse getView(Identifier identifier)

Get view.

Parameters:

identifier - database name and view name.

Returns:

GetViewResponse

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the view not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this view

dropView

public void dropView(Identifier identifier)

Drop view.

Parameters:

identifier - database name and view name.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the view not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this view

createView

public void createView(Identifier identifier,
                       ViewSchema schema)

Create view.

Parameters:

identifier - database name and view name.

schema - schema of the view

Throws:

AlreadyExistsException - Exception thrown on HTTP 409 means the view already exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this view

listViews

public List<String> listViews(String databaseName)

List views for a database.

Parameters:

databaseName - name of this database

Returns:

a list of view names

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

listViewsPaged

public PagedList<String> listViewsPaged(String databaseName,
                                        @Nullable
                                        Integer maxResults,
                                        @Nullable
                                        String pageToken,
                                        @Nullable
                                        String viewNamePattern)

List views.

Gets an array of views for a database. There is no guarantee of a specific ordering of the elements in the array.

Parameters:

databaseName - database name

maxResults - Optional parameter indicating the maximum number of results to include in the result. If maxResults is not specified or set to 0, will return the default number of max results.

pageToken - Optional parameter indicating the next page token allows list to be start from a specific point.

viewNamePattern - A sql LIKE pattern (%) for view names. All views will be returned if not set or empty. Currently, only prefix matching is supported.

Returns:

PagedList: elements and nextPageToken.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

listViewDetailsPaged

public PagedList<GetViewResponse> listViewDetailsPaged(String databaseName,
                                                       @Nullable
                                                       Integer maxResults,
                                                       @Nullable
                                                       String pageToken,
                                                       @Nullable
                                                       String viewNamePattern)

List view details.

Gets an array of view details for a database. There is no guarantee of a specific ordering of the elements in the array.

Parameters:

databaseName - database name

maxResults - Optional parameter indicating the maximum number of results to include in the result. If maxResults is not specified or set to 0, will return the default number of max results.

pageToken - Optional parameter indicating the next page token allows list to be start from a specific point.

viewNamePattern - A sql LIKE pattern (%) for view names. All views will be returned if not set or empty. Currently, only prefix matching is supported.

Returns:

PagedList: elements and nextPageToken.

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the database not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

listViewsPagedGlobally

public PagedList<String> listViewsPagedGlobally(@Nullable
                                                String databaseNamePattern,
                                                @Nullable
                                                String viewNamePattern,
                                                @Nullable
                                                Integer maxResults,
                                                @Nullable
                                                String pageToken)

List views for a catalog.

Gets an array of views for a catalog. There is no guarantee of a specific ordering of the elements in the array.

Parameters:

databaseNamePattern - A sql LIKE pattern (%) for database names. All databases will be returned if not set or empty. Currently, only prefix matching is supported.

viewNamePattern - A sql LIKE pattern (%) for view names. All views will be returned if not set or empty. Currently, only prefix matching is supported.

maxResults - Optional parameter indicating the maximum number of results to include in the result. If maxResults is not specified or set to 0, will return the default number of max results.

pageToken - Optional parameter indicating the next page token allows list to be start from a specific point.

Returns:

PagedList: elements and nextPageToken.

Throws:

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this database

renameView

public void renameView(Identifier fromView,
                       Identifier toView)

Rename view.

Parameters:

fromView - from view

toView - to view

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means fromView not exists

AlreadyExistsException - Exception thrown on HTTP 409 means toView already exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for views

alterView

public void alterView(Identifier identifier,
                      List<ViewChange> viewChanges)

Alter view.

Parameters:

identifier - database name and view name.

viewChanges - view changes

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the view not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this view

loadTableToken

public GetTableTokenResponse loadTableToken(Identifier identifier)

Load token for File System of this table.

Parameters:

identifier - database name and view name.

Returns:

GetTableTokenResponse

Throws:

NoSuchResourceException - Exception thrown on HTTP 404 means the table not exists

ForbiddenException - Exception thrown on HTTP 403 means don't have the permission for this table

fromJson

public static <T> T fromJson(String json,
                             Class<T> clazz)
                      throws org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException

Util method to deserialize object from json.

Throws:

org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException

toJson

public static <T> String toJson(T t)
                         throws org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException

Util method to serialize object to json.

Throws:

org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException