public class QTestUtil
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
QTestUtil.QTestSetup
QTestSetup defines test fixtures which are reused across testcases,
and are needed before any test can be run
|
static class |
QTestUtil.QTRunner
QTRunner: Runnable class for running a a single query file.
|
Modifier and Type | Field and Description |
---|---|
protected HiveConf |
conf |
protected java.lang.String |
logDir |
protected java.lang.String |
outDir |
protected boolean |
overWrite |
static java.util.HashSet<java.lang.String> |
srcTables |
Constructor and Description |
---|
QTestUtil(java.lang.String outDir,
java.lang.String logDir) |
QTestUtil(java.lang.String outDir,
java.lang.String logDir,
boolean miniMr,
java.lang.String hadoopVer) |
Modifier and Type | Method and Description |
---|---|
void |
addFile(java.io.File qf) |
void |
addFile(java.lang.String qFile) |
java.util.List<Task<? extends java.io.Serializable>> |
analyzeAST(ASTNode ast) |
int |
checkCliDriverResults(java.lang.String tname) |
int |
checkNegativeResults(java.lang.String tname,
java.lang.Exception e) |
int |
checkParseResults(java.lang.String tname,
ASTNode tree) |
int |
checkPlan(java.lang.String tname,
java.util.List<Task<? extends java.io.Serializable>> tasks) |
void |
cleanUp() |
void |
clearPostTestEffects()
Clear out any side effects of running tests
|
void |
clearTestSideEffects()
Clear out any side effects of running tests
|
void |
cliInit(java.lang.String tname) |
void |
cliInit(java.lang.String tname,
boolean recreate) |
void |
convertSequenceFileToTextFile() |
void |
copyDirectoryToLocal(Path src,
Path dest) |
void |
createSources() |
boolean |
deleteDirectory(java.io.File path) |
int |
execute(java.lang.String tname) |
int |
executeClient(java.lang.String tname) |
int |
executeOne(java.lang.String tname) |
java.lang.String |
getLogDirectory() |
java.lang.String |
getOutputDirectory() |
java.util.TreeMap<java.lang.String,java.lang.String> |
getQMap() |
void |
init() |
void |
init(java.lang.String tname) |
void |
initConf() |
void |
normalizeNames(java.io.File path) |
java.lang.String |
outPath(java.lang.String outDir,
java.lang.String testName)
Given the current configurations (e.g., hadoop version and execution mode), return
the correct file name to compare with the current test run output.
|
static void |
outputTestFailureHelpMessage() |
ASTNode |
parseQuery(java.lang.String tname) |
static boolean |
queryListRunnerMultiThreaded(java.io.File[] qfiles,
QTestUtil[] qt)
Executes a set of query files parallel.
|
static QTestUtil[] |
queryListRunnerSetup(java.io.File[] qfiles,
java.lang.String resDir,
java.lang.String logDir)
Setup to execute a set of query files.
|
static boolean |
queryListRunnerSingleThreaded(java.io.File[] qfiles,
QTestUtil[] qt)
Executes a set of query files in sequence.
|
void |
resetParser() |
boolean |
shouldBeSkipped(java.lang.String tname) |
void |
shutdown() |
protected final java.lang.String outDir
protected final java.lang.String logDir
public static final java.util.HashSet<java.lang.String> srcTables
protected HiveConf conf
protected final boolean overWrite
public QTestUtil(java.lang.String outDir, java.lang.String logDir) throws java.lang.Exception
java.lang.Exception
public QTestUtil(java.lang.String outDir, java.lang.String logDir, boolean miniMr, java.lang.String hadoopVer) throws java.lang.Exception
java.lang.Exception
public boolean deleteDirectory(java.io.File path)
public void copyDirectoryToLocal(Path src, Path dest) throws java.lang.Exception
java.lang.Exception
public void normalizeNames(java.io.File path) throws java.lang.Exception
java.lang.Exception
public java.lang.String getOutputDirectory()
public java.lang.String getLogDirectory()
public void initConf() throws java.lang.Exception
java.lang.Exception
public void shutdown() throws java.lang.Exception
java.lang.Exception
public void addFile(java.lang.String qFile) throws java.lang.Exception
java.lang.Exception
public void addFile(java.io.File qf) throws java.lang.Exception
java.lang.Exception
public void clearPostTestEffects() throws java.lang.Exception
java.lang.Exception
public void clearTestSideEffects() throws java.lang.Exception
java.lang.Exception
public void cleanUp() throws java.lang.Exception
java.lang.Exception
public void createSources() throws java.lang.Exception
java.lang.Exception
public void init() throws java.lang.Exception
java.lang.Exception
public void init(java.lang.String tname) throws java.lang.Exception
java.lang.Exception
public void cliInit(java.lang.String tname) throws java.lang.Exception
java.lang.Exception
public void cliInit(java.lang.String tname, boolean recreate) throws java.lang.Exception
java.lang.Exception
public int executeOne(java.lang.String tname)
public int execute(java.lang.String tname)
public int executeClient(java.lang.String tname)
public boolean shouldBeSkipped(java.lang.String tname)
public void convertSequenceFileToTextFile() throws java.lang.Exception
java.lang.Exception
public int checkNegativeResults(java.lang.String tname, java.lang.Exception e) throws java.lang.Exception
java.lang.Exception
public int checkParseResults(java.lang.String tname, ASTNode tree) throws java.lang.Exception
java.lang.Exception
public int checkPlan(java.lang.String tname, java.util.List<Task<? extends java.io.Serializable>> tasks) throws java.lang.Exception
java.lang.Exception
public java.lang.String outPath(java.lang.String outDir, java.lang.String testName)
outDir
- The directory where the reference log files are stored.testName
- The test file name (terminated by ".out").public int checkCliDriverResults(java.lang.String tname) throws java.lang.Exception
java.lang.Exception
public ASTNode parseQuery(java.lang.String tname) throws java.lang.Exception
java.lang.Exception
public void resetParser() throws SemanticException
SemanticException
public java.util.List<Task<? extends java.io.Serializable>> analyzeAST(ASTNode ast) throws java.lang.Exception
java.lang.Exception
public java.util.TreeMap<java.lang.String,java.lang.String> getQMap()
public static QTestUtil[] queryListRunnerSetup(java.io.File[] qfiles, java.lang.String resDir, java.lang.String logDir) throws java.lang.Exception
qfiles
- array of input query files containing arbitrary number of hive
queriesresDir
- output directorylogDir
- log directoryjava.lang.Exception
public static boolean queryListRunnerSingleThreaded(java.io.File[] qfiles, QTestUtil[] qt) throws java.lang.Exception
qfiles
- array of input query files containing arbitrary number of hive
queriesqt
- array of QTestUtils, one per qfilejava.lang.Exception
public static boolean queryListRunnerMultiThreaded(java.io.File[] qfiles, QTestUtil[] qt) throws java.lang.Exception
qfiles
- array of input query files containing arbitrary number of hive
queriesqt
- array of QTestUtils, one per qfilejava.lang.Exception
public static void outputTestFailureHelpMessage()
Copyright © 2012 The Apache Software Foundation