Uses of Interface
com.facebook.presto.spi.connector.ConnectorTransactionHandle

Packages that use ConnectorTransactionHandle

Package	Description
com.facebook.presto.spi
com.facebook.presto.spi.connector
com.facebook.presto.spi.connector.classloader

Uses of ConnectorTransactionHandle in com.facebook.presto.spi

Methods in com.facebook.presto.spi that return types with arguments of type ConnectorTransactionHandle

Modifier and Type	Method and Description
default Class<? extends ConnectorTransactionHandle>	ConnectorHandleResolver.getTransactionHandleClass()

Methods in com.facebook.presto.spi with parameters of type ConnectorTransactionHandle

Modifier and Type	Method and Description
default RecordCursor	SystemTable.cursor(ConnectorTransactionHandle transactionHandle, ConnectorSession session, TupleDomain<Integer> constraint) Create a cursor for the data in this table.
default ConnectorPageSource	SystemTable.pageSource(ConnectorTransactionHandle transactionHandle, ConnectorSession session, TupleDomain<Integer> constraint) Create a page source for the data in this table.

Uses of ConnectorTransactionHandle in com.facebook.presto.spi.connector

Methods in com.facebook.presto.spi.connector that return ConnectorTransactionHandle

Modifier and Type	Method and Description
ConnectorTransactionHandle	Connector.beginTransaction(IsolationLevel isolationLevel, boolean readOnly)

Methods in com.facebook.presto.spi.connector with parameters of type ConnectorTransactionHandle

Modifier and Type	Method and Description
default void	ConnectorAccessControl.checkCanAddColumn(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName) Check if identity is allowed to add columns to the specified table in this catalog.
default void	ConnectorAccessControl.checkCanCreateRole(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String role, Optional<PrestoPrincipal> grantor)
default void	ConnectorAccessControl.checkCanCreateSchema(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String schemaName) Check if identity is allowed to create the specified schema in this catalog.
default void	ConnectorAccessControl.checkCanCreateTable(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName) Check if identity is allowed to create the specified table in this catalog.
default void	ConnectorAccessControl.checkCanCreateView(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName viewName) Check if identity is allowed to create the specified view in this catalog.
default void	ConnectorAccessControl.checkCanCreateViewWithSelectFromColumns(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName, Set<String> columnNames) Check if identity is allowed to create a view that selects from the specified columns in a relation.
default void	ConnectorAccessControl.checkCanDeleteFromTable(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName) Check if identity is allowed to delete from the specified table in this catalog.
default void	ConnectorAccessControl.checkCanDropColumn(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName) Check if identity is allowed to drop columns from the specified table in this catalog.
default void	ConnectorAccessControl.checkCanDropRole(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String role)
default void	ConnectorAccessControl.checkCanDropSchema(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String schemaName) Check if identity is allowed to drop the specified schema in this catalog.
default void	ConnectorAccessControl.checkCanDropTable(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName) Check if identity is allowed to drop the specified table in this catalog.
default void	ConnectorAccessControl.checkCanDropView(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName viewName) Check if identity is allowed to drop the specified view in this catalog.
default void	ConnectorAccessControl.checkCanGrantRoles(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, Set<String> roles, Set<PrestoPrincipal> grantees, boolean withAdminOption, Optional<PrestoPrincipal> grantor, String catalogName)
default void	ConnectorAccessControl.checkCanGrantTablePrivilege(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, Privilege privilege, SchemaTableName tableName, PrestoPrincipal grantee, boolean withGrantOption) Check if identity is allowed to grant to any other user the specified privilege on the specified table.
default void	ConnectorAccessControl.checkCanInsertIntoTable(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName) Check if identity is allowed to insert into the specified table in this catalog.
default void	ConnectorAccessControl.checkCanRenameColumn(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName) Check if identity is allowed to rename a column in the specified table in this catalog.
default void	ConnectorAccessControl.checkCanRenameSchema(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String schemaName, String newSchemaName) Check if identity is allowed to rename the specified schema in this catalog.
default void	ConnectorAccessControl.checkCanRenameTable(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName, SchemaTableName newTableName) Check if identity is allowed to rename the specified table in this catalog.
default void	ConnectorAccessControl.checkCanRevokeRoles(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, Set<String> roles, Set<PrestoPrincipal> grantees, boolean adminOptionFor, Optional<PrestoPrincipal> grantor, String catalogName)
default void	ConnectorAccessControl.checkCanRevokeTablePrivilege(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, Privilege privilege, SchemaTableName tableName, PrestoPrincipal revokee, boolean grantOptionFor) Check if identity is allowed to revoke the specified privilege on the specified table from any user.
default void	ConnectorAccessControl.checkCanSelectFromColumns(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, SchemaTableName tableName, Set<String> columnNames) Check if identity is allowed to select from the specified columns in a relation.
default void	ConnectorAccessControl.checkCanSetCatalogSessionProperty(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String propertyName) Check if identity is allowed to set the specified property in this catalog.
default void	ConnectorAccessControl.checkCanSetRole(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String role, String catalogName)
default void	ConnectorAccessControl.checkCanShowCurrentRoles(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String catalogName) Check if identity is allowed to show current roles on the specified catalog.
default void	ConnectorAccessControl.checkCanShowRoleGrants(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String catalogName) Check if identity is allowed to show its own role grants on the specified catalog.
default void	ConnectorAccessControl.checkCanShowRoles(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String catalogName) Check if identity is allowed to show roles on the specified catalog.
default void	ConnectorAccessControl.checkCanShowSchemas(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity) Check if identity is allowed to execute SHOW SCHEMAS in a catalog.
default void	ConnectorAccessControl.checkCanShowTablesMetadata(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, String schemaName) Check if identity is allowed to show metadata of tables by executing SHOW TABLES, SHOW GRANTS etc.
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)
default Set<String>	ConnectorAccessControl.filterSchemas(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, Set<String> schemaNames) Filter the list of schemas to those visible to the identity.
default Set<SchemaTableName>	ConnectorAccessControl.filterTables(ConnectorTransactionHandle transactionHandle, ConnectorIdentity identity, Set<SchemaTableName> tableNames) Filter the list of tables and views to those visible to the identity.
BucketFunction	ConnectorNodePartitioningProvider.getBucketFunction(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle, List<Type> partitionChannelTypes, int bucketCount)
ConnectorBucketNodeMap	ConnectorNodePartitioningProvider.getBucketNodeMap(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)
ToIntFunction<ConnectorSplit>	ConnectorNodePartitioningProvider.getSplitBucketFunction(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle)
ConnectorSplitSource	ConnectorSplitManager.getSplits(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorTableLayoutHandle layout, ConnectorSplitManager.SplitSchedulingStrategy splitSchedulingStrategy)
default List<ConnectorPartitionHandle>	ConnectorNodePartitioningProvider.listPartitionHandles(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle) Returns a list of all partitions associated with the provided partitioningHandle.
default void	Connector.rollback(ConnectorTransactionHandle transactionHandle) Rollback the transaction.

Uses of ConnectorTransactionHandle in com.facebook.presto.spi.connector.classloader

Methods in com.facebook.presto.spi.connector.classloader with parameters of type ConnectorTransactionHandle

Modifier and Type	Method and Description
ConnectorPageSink	ClassLoaderSafeConnectorPageSinkProvider.createPageSink(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorInsertTableHandle insertTableHandle)
ConnectorPageSink	ClassLoaderSafeConnectorPageSinkProvider.createPageSink(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorOutputTableHandle outputTableHandle)
ConnectorPageSource	ClassLoaderSafeConnectorPageSourceProvider.createPageSource(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorSplit split, List<ColumnHandle> columns)
BucketFunction	ClassLoaderSafeNodePartitioningProvider.getBucketFunction(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle, List<Type> partitionChannelTypes, int bucketCount)
ConnectorBucketNodeMap	ClassLoaderSafeNodePartitioningProvider.getBucketNodeMap(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle)
ToIntFunction<ConnectorSplit>	ClassLoaderSafeNodePartitioningProvider.getSplitBucketFunction(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle)
ConnectorSplitSource	ClassLoaderSafeConnectorSplitManager.getSplits(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorTableLayoutHandle layout, ConnectorSplitManager.SplitSchedulingStrategy splitSchedulingStrategy)
List<ConnectorPartitionHandle>	ClassLoaderSafeNodePartitioningProvider.listPartitionHandles(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle)