com.facebook.presto.spi.classloader

Class ClassLoaderSafeConnectorMetadata

java.lang.Object

com.facebook.presto.spi.classloader.ClassLoaderSafeConnectorMetadata

All Implemented Interfaces:

ConnectorMetadata

public class ClassLoaderSafeConnectorMetadata
extends Object
implements ConnectorMetadata

Constructor Summary

Constructors

Constructor and Description
ClassLoaderSafeConnectorMetadata(ConnectorMetadata delegate, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
void	addColumn(ConnectorSession session, ConnectorTableHandle tableHandle, ColumnMetadata column) Add the specified column
ConnectorOutputTableHandle	beginCreateTable(ConnectorSession session, ConnectorTableMetadata tableMetadata) Begin the atomic creation of a table with data.
ConnectorTableHandle	beginDelete(ConnectorSession session, ConnectorTableHandle tableHandle) Begin delete query
ConnectorInsertTableHandle	beginInsert(ConnectorSession session, ConnectorTableHandle tableHandle) Begin insert query
boolean	canCreateSampledTables(ConnectorSession session) Returns true if this catalog supports creation of sampled tables
void	commitCreateTable(ConnectorSession session, ConnectorOutputTableHandle tableHandle, Collection<io.airlift.slice.Slice> fragments) Commit a table creation with data after the data is written.
void	commitInsert(ConnectorSession session, ConnectorInsertTableHandle insertHandle, Collection<io.airlift.slice.Slice> fragments) Commit insert query
void	createTable(ConnectorSession session, ConnectorTableMetadata tableMetadata) Creates a table using the specified table metadata.
void	createView(ConnectorSession session, SchemaTableName viewName, String viewData, boolean replace) Create the specified view.
void	dropTable(ConnectorSession session, ConnectorTableHandle tableHandle) Drops the specified table
void	dropView(ConnectorSession session, SchemaTableName viewName) Drop the specified view.
Map<String,ColumnHandle>	getColumnHandles(ConnectorSession session, ConnectorTableHandle tableHandle) Gets all of the columns on the specified table, or an empty map if the columns can not be enumerated.
ColumnMetadata	getColumnMetadata(ConnectorSession session, ConnectorTableHandle tableHandle, ColumnHandle columnHandle) Gets the metadata for the specified table column.
ColumnHandle	getSampleWeightColumnHandle(ConnectorSession session, ConnectorTableHandle tableHandle) Returns the handle for the sample weight column, or null if the table does not contain sampled data.
ConnectorTableHandle	getTableHandle(ConnectorSession session, SchemaTableName tableName) Returns a table handle for the specified table name, or null if the connector does not contain the table.
ConnectorTableLayout	getTableLayout(ConnectorSession session, ConnectorTableLayoutHandle handle)
List<ConnectorTableLayoutResult>	getTableLayouts(ConnectorSession session, ConnectorTableHandle table, Constraint<ColumnHandle> constraint, Optional<Set<ColumnHandle>> desiredColumns) Return a list of table layouts that satisfy the given constraint.
ConnectorTableMetadata	getTableMetadata(ConnectorSession session, ConnectorTableHandle table) Return the metadata for the specified table handle.
ColumnHandle	getUpdateRowIdColumnHandle(ConnectorSession session, ConnectorTableHandle tableHandle) Get the column handle that will generate row IDs for the delete operation.
Map<SchemaTableName,ConnectorViewDefinition>	getViews(ConnectorSession session, SchemaTablePrefix prefix) Gets the view data for views that match the specified table prefix.
void	grantTablePrivileges(ConnectorSession session, SchemaTableName tableName, Set<Privilege> privileges, String grantee, boolean grantOption) Grants the specified privilege to the specified user on the specified table
List<String>	listSchemaNames(ConnectorSession session) Returns the schemas provided by this connector.
Map<SchemaTableName,List<ColumnMetadata>>	listTableColumns(ConnectorSession session, SchemaTablePrefix prefix) Gets the metadata for all columns that match the specified table prefix.
List<SchemaTableName>	listTables(ConnectorSession session, String schemaNameOrNull) List table names, possibly filtered by schema.
List<SchemaTableName>	listViews(ConnectorSession session, String schemaNameOrNull) List view names, possibly filtered by schema.
OptionalLong	metadataDelete(ConnectorSession session, ConnectorTableHandle tableHandle, ConnectorTableLayoutHandle tableLayoutHandle) Delete the provided table layout
void	renameColumn(ConnectorSession session, ConnectorTableHandle tableHandle, ColumnHandle source, String target) Rename the specified column
void	renameTable(ConnectorSession session, ConnectorTableHandle tableHandle, SchemaTableName newTableName) Rename the specified table
boolean	supportsMetadataDelete(ConnectorSession session, ConnectorTableHandle tableHandle, ConnectorTableLayoutHandle tableLayoutHandle)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.facebook.presto.spi.ConnectorMetadata

commitDelete, rollbackCreateTable, rollbackDelete, rollbackInsert

Constructor Detail

ClassLoaderSafeConnectorMetadata

public ClassLoaderSafeConnectorMetadata(ConnectorMetadata delegate,
                                        ClassLoader classLoader)

Method Detail

getTableLayouts

public List<ConnectorTableLayoutResult> getTableLayouts(ConnectorSession session,
                                                        ConnectorTableHandle table,
                                                        Constraint<ColumnHandle> constraint,
                                                        Optional<Set<ColumnHandle>> desiredColumns)

Description copied from interface: ConnectorMetadata

Return a list of table layouts that satisfy the given constraint.

For each layout, connectors must return an "unenforced constraint" representing the part of the constraint summary that isn't guaranteed by the layout.

Specified by:

getTableLayouts in interface ConnectorMetadata

getTableLayout

public ConnectorTableLayout getTableLayout(ConnectorSession session,
                                           ConnectorTableLayoutHandle handle)

Specified by:

getTableLayout in interface ConnectorMetadata

listSchemaNames

public List<String> listSchemaNames(ConnectorSession session)

Description copied from interface: ConnectorMetadata

Returns the schemas provided by this connector.

Specified by:

listSchemaNames in interface ConnectorMetadata

getTableHandle

public ConnectorTableHandle getTableHandle(ConnectorSession session,
                                           SchemaTableName tableName)

Description copied from interface: ConnectorMetadata

Returns a table handle for the specified table name, or null if the connector does not contain the table.

Specified by:

getTableHandle in interface ConnectorMetadata

getTableMetadata

public ConnectorTableMetadata getTableMetadata(ConnectorSession session,
                                               ConnectorTableHandle table)

Description copied from interface: ConnectorMetadata

Return the metadata for the specified table handle.

Specified by:

getTableMetadata in interface ConnectorMetadata

listTables

public List<SchemaTableName> listTables(ConnectorSession session,
                                        String schemaNameOrNull)

Description copied from interface: ConnectorMetadata

List table names, possibly filtered by schema. An empty list is returned if none match.

Specified by:

listTables in interface ConnectorMetadata

getSampleWeightColumnHandle

public ColumnHandle getSampleWeightColumnHandle(ConnectorSession session,
                                                ConnectorTableHandle tableHandle)

Description copied from interface: ConnectorMetadata

Returns the handle for the sample weight column, or null if the table does not contain sampled data.

Specified by:

getSampleWeightColumnHandle in interface ConnectorMetadata

canCreateSampledTables

public boolean canCreateSampledTables(ConnectorSession session)

Description copied from interface: ConnectorMetadata

Returns true if this catalog supports creation of sampled tables

Specified by:

canCreateSampledTables in interface ConnectorMetadata

getColumnHandles

public Map<String,ColumnHandle> getColumnHandles(ConnectorSession session,
                                                 ConnectorTableHandle tableHandle)

Description copied from interface: ConnectorMetadata

Gets all of the columns on the specified table, or an empty map if the columns can not be enumerated.

Specified by:

getColumnHandles in interface ConnectorMetadata

getColumnMetadata

public ColumnMetadata getColumnMetadata(ConnectorSession session,
                                        ConnectorTableHandle tableHandle,
                                        ColumnHandle columnHandle)

Description copied from interface: ConnectorMetadata

Gets the metadata for the specified table column.

Specified by:

getColumnMetadata in interface ConnectorMetadata

listTableColumns

public Map<SchemaTableName,List<ColumnMetadata>> listTableColumns(ConnectorSession session,
                                                                  SchemaTablePrefix prefix)

Description copied from interface: ConnectorMetadata

Gets the metadata for all columns that match the specified table prefix.

Specified by:

listTableColumns in interface ConnectorMetadata

addColumn

public void addColumn(ConnectorSession session,
                      ConnectorTableHandle tableHandle,
                      ColumnMetadata column)

Description copied from interface: ConnectorMetadata

Add the specified column

Specified by:

addColumn in interface ConnectorMetadata

createTable

public void createTable(ConnectorSession session,
                        ConnectorTableMetadata tableMetadata)

Description copied from interface: ConnectorMetadata

Creates a table using the specified table metadata.

Specified by:

createTable in interface ConnectorMetadata

dropTable

public void dropTable(ConnectorSession session,
                      ConnectorTableHandle tableHandle)

Description copied from interface: ConnectorMetadata

Drops the specified table

Specified by:

dropTable in interface ConnectorMetadata

renameColumn

public void renameColumn(ConnectorSession session,
                         ConnectorTableHandle tableHandle,
                         ColumnHandle source,
                         String target)

Description copied from interface: ConnectorMetadata

Rename the specified column

Specified by:

renameColumn in interface ConnectorMetadata

renameTable

public void renameTable(ConnectorSession session,
                        ConnectorTableHandle tableHandle,
                        SchemaTableName newTableName)

Description copied from interface: ConnectorMetadata

Rename the specified table

Specified by:

renameTable in interface ConnectorMetadata

beginCreateTable

public ConnectorOutputTableHandle beginCreateTable(ConnectorSession session,
                                                   ConnectorTableMetadata tableMetadata)

Description copied from interface: ConnectorMetadata

Begin the atomic creation of a table with data.

Specified by:

beginCreateTable in interface ConnectorMetadata

commitCreateTable

public void commitCreateTable(ConnectorSession session,
                              ConnectorOutputTableHandle tableHandle,
                              Collection<io.airlift.slice.Slice> fragments)

Description copied from interface: ConnectorMetadata

Commit a table creation with data after the data is written.

Specified by:

commitCreateTable in interface ConnectorMetadata

beginInsert

public ConnectorInsertTableHandle beginInsert(ConnectorSession session,
                                              ConnectorTableHandle tableHandle)

Description copied from interface: ConnectorMetadata

Begin insert query

Specified by:

beginInsert in interface ConnectorMetadata

commitInsert

public void commitInsert(ConnectorSession session,
                         ConnectorInsertTableHandle insertHandle,
                         Collection<io.airlift.slice.Slice> fragments)

Description copied from interface: ConnectorMetadata

Commit insert query

Specified by:

commitInsert in interface ConnectorMetadata

createView

public void createView(ConnectorSession session,
                       SchemaTableName viewName,
                       String viewData,
                       boolean replace)

Description copied from interface: ConnectorMetadata

Create the specified view. The data for the view is opaque to the connector.

Specified by:

createView in interface ConnectorMetadata

dropView

public void dropView(ConnectorSession session,
                     SchemaTableName viewName)

Description copied from interface: ConnectorMetadata

Drop the specified view.

Specified by:

dropView in interface ConnectorMetadata

listViews

public List<SchemaTableName> listViews(ConnectorSession session,
                                       String schemaNameOrNull)

Description copied from interface: ConnectorMetadata

List view names, possibly filtered by schema. An empty list is returned if none match.

Specified by:

listViews in interface ConnectorMetadata

getViews

public Map<SchemaTableName,ConnectorViewDefinition> getViews(ConnectorSession session,
                                                             SchemaTablePrefix prefix)

Description copied from interface: ConnectorMetadata

Gets the view data for views that match the specified table prefix.

Specified by:

getViews in interface ConnectorMetadata

getUpdateRowIdColumnHandle

public ColumnHandle getUpdateRowIdColumnHandle(ConnectorSession session,
                                               ConnectorTableHandle tableHandle)

Description copied from interface: ConnectorMetadata

Get the column handle that will generate row IDs for the delete operation. These IDs will be passed to the deleteRows() method of the UpdatablePageSource that created them.

Specified by:

getUpdateRowIdColumnHandle in interface ConnectorMetadata

beginDelete

public ConnectorTableHandle beginDelete(ConnectorSession session,
                                        ConnectorTableHandle tableHandle)

Description copied from interface: ConnectorMetadata

Begin delete query

Specified by:

beginDelete in interface ConnectorMetadata

supportsMetadataDelete

public boolean supportsMetadataDelete(ConnectorSession session,
                                      ConnectorTableHandle tableHandle,
                                      ConnectorTableLayoutHandle tableLayoutHandle)

Specified by:

supportsMetadataDelete in interface ConnectorMetadata

Returns:

whether delete without table scan is supported

metadataDelete

public OptionalLong metadataDelete(ConnectorSession session,
                                   ConnectorTableHandle tableHandle,
                                   ConnectorTableLayoutHandle tableLayoutHandle)

Description copied from interface: ConnectorMetadata

Delete the provided table layout

Specified by:

metadataDelete in interface ConnectorMetadata

Returns:

number of rows deleted, or null for unknown

grantTablePrivileges

public void grantTablePrivileges(ConnectorSession session,
                                 SchemaTableName tableName,
                                 Set<Privilege> privileges,
                                 String grantee,
                                 boolean grantOption)

Description copied from interface: ConnectorMetadata

Grants the specified privilege to the specified user on the specified table

Specified by:

grantTablePrivileges in interface ConnectorMetadata

toString

public String toString()

Overrides:

toString in class Object