| Package | Description |
|---|---|
| com.facebook.presto.spi | |
| com.facebook.presto.spi.connector | |
| com.facebook.presto.spi.connector.classloader |
| Modifier and Type | Method and Description |
|---|---|
default Class<? extends ConnectorTransactionHandle> |
ConnectorHandleResolver.getTransactionHandleClass() |
| Modifier and Type | Method and Description |
|---|---|
RecordCursor |
SystemTable.cursor(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
TupleDomain<Integer> constraint)
Create a cursor for the data in this table.
|
| Modifier and Type | Method and Description |
|---|---|
ConnectorTransactionHandle |
Connector.beginTransaction(IsolationLevel isolationLevel,
boolean readOnly) |
| Modifier and Type | Method and Description |
|---|---|
void |
ConnectorAccessControl.checkCanAddColumn(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName)
Check if identity is allowed to add columns to the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanCreateTable(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName)
Check if identity is allowed to create the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanCreateView(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName viewName)
Check if identity is allowed to create the specified view in this catalog.
|
void |
ConnectorAccessControl.checkCanCreateViewWithSelectFromTable(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName)
Check if identity is allowed to create a view that selects from the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanCreateViewWithSelectFromView(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName viewName)
Check if identity is allowed to create a view that selects from the specified view in this catalog.
|
void |
ConnectorAccessControl.checkCanDeleteFromTable(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName)
Check if identity is allowed to delete from the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanDropTable(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName)
Check if identity is allowed to drop the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanDropView(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName viewName)
Check if identity is allowed to drop the specified view in this catalog.
|
void |
ConnectorAccessControl.checkCanInsertIntoTable(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName)
Check if identity is allowed to insert into the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanRenameColumn(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName)
Check if identity is allowed to rename a column in the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanRenameTable(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName,
SchemaTableName newTableName)
Check if identity is allowed to rename the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanSelectFromTable(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName tableName)
Check if identity is allowed to select from the specified table in this catalog.
|
void |
ConnectorAccessControl.checkCanSelectFromView(ConnectorTransactionHandle transactionHandle,
Identity identity,
SchemaTableName viewName)
Check if identity is allowed to select from the specified view in this catalog.
|
default void |
Connector.commit(ConnectorTransactionHandle transactionHandle)
Commit the transaction.
|
ConnectorPageSink |
ConnectorPageSinkProvider.createPageSink(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorInsertTableHandle insertTableHandle) |
ConnectorPageSink |
ConnectorPageSinkProvider.createPageSink(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorOutputTableHandle outputTableHandle) |
ConnectorPageSource |
ConnectorPageSourceProvider.createPageSource(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorSplit split,
List<ColumnHandle> columns) |
BucketFunction |
ConnectorNodePartitioningProvider.getBucketFunction(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorPartitioningHandle partitioningHandle,
List<Type> partitionChannelTypes,
int bucketCount) |
Map<Integer,Node> |
ConnectorNodePartitioningProvider.getBucketToNode(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorPartitioningHandle partitioningHandle) |
ConnectorIndex |
ConnectorIndexProvider.getIndex(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorIndexHandle indexHandle,
List<ColumnHandle> lookupSchema,
List<ColumnHandle> outputSchema) |
ConnectorMetadata |
Connector.getMetadata(ConnectorTransactionHandle transactionHandle)
Guaranteed to be called at most once per transaction.
|
RecordSet |
ConnectorRecordSetProvider.getRecordSet(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorSplit split,
List<? extends ColumnHandle> columns) |
RecordSink |
ConnectorRecordSinkProvider.getRecordSink(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorInsertTableHandle tableHandle) |
RecordSink |
ConnectorRecordSinkProvider.getRecordSink(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorOutputTableHandle tableHandle) |
java.util.function.ToIntFunction<ConnectorSplit> |
ConnectorNodePartitioningProvider.getSplitBucketFunction(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorPartitioningHandle partitioningHandle) |
default ConnectorSplitSource |
ConnectorSplitManager.getSplits(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorTableLayoutHandle layout) |
default void |
Connector.rollback(ConnectorTransactionHandle transactionHandle)
Rollback the transaction.
|
Copyright © 2012-2016. All Rights Reserved.