| 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.
|
| Modifier and Type | Method and Description |
|---|---|
String |
DuplicateMapKeyException.getDetailedMessage(Type keyType,
ConnectorSession session) |
| Modifier and Type | Method and Description |
|---|---|
default void |
ConnectorMetadata.addColumn(ConnectorSession session,
ConnectorTableHandle tableHandle,
ColumnMetadata column)
Add the specified column
|
default ConnectorOutputTableHandle |
ConnectorMetadata.beginCreateTable(ConnectorSession session,
ConnectorTableMetadata tableMetadata,
Optional<ConnectorNewTableLayout> layout)
Begin the atomic creation of a table with data.
|
default ConnectorTableHandle |
ConnectorMetadata.beginDelete(ConnectorSession session,
ConnectorTableHandle tableHandle)
Begin delete query
|
default ConnectorInsertTableHandle |
ConnectorMetadata.beginInsert(ConnectorSession session,
ConnectorTableHandle tableHandle)
Begin insert query
|
default void |
ConnectorMetadata.beginQuery(ConnectorSession session)
Start a SELECT/UPDATE/INSERT/DELETE query.
|
default ConnectorTableHandle |
ConnectorMetadata.beginStatisticsCollection(ConnectorSession session,
ConnectorTableHandle tableHandle)
Begin statistics collection
|
default void |
ConnectorMetadata.cleanupQuery(ConnectorSession session)
Cleanup after a SELECT/UPDATE/INSERT/DELETE query.
|
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 void |
ConnectorMetadata.createRole(ConnectorSession session,
String role,
Optional<PrestoPrincipal> grantor)
Creates the specified role.
|
default void |
ConnectorMetadata.createSchema(ConnectorSession session,
String schemaName,
Map<String,Object> properties)
Creates a schema.
|
default void |
ConnectorMetadata.createTable(ConnectorSession session,
ConnectorTableMetadata tableMetadata,
boolean ignoreExisting)
Creates a table using the specified table metadata.
|
default ConnectorTableHandle |
ConnectorMetadata.createTemporaryTable(ConnectorSession session,
List<ColumnMetadata> columns,
Optional<ConnectorPartitioningMetadata> partitioningMetadata)
Creates a temporary table with optional partitioning requirements.
|
default void |
ConnectorMetadata.createView(ConnectorSession session,
SchemaTableName viewName,
String viewData,
boolean replace)
Create the specified view.
|
default void |
ConnectorMetadata.dropColumn(ConnectorSession session,
ConnectorTableHandle tableHandle,
ColumnHandle column)
Drop the specified column
|
default void |
ConnectorMetadata.dropRole(ConnectorSession session,
String role)
Drops the specified role.
|
default void |
ConnectorMetadata.dropSchema(ConnectorSession session,
String schemaName)
Drops the specified schema.
|
default void |
ConnectorMetadata.dropTable(ConnectorSession session,
ConnectorTableHandle tableHandle)
Drops the specified table
|
default void |
ConnectorMetadata.dropView(ConnectorSession session,
SchemaTableName viewName)
Drop the specified view.
|
default Optional<ConnectorOutputMetadata> |
ConnectorMetadata.finishCreateTable(ConnectorSession session,
ConnectorOutputTableHandle tableHandle,
Collection<io.airlift.slice.Slice> fragments,
Collection<ComputedStatistics> computedStatistics)
Finish a table creation with data after the data is written.
|
default void |
ConnectorMetadata.finishDelete(ConnectorSession session,
ConnectorTableHandle tableHandle,
Collection<io.airlift.slice.Slice> fragments)
Finish delete query
|
default Optional<ConnectorOutputMetadata> |
ConnectorMetadata.finishInsert(ConnectorSession session,
ConnectorInsertTableHandle insertHandle,
Collection<io.airlift.slice.Slice> fragments,
Collection<ComputedStatistics> computedStatistics)
Finish insert query
|
default void |
ConnectorMetadata.finishStatisticsCollection(ConnectorSession session,
ConnectorTableHandle tableHandle,
Collection<ComputedStatistics> computedStatistics)
Finish statistics collection
|
default ConnectorTableLayoutHandle |
ConnectorMetadata.getAlternativeLayoutHandle(ConnectorSession session,
ConnectorTableLayoutHandle tableLayoutHandle,
ConnectorPartitioningHandle partitioningHandle)
Return a table layout handle whose partitioning is converted to the provided partitioning handle,
but otherwise identical to the provided table layout handle.
|
BucketFunction |
ConnectorNodePartitioningProvider.getBucketFunction(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorPartitioningHandle partitioningHandle,
List<Type> partitionChannelTypes,
int bucketCount) |
ConnectorBucketNodeMap |
ConnectorNodePartitioningProvider.getBucketNodeMap(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorPartitioningHandle partitioningHandle) |
Map<String,ColumnHandle> |
ConnectorMetadata.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 |
ConnectorMetadata.getColumnMetadata(ConnectorSession session,
ConnectorTableHandle tableHandle,
ColumnHandle columnHandle)
Gets the metadata for the specified table column.
|
default Optional<ConnectorPartitioningHandle> |
ConnectorMetadata.getCommonPartitioningHandle(ConnectorSession session,
ConnectorPartitioningHandle left,
ConnectorPartitioningHandle right)
Deprecated.
|
ConnectorIndex |
ConnectorIndexProvider.getIndex(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorIndexHandle indexHandle,
List<ColumnHandle> lookupSchema,
List<ColumnHandle> outputSchema) |
default Optional<ConnectorNewTableLayout> |
ConnectorMetadata.getInsertLayout(ConnectorSession session,
ConnectorTableHandle tableHandle)
Get the physical layout for a inserting into an existing table.
|
default Optional<ConnectorNewTableLayout> |
ConnectorMetadata.getNewTableLayout(ConnectorSession session,
ConnectorTableMetadata tableMetadata)
Get the physical layout for a new table.
|
default ConnectorPartitioningHandle |
ConnectorMetadata.getPartitioningHandleForExchange(ConnectorSession session,
int partitionCount,
List<Type> partitionTypes)
Provides partitioning handle for exchange.
|
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 TableStatisticsMetadata |
ConnectorMetadata.getStatisticsCollectionMetadata(ConnectorSession session,
ConnectorTableMetadata tableMetadata)
Describe statistics that must be collected during a statistics collection
|
default TableStatisticsMetadata |
ConnectorMetadata.getStatisticsCollectionMetadataForWrite(ConnectorSession session,
ConnectorTableMetadata tableMetadata)
Describes statistics that must be collected during a write.
|
default Optional<SystemTable> |
ConnectorMetadata.getSystemTable(ConnectorSession session,
SchemaTableName tableName)
Returns the system table for the specified table name, if one exists.
|
ConnectorTableHandle |
ConnectorMetadata.getTableHandle(ConnectorSession session,
SchemaTableName tableName)
Returns a table handle for the specified table name, or null if the connector does not contain the table.
|
default ConnectorTableHandle |
ConnectorMetadata.getTableHandleForStatisticsCollection(ConnectorSession session,
SchemaTableName tableName,
Map<String,Object> analyzeProperties)
Returns a table handle for the specified table name, or null if the connector does not contain the table.
|
ConnectorTableLayout |
ConnectorMetadata.getTableLayout(ConnectorSession session,
ConnectorTableLayoutHandle handle) |
List<ConnectorTableLayoutResult> |
ConnectorMetadata.getTableLayouts(ConnectorSession session,
ConnectorTableHandle table,
Constraint<ColumnHandle> constraint,
Optional<Set<ColumnHandle>> desiredColumns)
Return a list of table layouts that satisfy the given constraint.
|
ConnectorTableMetadata |
ConnectorMetadata.getTableMetadata(ConnectorSession session,
ConnectorTableHandle table)
Return the metadata for the specified table handle.
|
default TableStatistics |
ConnectorMetadata.getTableStatistics(ConnectorSession session,
ConnectorTableHandle tableHandle,
Constraint<ColumnHandle> constraint)
Get statistics for table for given filtering constraint.
|
default ColumnHandle |
ConnectorMetadata.getUpdateRowIdColumnHandle(ConnectorSession session,
ConnectorTableHandle tableHandle)
Get the column handle that will generate row IDs for the delete operation.
|
default Map<SchemaTableName,ConnectorViewDefinition> |
ConnectorMetadata.getViews(ConnectorSession session,
SchemaTablePrefix prefix)
Gets the view data for views that match the specified table prefix.
|
default void |
ConnectorMetadata.grantRoles(ConnectorSession connectorSession,
Set<String> roles,
Set<PrestoPrincipal> grantees,
boolean withAdminOption,
Optional<PrestoPrincipal> grantor)
Grants the specified roles to the specified grantees
|
default void |
ConnectorMetadata.grantTablePrivileges(ConnectorSession session,
SchemaTableName tableName,
Set<Privilege> privileges,
PrestoPrincipal grantee,
boolean grantOption)
Grants the specified privilege to the specified user on the specified table
|
default boolean |
ConnectorMetadata.isRefinedPartitioningOver(ConnectorSession session,
ConnectorPartitioningHandle left,
ConnectorPartitioningHandle right)
Partitioning
a = {a_1, ... |
default Set<RoleGrant> |
ConnectorMetadata.listApplicableRoles(ConnectorSession session,
PrestoPrincipal principal)
List applicable roles, including the transitive grants, for the specified principal
|
default Set<String> |
ConnectorMetadata.listEnabledRoles(ConnectorSession session)
List applicable roles, including the transitive grants, in given session
|
default List<ConnectorPartitionHandle> |
ConnectorNodePartitioningProvider.listPartitionHandles(ConnectorTransactionHandle transactionHandle,
ConnectorSession session,
ConnectorPartitioningHandle partitioningHandle)
Returns a list of all partitions associated with the provided
partitioningHandle. |
default Set<RoleGrant> |
ConnectorMetadata.listRoleGrants(ConnectorSession session,
PrestoPrincipal principal)
List role grants for a given principal, not recursively.
|
default Set<String> |
ConnectorMetadata.listRoles(ConnectorSession session)
List available roles.
|
List<String> |
ConnectorMetadata.listSchemaNames(ConnectorSession session)
Returns the schemas provided by this connector.
|
Map<SchemaTableName,List<ColumnMetadata>> |
ConnectorMetadata.listTableColumns(ConnectorSession session,
SchemaTablePrefix prefix)
Gets the metadata for all columns that match the specified table prefix.
|
default List<GrantInfo> |
ConnectorMetadata.listTablePrivileges(ConnectorSession session,
SchemaTablePrefix prefix)
List the table privileges granted to the specified grantee for the tables that have the specified prefix considering the selected session role
|
default List<SchemaTableName> |
ConnectorMetadata.listTables(ConnectorSession session,
Optional<String> schemaName)
List table names, possibly filtered by schema.
|
default List<SchemaTableName> |
ConnectorMetadata.listTables(ConnectorSession session,
String schemaNameOrNull)
Deprecated.
|
default List<SchemaTableName> |
ConnectorMetadata.listViews(ConnectorSession session,
Optional<String> schemaName) |
default List<SchemaTableName> |
ConnectorMetadata.listViews(ConnectorSession session,
String schemaNameOrNull)
Deprecated.
|
default OptionalLong |
ConnectorMetadata.metadataDelete(ConnectorSession session,
ConnectorTableHandle tableHandle,
ConnectorTableLayoutHandle tableLayoutHandle)
Delete the provided table layout
|
default void |
ConnectorMetadata.renameColumn(ConnectorSession session,
ConnectorTableHandle tableHandle,
ColumnHandle source,
String target)
Rename the specified column
|
default void |
ConnectorMetadata.renameSchema(ConnectorSession session,
String source,
String target)
Renames the specified schema.
|
default void |
ConnectorMetadata.renameTable(ConnectorSession session,
ConnectorTableHandle tableHandle,
SchemaTableName newTableName)
Rename the specified table
|
default Optional<ConnectorResolvedIndex> |
ConnectorMetadata.resolveIndex(ConnectorSession session,
ConnectorTableHandle tableHandle,
Set<ColumnHandle> indexableColumns,
Set<ColumnHandle> outputColumns,
TupleDomain<ColumnHandle> tupleDomain)
Try to locate a table index that can lookup results by indexableColumns and provide the requested outputColumns.
|
default void |
ConnectorMetadata.revokeRoles(ConnectorSession connectorSession,
Set<String> roles,
Set<PrestoPrincipal> grantees,
boolean adminOptionFor,
Optional<PrestoPrincipal> grantor)
Revokes the specified roles from the specified grantees
|
default void |
ConnectorMetadata.revokeTablePrivileges(ConnectorSession session,
SchemaTableName tableName,
Set<Privilege> privileges,
PrestoPrincipal grantee,
boolean grantOption)
Revokes the specified privilege on the specified table from the specified user
|
default boolean |
ConnectorMetadata.schemaExists(ConnectorSession session,
String schemaName)
Checks if a schema exists.
|
default boolean |
ConnectorMetadata.supportsMetadataDelete(ConnectorSession session,
ConnectorTableHandle tableHandle) |
| Modifier and Type | Method and Description |
|---|---|
Object |
Marker.getPrintableValue(ConnectorSession session) |
String |
ValueSet.toString(ConnectorSession session) |
String |
TupleDomain.toString(ConnectorSession session) |
String |
SortedRangeSet.toString(ConnectorSession session) |
String |
Range.toString(ConnectorSession session) |
String |
Marker.toString(ConnectorSession session) |
String |
EquatableValueSet.toString(ConnectorSession session) |
String |
Domain.toString(ConnectorSession session) |
String |
AllOrNoneValueSet.toString(ConnectorSession session) |
| Modifier and Type | Method and Description |
|---|---|
<T> DomainTranslator.ExtractionResult<T> |
DomainTranslator.fromPredicate(ConnectorSession session,
RowExpression predicate,
DomainTranslator.ColumnExtractor<T> columnExtractor)
Convert a RowExpression predicate into an ExtractionResult consisting of:
1) A successfully extracted TupleDomain
2) An RowExpression fragment which represents the part of the original RowExpression that will need to be re-evaluated
after filtering with the TupleDomain.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
VarcharType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
VarbinaryType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
Type.getObjectValue(ConnectorSession session,
Block block,
int position)
Gets an object representation of the type value in the
block
position. |
Object |
TinyintType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
TimestampWithTimeZoneType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
TimestampType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
TimeWithTimeZoneType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
TimeType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
SmallintType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
RowType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
RealType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
QuantileDigestType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
P4HyperLogLogType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
MapType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
IntegerType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
HyperLogLogType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
FunctionType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
DoubleType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
DateType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
CharType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
BooleanType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
BigintType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Object |
ArrayType.getObjectValue(ConnectorSession session,
Block block,
int position) |
Copyright © 2012–2019. All rights reserved.