public class NessieIcebergClient
extends java.lang.Object
implements java.lang.AutoCloseable
Constructor and Description |
---|
NessieIcebergClient(org.projectnessie.client.api.NessieApiV1 api,
java.lang.String requestedRef,
java.lang.String requestedHash,
java.util.Map<java.lang.String,java.lang.String> catalogOptions) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
commitTable(TableMetadata base,
TableMetadata metadata,
java.lang.String newMetadataLocation,
org.projectnessie.model.IcebergTable expectedContent,
org.projectnessie.model.ContentKey key) |
void |
createNamespace(Namespace namespace,
java.util.Map<java.lang.String,java.lang.String> metadata) |
boolean |
dropNamespace(Namespace namespace) |
boolean |
dropTable(TableIdentifier identifier,
boolean purge) |
org.projectnessie.client.api.NessieApiV1 |
getApi() |
org.apache.iceberg.nessie.UpdateableReference |
getRef() |
java.util.List<Namespace> |
listNamespaces(Namespace namespace) |
java.util.List<TableIdentifier> |
listTables(Namespace namespace) |
java.util.Map<java.lang.String,java.lang.String> |
loadNamespaceMetadata(Namespace namespace) |
java.lang.String |
refName() |
void |
refresh() |
boolean |
removeProperties(Namespace namespace,
java.util.Set<java.lang.String> properties) |
void |
renameTable(TableIdentifier from,
TableIdentifier to) |
boolean |
setProperties(Namespace namespace,
java.util.Map<java.lang.String,java.lang.String> properties) |
org.projectnessie.model.IcebergTable |
table(TableIdentifier tableIdentifier) |
NessieIcebergClient |
withReference(java.lang.String requestedRef,
java.lang.String hash) |
public NessieIcebergClient(org.projectnessie.client.api.NessieApiV1 api, java.lang.String requestedRef, java.lang.String requestedHash, java.util.Map<java.lang.String,java.lang.String> catalogOptions)
public org.projectnessie.client.api.NessieApiV1 getApi()
public org.apache.iceberg.nessie.UpdateableReference getRef()
public void refresh() throws org.projectnessie.error.NessieNotFoundException
org.projectnessie.error.NessieNotFoundException
public NessieIcebergClient withReference(java.lang.String requestedRef, java.lang.String hash)
public java.util.List<TableIdentifier> listTables(Namespace namespace)
public org.projectnessie.model.IcebergTable table(TableIdentifier tableIdentifier)
public void createNamespace(Namespace namespace, java.util.Map<java.lang.String,java.lang.String> metadata)
public java.util.List<Namespace> listNamespaces(Namespace namespace) throws NoSuchNamespaceException
NoSuchNamespaceException
public boolean dropNamespace(Namespace namespace) throws NamespaceNotEmptyException
NamespaceNotEmptyException
public java.util.Map<java.lang.String,java.lang.String> loadNamespaceMetadata(Namespace namespace) throws NoSuchNamespaceException
NoSuchNamespaceException
public boolean setProperties(Namespace namespace, java.util.Map<java.lang.String,java.lang.String> properties)
public boolean removeProperties(Namespace namespace, java.util.Set<java.lang.String> properties)
public void renameTable(TableIdentifier from, TableIdentifier to)
public boolean dropTable(TableIdentifier identifier, boolean purge)
public void commitTable(TableMetadata base, TableMetadata metadata, java.lang.String newMetadataLocation, org.projectnessie.model.IcebergTable expectedContent, org.projectnessie.model.ContentKey key) throws org.projectnessie.error.NessieConflictException, org.projectnessie.error.NessieNotFoundException
org.projectnessie.error.NessieConflictException
org.projectnessie.error.NessieNotFoundException
public java.lang.String refName()
public void close()
close
in interface java.lang.AutoCloseable