public class HiveUtils extends Object
FileStoreTable
and Predicate
.Constructor and Description |
---|
HiveUtils() |
Modifier and Type | Method and Description |
---|---|
static FileStoreTable |
createFileStoreTable(org.apache.hadoop.mapred.JobConf jobConf) |
static Optional<Predicate> |
createPredicate(TableSchema tableSchema,
org.apache.hadoop.mapred.JobConf jobConf,
boolean limitToReadColumnNames) |
static Options |
extractCatalogConfig(org.apache.hadoop.conf.Configuration hiveConf)
Extract paimon catalog conf from Hive conf.
|
static String |
extractTagName(String location,
String tagToPartField)
Extract tag name from location, partition field should be tag name.
|
public static FileStoreTable createFileStoreTable(org.apache.hadoop.mapred.JobConf jobConf)
public static Optional<Predicate> createPredicate(TableSchema tableSchema, org.apache.hadoop.mapred.JobConf jobConf, boolean limitToReadColumnNames)
public static Options extractCatalogConfig(org.apache.hadoop.conf.Configuration hiveConf)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.