public class HiveTableUtil extends Object
Modifier and Type | Method and Description |
---|---|
static List<org.apache.hadoop.hive.metastore.api.FieldSchema> |
createHiveColumns(TableSchema schema)
Create Hive columns from Flink TableSchema.
|
static org.apache.hadoop.hive.metastore.api.Partition |
createHivePartition(String dbName,
String tableName,
List<String> values,
org.apache.hadoop.hive.metastore.api.StorageDescriptor sd,
Map<String,String> parameters)
Creates a Hive partition instance.
|
static Properties |
createPropertiesFromStorageDescriptor(org.apache.hadoop.hive.metastore.api.StorageDescriptor storageDescriptor)
Create properties info to initialize a SerDe.
|
static TableSchema |
createTableSchema(List<org.apache.hadoop.hive.metastore.api.FieldSchema> cols,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> partitionKeys)
Create a Flink's TableSchema from Hive table's columns and partition keys.
|
public static TableSchema createTableSchema(List<org.apache.hadoop.hive.metastore.api.FieldSchema> cols, List<org.apache.hadoop.hive.metastore.api.FieldSchema> partitionKeys)
public static List<org.apache.hadoop.hive.metastore.api.FieldSchema> createHiveColumns(TableSchema schema)
public static Properties createPropertiesFromStorageDescriptor(org.apache.hadoop.hive.metastore.api.StorageDescriptor storageDescriptor)
storageDescriptor
- Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.