org.apache.hadoop.hive.ql.exec.repl

Class ReplUtils

java.lang.Object

org.apache.hadoop.hive.ql.exec.repl.ReplUtils

public class ReplUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReplUtils.ReplLoadOpType Bootstrap REPL LOAD operation type on the examined object based on ckpt state.

Field Summary

Fields

Modifier and Type	Field and Description
static String	REPL_CHECKPOINT_KEY

Constructor Summary

Constructors

Constructor and Description
ReplUtils()

Method Summary

Modifier and Type	Method and Description
static Map<Integer,List<ExprNodeGenericFuncDesc>>	genPartSpecs(Table table, List<Map<String,String>> partitions)
static Task<?>	getTableCheckpointTask(ImportTableDesc tableDesc, HashMap<String,String> partSpec, String dumpRoot, HiveConf conf)
static Task<?>	getTableReplLogTask(ImportTableDesc tableDesc, ReplLogger replLogger, HiveConf conf)
static boolean	replCkptStatus(String dbName, Map<String,String> props, String dumpRoot)

Methods inherited from class java.lang.Object

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

Field Detail

REPL_CHECKPOINT_KEY

public static final String REPL_CHECKPOINT_KEY

See Also:

Constant Field Values

Constructor Detail

ReplUtils

public ReplUtils()

Method Detail

genPartSpecs

public static Map<Integer,List<ExprNodeGenericFuncDesc>> genPartSpecs(Table table,
                                                                      List<Map<String,String>> partitions)
                                                               throws SemanticException

Throws:

SemanticException

getTableReplLogTask

public static Task<?> getTableReplLogTask(ImportTableDesc tableDesc,
                                          ReplLogger replLogger,
                                          HiveConf conf)
                                   throws SemanticException

Throws:

SemanticException

getTableCheckpointTask

public static Task<?> getTableCheckpointTask(ImportTableDesc tableDesc,
                                             HashMap<String,String> partSpec,
                                             String dumpRoot,
                                             HiveConf conf)
                                      throws SemanticException

Throws:

SemanticException

replCkptStatus

public static boolean replCkptStatus(String dbName,
                                     Map<String,String> props,
                                     String dumpRoot)
                              throws org.apache.hadoop.hive.metastore.api.InvalidOperationException

Throws:

org.apache.hadoop.hive.metastore.api.InvalidOperationException