Package org.apache.iceberg.nessie

Class NessieIcebergClient

java.lang.Object

org.apache.iceberg.nessie.NessieIcebergClient

All Implemented Interfaces:

AutoCloseable

public class NessieIcebergClient
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
NessieIcebergClient(org.projectnessie.client.api.NessieApiV1 api, String requestedRef, String requestedHash, Map<String,String> catalogOptions)

Method Summary

Modifier and Type	Method	Description
void	close()
void	commitTable(TableMetadata base, TableMetadata metadata, String newMetadataLocation, String contentId, org.projectnessie.model.ContentKey key)
void	commitView(ViewMetadata base, ViewMetadata metadata, String newMetadataLocation, String contentId, org.projectnessie.model.ContentKey key)
void	createNamespace(Namespace namespace, Map<String,String> metadata)
boolean	dropNamespace(Namespace namespace)
boolean	dropTable(TableIdentifier identifier, boolean purge)
boolean	dropView(TableIdentifier identifier, boolean purge)
org.projectnessie.model.IcebergContent	fetchContent(TableIdentifier tableIdentifier)
org.projectnessie.client.api.NessieApiV1	getApi()
org.projectnessie.model.Reference	getReference()
List<Namespace>	listNamespaces(Namespace namespace)
List<TableIdentifier>	listTables(Namespace namespace)
List<TableIdentifier>	listViews(Namespace namespace)
Map<String,String>	loadNamespaceMetadata(Namespace namespace)
String	refName()
void	refresh()
boolean	removeProperties(Namespace namespace, Set<String> properties)
void	renameTable(TableIdentifier from, TableIdentifier to)
void	renameView(TableIdentifier from, TableIdentifier to)
boolean	setProperties(Namespace namespace, Map<String,String> properties)
org.projectnessie.model.IcebergTable	table(TableIdentifier tableIdentifier)
org.projectnessie.model.IcebergView	view(TableIdentifier tableIdentifier)
NessieIcebergClient	withReference(String requestedRef, String hash)

Methods inherited from class java.lang.Object

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

Constructor Details

NessieIcebergClient

public NessieIcebergClient(org.projectnessie.client.api.NessieApiV1 api,
 String requestedRef,
 String requestedHash,
 Map<String,String> catalogOptions)

Method Details

getApi

public org.projectnessie.client.api.NessieApiV1 getApi()

getReference

public org.projectnessie.model.Reference getReference()

refresh

public void refresh()
             throws org.projectnessie.error.NessieNotFoundException

Throws:

org.projectnessie.error.NessieNotFoundException

withReference

public NessieIcebergClient withReference(String requestedRef,
 String hash)

listTables

public List<TableIdentifier> listTables(Namespace namespace)

listViews

public List<TableIdentifier> listViews(Namespace namespace)

table

public org.projectnessie.model.IcebergTable table(TableIdentifier tableIdentifier)

view

public org.projectnessie.model.IcebergView view(TableIdentifier tableIdentifier)

fetchContent

public org.projectnessie.model.IcebergContent fetchContent(TableIdentifier tableIdentifier)

createNamespace

public void createNamespace(Namespace namespace,
 Map<String,String> metadata)

listNamespaces

public List<Namespace> listNamespaces(Namespace namespace)
                               throws NoSuchNamespaceException

Throws:

NoSuchNamespaceException

dropNamespace

public boolean dropNamespace(Namespace namespace)
                      throws NamespaceNotEmptyException

Throws:

NamespaceNotEmptyException

loadNamespaceMetadata

public Map<String,String> loadNamespaceMetadata(Namespace namespace)
                                         throws NoSuchNamespaceException

Throws:

NoSuchNamespaceException

setProperties

public boolean setProperties(Namespace namespace,
 Map<String,String> properties)

removeProperties

public boolean removeProperties(Namespace namespace,
 Set<String> properties)

renameTable

public void renameTable(TableIdentifier from,
 TableIdentifier to)

renameView

public void renameView(TableIdentifier from,
 TableIdentifier to)

dropTable

public boolean dropTable(TableIdentifier identifier,
 boolean purge)

dropView

public boolean dropView(TableIdentifier identifier,
 boolean purge)

commitTable

public void commitTable(TableMetadata base,
 TableMetadata metadata,
 String newMetadataLocation,
 String contentId,
 org.projectnessie.model.ContentKey key)
                 throws org.projectnessie.error.NessieConflictException,
org.projectnessie.error.NessieNotFoundException

Throws:

org.projectnessie.error.NessieConflictException

org.projectnessie.error.NessieNotFoundException

commitView

public void commitView(ViewMetadata base,
 ViewMetadata metadata,
 String newMetadataLocation,
 String contentId,
 org.projectnessie.model.ContentKey key)
                throws org.projectnessie.error.NessieConflictException,
org.projectnessie.error.NessieNotFoundException

Throws:

org.projectnessie.error.NessieConflictException

org.projectnessie.error.NessieNotFoundException

refName

public String refName()

close

public void close()

Specified by:

close in interface AutoCloseable