public class Utils extends Object
Modifier and Type | Class and Description |
---|---|
static class |
Utils.ReplDumpState |
Modifier and Type | Field and Description |
---|---|
static String |
BOOTSTRAP_DUMP_STATE_KEY_PREFIX |
Constructor and Description |
---|
Utils() |
Modifier and Type | Method and Description |
---|---|
static Collection<String> |
getAllTables(Hive db,
String dbName) |
static boolean |
isBootstrapDumpInProgress(Hive hiveDb,
String dbName) |
static Iterable<? extends String> |
matchesDb(Hive db,
String dbPattern) |
static Iterable<? extends String> |
matchesTbl(Hive db,
String dbName,
String tblPattern) |
static void |
resetDbBootstrapDumpState(Hive hiveDb,
String dbName,
String uniqueKey) |
static String |
setDbBootstrapDumpState(Hive hiveDb,
String dbName) |
static boolean |
shouldReplicate(NotificationEvent tableForEvent,
ReplicationSpec replicationSpec,
Hive db,
HiveConf hiveConf) |
static Boolean |
shouldReplicate(ReplicationSpec replicationSpec,
Table tableHandle,
HiveConf hiveConf)
validates if a table can be exported, similar to EximUtil.shouldExport with few replication
specific checks.
|
static void |
writeOutput(List<String> values,
org.apache.hadoop.fs.Path outputFile,
HiveConf hiveConf) |
public static final String BOOTSTRAP_DUMP_STATE_KEY_PREFIX
public static void writeOutput(List<String> values, org.apache.hadoop.fs.Path outputFile, HiveConf hiveConf) throws SemanticException
SemanticException
public static Iterable<? extends String> matchesDb(Hive db, String dbPattern) throws HiveException
HiveException
public static Iterable<? extends String> matchesTbl(Hive db, String dbName, String tblPattern) throws HiveException
HiveException
public static Collection<String> getAllTables(Hive db, String dbName) throws HiveException
HiveException
public static String setDbBootstrapDumpState(Hive hiveDb, String dbName) throws HiveException
HiveException
public static void resetDbBootstrapDumpState(Hive hiveDb, String dbName, String uniqueKey) throws HiveException
HiveException
public static boolean isBootstrapDumpInProgress(Hive hiveDb, String dbName) throws HiveException
HiveException
public static Boolean shouldReplicate(ReplicationSpec replicationSpec, Table tableHandle, HiveConf hiveConf)
public static boolean shouldReplicate(NotificationEvent tableForEvent, ReplicationSpec replicationSpec, Hive db, HiveConf hiveConf)
Copyright © 2022 The Apache Software Foundation. All rights reserved.