Package org.apache.polaris.service.it.env

Class CatalogApi

java.lang.Object

org.apache.polaris.service.it.env.RestApi

org.apache.polaris.service.it.env.PolarisRestApi

org.apache.polaris.service.it.env.CatalogApi

public class CatalogApi
extends PolarisRestApi

A simple, non-exhaustive set of helper methods for accessing the Iceberg REST API.

See Also:

• PolarisClient.catalogApi(String)

Constructor Summary

Constructors

Constructor	Description
CatalogApi(jakarta.ws.rs.client.Client client, PolarisApiEndpoints endpoints, String authToken, URI uri)

Method Summary

Modifier and Type	Method	Description
void	createNamespace(String catalogName, String namespaceName)
void	deleteNamespace(String catalog, org.apache.iceberg.catalog.Namespace namespace)
void	dropTable(String catalog, org.apache.iceberg.catalog.TableIdentifier id)
void	dropView(String catalog, org.apache.iceberg.catalog.TableIdentifier id)
List<org.apache.iceberg.catalog.Namespace>	listAllNamespacesChildFirst(String catalog)
List<org.apache.iceberg.catalog.Namespace>	listNamespaces(String catalog, org.apache.iceberg.catalog.Namespace parent)
org.apache.iceberg.rest.responses.ListNamespacesResponse	listNamespaces(String catalog, org.apache.iceberg.catalog.Namespace parent, String pageToken, String pageSize)
List<org.apache.iceberg.catalog.TableIdentifier>	listTables(String catalog, org.apache.iceberg.catalog.Namespace namespace)
org.apache.iceberg.rest.responses.ListTablesResponse	listTables(String catalog, org.apache.iceberg.catalog.Namespace namespace, String pageToken, String pageSize)
List<org.apache.iceberg.catalog.TableIdentifier>	listViews(String catalog, org.apache.iceberg.catalog.Namespace namespace)
org.apache.iceberg.rest.responses.ListTablesResponse	listViews(String catalog, org.apache.iceberg.catalog.Namespace namespace, String pageToken, String pageSize)
org.apache.iceberg.rest.responses.LoadCredentialsResponse	loadCredentials(String catalog, org.apache.iceberg.catalog.TableIdentifier id)
org.apache.iceberg.rest.responses.LoadTableResponse	loadTable(String catalog, org.apache.iceberg.catalog.TableIdentifier id, String snapshots)
org.apache.iceberg.rest.responses.LoadTableResponse	loadTable(String catalog, org.apache.iceberg.catalog.TableIdentifier id, String snapshots, Map<String,String> headers)
org.apache.iceberg.rest.responses.LoadTableResponse	loadTableWithAccessDelegation(String catalog, org.apache.iceberg.catalog.TableIdentifier id, String snapshots)
void	purge(String catalog)
void	purge(String catalog, org.apache.iceberg.catalog.Namespace ns)
org.apache.iceberg.rest.responses.LoadTableResponse	registerTable(String catalog, org.apache.iceberg.catalog.Namespace namespace, String tableName, String metadataLocation, boolean overwrite)
org.apache.iceberg.rest.responses.LoadTableResponse	registerTable(String catalog, org.apache.iceberg.catalog.Namespace namespace, String tableName, String metadataLocation, boolean overwrite, Map<String,String> headers)
org.apache.iceberg.rest.responses.LoadTableResponse	registerTableWithAccessDelegation(String catalog, org.apache.iceberg.catalog.Namespace namespace, String tableName, String metadataLocation, boolean overwrite)
void	renameTable(String catalog, org.apache.iceberg.catalog.TableIdentifier source, org.apache.iceberg.catalog.TableIdentifier destination)

Methods inherited from class org.apache.polaris.service.it.env.PolarisRestApi

defaultHeaders, request

Methods inherited from class org.apache.polaris.service.it.env.RestApi

request, request, request, request

Methods inherited from class java.lang.Object

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

Constructor Details

CatalogApi

public CatalogApi(jakarta.ws.rs.client.Client client,
 PolarisApiEndpoints endpoints,
 String authToken,
 URI uri)

Method Details

createNamespace

public void createNamespace(String catalogName,
 String namespaceName)

listNamespaces

public List<org.apache.iceberg.catalog.Namespace> listNamespaces(String catalog,
 org.apache.iceberg.catalog.Namespace parent)

listNamespaces

public org.apache.iceberg.rest.responses.ListNamespacesResponse listNamespaces(String catalog,
 org.apache.iceberg.catalog.Namespace parent,
 String pageToken,
 String pageSize)

listAllNamespacesChildFirst

public List<org.apache.iceberg.catalog.Namespace> listAllNamespacesChildFirst(String catalog)

deleteNamespace

public void deleteNamespace(String catalog,
 org.apache.iceberg.catalog.Namespace namespace)

purge

public void purge(String catalog)

purge

public void purge(String catalog,
 org.apache.iceberg.catalog.Namespace ns)

listTables

public List<org.apache.iceberg.catalog.TableIdentifier> listTables(String catalog,
 org.apache.iceberg.catalog.Namespace namespace)

listTables

public org.apache.iceberg.rest.responses.ListTablesResponse listTables(String catalog,
 org.apache.iceberg.catalog.Namespace namespace,
 String pageToken,
 String pageSize)

renameTable

public void renameTable(String catalog,
 org.apache.iceberg.catalog.TableIdentifier source,
 org.apache.iceberg.catalog.TableIdentifier destination)

dropTable

public void dropTable(String catalog,
 org.apache.iceberg.catalog.TableIdentifier id)

registerTable

public org.apache.iceberg.rest.responses.LoadTableResponse registerTable(String catalog,
 org.apache.iceberg.catalog.Namespace namespace,
 String tableName,
 String metadataLocation,
 boolean overwrite)

registerTableWithAccessDelegation

public org.apache.iceberg.rest.responses.LoadTableResponse registerTableWithAccessDelegation(String catalog,
 org.apache.iceberg.catalog.Namespace namespace,
 String tableName,
 String metadataLocation,
 boolean overwrite)

registerTable

public org.apache.iceberg.rest.responses.LoadTableResponse registerTable(String catalog,
 org.apache.iceberg.catalog.Namespace namespace,
 String tableName,
 String metadataLocation,
 boolean overwrite,
 Map<String,String> headers)

loadTable

public org.apache.iceberg.rest.responses.LoadTableResponse loadTable(String catalog,
 org.apache.iceberg.catalog.TableIdentifier id,
 String snapshots)

loadTableWithAccessDelegation

public org.apache.iceberg.rest.responses.LoadTableResponse loadTableWithAccessDelegation(String catalog,
 org.apache.iceberg.catalog.TableIdentifier id,
 String snapshots)

loadCredentials

public org.apache.iceberg.rest.responses.LoadCredentialsResponse loadCredentials(String catalog,
 org.apache.iceberg.catalog.TableIdentifier id)

loadTable

public org.apache.iceberg.rest.responses.LoadTableResponse loadTable(String catalog,
 org.apache.iceberg.catalog.TableIdentifier id,
 String snapshots,
 Map<String,String> headers)

listViews

public List<org.apache.iceberg.catalog.TableIdentifier> listViews(String catalog,
 org.apache.iceberg.catalog.Namespace namespace)

listViews

public org.apache.iceberg.rest.responses.ListTablesResponse listViews(String catalog,
 org.apache.iceberg.catalog.Namespace namespace,
 String pageToken,
 String pageSize)

dropView

public void dropView(String catalog,
 org.apache.iceberg.catalog.TableIdentifier id)