com.datastrato.gravitino.client

Class RelationalTable

java.lang.Object

com.datastrato.gravitino.client.RelationalTable

All Implemented Interfaces:

Auditable, SupportsPartitions, Table

public class RelationalTable
extends java.lang.Object
implements Table, SupportsPartitions

Represents a relational table.

Constructor Summary

Constructors

Constructor and Description
RelationalTable(Namespace namespace, TableDTO tableDTO, RESTClient restClient) Creates a new RelationalTable.

Method Summary

Modifier and Type	Method and Description
Partition	addPartition(Partition partition) Adds a partition to the table.
Audit	auditInfo()
Column[]	columns()
java.lang.String	comment()
Distribution	distribution()
boolean	dropPartition(java.lang.String partitionName) Drops the partition with the given name.
protected static java.lang.String	formatPartitionRequestPath(java.lang.String prefix, java.lang.String partitionName) Formats the partition request path.
static RelationalTable	from(Namespace namespace, TableDTO tableDTO, RESTClient restClient) Creates a new RelationalTable.
Partition	getPartition(java.lang.String partitionName) Returns the partition with the given name.
java.lang.String	getPartitionRequestPath()
Index[]	index()
java.lang.String[]	listPartitionNames() List all partition names of the table
Partition[]	listPartitions() List all partitions
java.lang.String	name() Returns the name of the table.
Namespace	namespace() Returns the namespace of the table.
Transform[]	partitioning()
java.util.Map<java.lang.String,java.lang.String>	properties()
SortOrder[]	sortOrder()
SupportsPartitions	supportPartitions() Returns the partitioning strategy of the table.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.datastrato.gravitino.rel.SupportsPartitions

partitionExists, purgePartition

Constructor Detail

RelationalTable

public RelationalTable(Namespace namespace,
                       TableDTO tableDTO,
                       RESTClient restClient)

Creates a new RelationalTable.

Parameters:

namespace - The namespace of the table.

tableDTO - The table data transfer object.

restClient - The REST client.

Method Detail

from

public static RelationalTable from(Namespace namespace,
                                   TableDTO tableDTO,
                                   RESTClient restClient)

Creates a new RelationalTable.

Parameters:

namespace - The namespace of the table.

tableDTO - The table data transfer object.

restClient - The REST client.

Returns:

A new RelationalTable.

namespace

public Namespace namespace()

Returns the namespace of the table.

Returns:

The namespace of the table.

name

public java.lang.String name()

Returns the name of the table.

Specified by:

name in interface Table

Returns:

The name of the table.

columns

public Column[] columns()

Specified by:

columns in interface Table

Returns:

the columns of the table.

partitioning

public Transform[] partitioning()

Specified by:

partitioning in interface Table

Returns:

the partitioning of the table.

sortOrder

public SortOrder[] sortOrder()

Specified by:

sortOrder in interface Table

Returns:

the sort order of the table.

distribution

public Distribution distribution()

Specified by:

distribution in interface Table

Returns:

the distribution of the table.

comment

@Nullable
public java.lang.String comment()

Specified by:

comment in interface Table

Returns:

the comment of the table.

properties

public java.util.Map<java.lang.String,java.lang.String> properties()

Specified by:

properties in interface Table

Returns:

the properties of the table.

auditInfo

public Audit auditInfo()

Specified by:

auditInfo in interface Auditable

Returns:

the audit information of the table.

index

public Index[] index()

Specified by:

index in interface Table

Returns:

the indexes of the table.

listPartitionNames

public java.lang.String[] listPartitionNames()

Description copied from interface: SupportsPartitions

List all partition names of the table

Specified by:

listPartitionNames in interface SupportsPartitions

Returns:

The partition names of the table.

getPartitionRequestPath

public java.lang.String getPartitionRequestPath()

Returns:

The partition request path.

listPartitions

public Partition[] listPartitions()

Description copied from interface: SupportsPartitions

List all partitions

Specified by:

listPartitions in interface SupportsPartitions

Returns:

The partitions of the table.

getPartition

public Partition getPartition(java.lang.String partitionName)
                       throws NoSuchPartitionException

Returns the partition with the given name.

Specified by:

getPartition in interface SupportsPartitions

Parameters:

partitionName - the name of the partition

Returns:

the partition with the given name

Throws:

NoSuchPartitionException - if the partition does not exist, throws this exception.

addPartition

public Partition addPartition(Partition partition)
                       throws PartitionAlreadyExistsException

Adds a partition to the table.

Specified by:

addPartition in interface SupportsPartitions

Parameters:

partition - The partition to add.

Returns:

The added partition.

Throws:

PartitionAlreadyExistsException - If the partition already exists, throws this exception.

dropPartition

public boolean dropPartition(java.lang.String partitionName)

Drops the partition with the given name.

Specified by:

dropPartition in interface SupportsPartitions

Parameters:

partitionName - The identifier of the partition.

Returns:

true if the partition is dropped, false otherwise.

supportPartitions

public SupportsPartitions supportPartitions()
                                     throws java.lang.UnsupportedOperationException

Returns the partitioning strategy of the table.

Specified by:

supportPartitions in interface Table

Returns:

the partitioning strategy of the table.

Throws:

java.lang.UnsupportedOperationException - If the table does not support partition operations.

formatPartitionRequestPath

protected static java.lang.String formatPartitionRequestPath(java.lang.String prefix,
                                                             java.lang.String partitionName)

Formats the partition request path.

Parameters:

prefix - The prefix of the path.

partitionName - The name of the partition.

Returns:

The formatted partition request path.