public class ReplUtils extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ReplUtils.ReplLoadOpType
Bootstrap REPL LOAD operation type on the examined object based on ckpt state.
|
Modifier and Type | Field and Description |
---|---|
static String |
REPL_CHECKPOINT_KEY |
Constructor and Description |
---|
ReplUtils() |
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) |
public static final String REPL_CHECKPOINT_KEY
public static Map<Integer,List<ExprNodeGenericFuncDesc>> genPartSpecs(Table table, List<Map<String,String>> partitions) throws SemanticException
SemanticException
public static Task<?> getTableReplLogTask(ImportTableDesc tableDesc, ReplLogger replLogger, HiveConf conf) throws SemanticException
SemanticException
public static Task<?> getTableCheckpointTask(ImportTableDesc tableDesc, HashMap<String,String> partSpec, String dumpRoot, HiveConf conf) throws SemanticException
SemanticException
public static boolean replCkptStatus(String dbName, Map<String,String> props, String dumpRoot) throws InvalidOperationException
InvalidOperationException
Copyright © 2022 The Apache Software Foundation. All rights reserved.