org.apache.gravitino.file

Interface FilesetCatalog

@Evolving
public interface FilesetCatalog

The FilesetCatalog interface defines the public API for managing fileset objects in a schema. If the catalog implementation supports fileset objects, it should implement this interface.

Method Summary

Modifier and Type	Method and Description
Fileset	alterFileset(NameIdentifier ident, FilesetChange... changes) Apply the change to a fileset in the catalog.
Fileset	createFileset(NameIdentifier ident, java.lang.String comment, Fileset.Type type, java.lang.String storageLocation, java.util.Map<java.lang.String,java.lang.String> properties) Create a fileset metadata in the catalog.
boolean	dropFileset(NameIdentifier ident) Drop a fileset from the catalog.
default boolean	filesetExists(NameIdentifier ident) Check if a fileset exists using an NameIdentifier from the catalog.
NameIdentifier[]	listFilesets(Namespace namespace) List the filesets in a schema namespace from the catalog.
Fileset	loadFileset(NameIdentifier ident) Load fileset metadata by NameIdentifier from the catalog.

Method Detail

listFilesets

NameIdentifier[] listFilesets(Namespace namespace)
                       throws NoSuchSchemaException

List the filesets in a schema namespace from the catalog.

Parameters:

namespace - A schema namespace.

Returns:

An array of fileset identifiers in the namespace.

Throws:

NoSuchSchemaException - If the schema does not exist.

loadFileset

Fileset loadFileset(NameIdentifier ident)
             throws NoSuchFilesetException

Load fileset metadata by NameIdentifier from the catalog.

Parameters:

ident - A fileset identifier.

Returns:

The fileset metadata.

Throws:

NoSuchFilesetException - If the fileset does not exist.

filesetExists

default boolean filesetExists(NameIdentifier ident)

Check if a fileset exists using an NameIdentifier from the catalog.

Parameters:

ident - A fileset identifier.

Returns:

true If the fileset exists, false otherwise.

createFileset

Fileset createFileset(NameIdentifier ident,
                      java.lang.String comment,
                      Fileset.Type type,
                      java.lang.String storageLocation,
                      java.util.Map<java.lang.String,java.lang.String> properties)
               throws NoSuchSchemaException,
                      FilesetAlreadyExistsException

Create a fileset metadata in the catalog.

If the type of the fileset object is "MANAGED", the underlying storageLocation can be null, and Gravitino will manage the storage location based on the location of the schema.

If the type of the fileset object is "EXTERNAL", the underlying storageLocation must be set.

Parameters:

ident - A fileset identifier.

comment - The comment of the fileset.

type - The type of the fileset.

storageLocation - The storage location of the fileset.

properties - The properties of the fileset.

Returns:

The created fileset metadata

Throws:

NoSuchSchemaException - If the schema does not exist.

FilesetAlreadyExistsException - If the fileset already exists.

alterFileset

Fileset alterFileset(NameIdentifier ident,
                     FilesetChange... changes)
              throws NoSuchFilesetException,
                     java.lang.IllegalArgumentException

Apply the change to a fileset in the catalog.

Implementation may reject the change. If any change is rejected, no changes should be applied to the fileset.

The FilesetChange.RenameFileset change will only update the fileset name, the underlying storage location for managed fileset will not be renamed.

Parameters:

ident - A fileset identifier.

changes - The changes to apply to the fileset.

Returns:

The altered fileset metadata.

Throws:

NoSuchFilesetException - If the fileset does not exist.

java.lang.IllegalArgumentException - If the change is rejected by the implementation.

dropFileset

boolean dropFileset(NameIdentifier ident)

Drop a fileset from the catalog.

The underlying files will be deleted if this fileset type is managed, otherwise, only the metadata will be dropped.

Parameters:

ident - A fileset identifier.

Returns:

true If the fileset is dropped, false the fileset did not exist.