org.apache.hadoop.hive.ql.parse.repl.dump

Class Utils

java.lang.Object

org.apache.hadoop.hive.ql.parse.repl.dump.Utils

public class Utils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Utils.ReplDumpState

Field Summary

Fields

Modifier and Type	Field and Description
static String	BOOTSTRAP_DUMP_STATE_KEY_PREFIX

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

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(org.apache.hadoop.hive.metastore.api.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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BOOTSTRAP_DUMP_STATE_KEY_PREFIX

public static final String BOOTSTRAP_DUMP_STATE_KEY_PREFIX

See Also:

Constant Field Values

Constructor Detail

Utils

public Utils()

Method Detail

writeOutput

public static void writeOutput(List<String> values,
                               org.apache.hadoop.fs.Path outputFile,
                               HiveConf hiveConf)
                        throws SemanticException

Throws:

SemanticException

matchesDb

public static Iterable<? extends String> matchesDb(Hive db,
                                                   String dbPattern)
                                            throws HiveException

Throws:

HiveException

matchesTbl

public static Iterable<? extends String> matchesTbl(Hive db,
                                                    String dbName,
                                                    String tblPattern)
                                             throws HiveException

Throws:

HiveException

getAllTables

public static Collection<String> getAllTables(Hive db,
                                              String dbName)
                                       throws HiveException

Throws:

HiveException

setDbBootstrapDumpState

public static String setDbBootstrapDumpState(Hive hiveDb,
                                             String dbName)
                                      throws HiveException

Throws:

HiveException

resetDbBootstrapDumpState

public static void resetDbBootstrapDumpState(Hive hiveDb,
                                             String dbName,
                                             String uniqueKey)
                                      throws HiveException

Throws:

HiveException

isBootstrapDumpInProgress

public static boolean isBootstrapDumpInProgress(Hive hiveDb,
                                                String dbName)
                                         throws HiveException

Throws:

HiveException

shouldReplicate

public 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.

shouldReplicate

public static boolean shouldReplicate(org.apache.hadoop.hive.metastore.api.NotificationEvent tableForEvent,
                                      ReplicationSpec replicationSpec,
                                      Hive db,
                                      HiveConf hiveConf)