Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.constraints | |
org.apache.flink.table.catalog.hive.client | |
org.apache.flink.table.catalog.hive.util |
Modifier and Type | Method and Description |
---|---|
Optional<UniqueConstraint> |
TableSchema.getPrimaryKey()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static UniqueConstraint |
UniqueConstraint.primaryKey(String name,
List<String> columns)
Deprecated.
Creates a non enforced
ConstraintType#PRIMARY_KEY constraint. |
Modifier and Type | Method and Description |
---|---|
Optional<UniqueConstraint> |
HiveShimV210.getPrimaryKey(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
String dbName,
String tableName,
byte requiredTrait) |
Optional<UniqueConstraint> |
HiveShim.getPrimaryKey(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
String dbName,
String tableName,
byte requiredTrait)
Get the primary key of a Hive table and convert it to a UniqueConstraint.
|
Optional<UniqueConstraint> |
HiveShimV100.getPrimaryKey(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
String dbName,
String tableName,
byte requiredTrait) |
Optional<UniqueConstraint> |
HiveMetastoreClientWrapper.getPrimaryKey(String dbName,
String tableName,
byte trait) |
Modifier and Type | Method and Description |
---|---|
void |
HiveShimV210.createTableWithConstraints(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
org.apache.hadoop.hive.metastore.api.Table table,
org.apache.hadoop.conf.Configuration conf,
UniqueConstraint pk,
List<Byte> pkTraits,
List<String> notNullCols,
List<Byte> nnTraits) |
void |
HiveShim.createTableWithConstraints(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
org.apache.hadoop.hive.metastore.api.Table table,
org.apache.hadoop.conf.Configuration conf,
UniqueConstraint pk,
List<Byte> pkTraits,
List<String> notNullCols,
List<Byte> nnTraits)
Creates a table with PK and NOT NULL constraints.
|
void |
HiveShimV310.createTableWithConstraints(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
org.apache.hadoop.hive.metastore.api.Table table,
org.apache.hadoop.conf.Configuration conf,
UniqueConstraint pk,
List<Byte> pkTraits,
List<String> notNullCols,
List<Byte> nnTraits) |
void |
HiveShimV100.createTableWithConstraints(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
org.apache.hadoop.hive.metastore.api.Table table,
org.apache.hadoop.conf.Configuration conf,
UniqueConstraint pk,
List<Byte> pkTraits,
List<String> notNullCols,
List<Byte> nnTraits) |
void |
HiveMetastoreClientWrapper.createTableWithConstraints(org.apache.hadoop.hive.metastore.api.Table table,
org.apache.hadoop.conf.Configuration conf,
UniqueConstraint pk,
List<Byte> pkTraits,
List<String> notNullCols,
List<Byte> nnTraits) |
Modifier and Type | Method and Description |
---|---|
static ResolvedSchema |
HiveTableUtil.createResolvedSchema(List<org.apache.hadoop.hive.metastore.api.FieldSchema> nonPartCols,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> partitionKeys,
Set<String> notNullColumns,
UniqueConstraint primaryKey)
Create a Flink's ResolvedSchema from Hive table's columns and partition keys.
|
static Schema |
HiveTableUtil.createSchema(List<org.apache.hadoop.hive.metastore.api.FieldSchema> nonPartCols,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> partitionKeys,
Set<String> notNullColumns,
UniqueConstraint primaryKey)
Create a Flink's Schema from Hive table's columns and partition keys.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.