public class TestUtils
extends java.lang.Object
Constructor and Description |
---|
TestUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
addElement(org.w3c.dom.Document doc,
org.w3c.dom.Element rootElement,
java.lang.String elementName,
java.lang.String typeIn,
java.lang.String isArrayIn,
java.lang.String partitionerIn)
Helper method to add elements to the test data schema
|
static void |
createQuerySchema(java.lang.String schemaFile,
java.lang.String querySchemaName,
java.lang.String dataSchemaNameInput,
java.lang.String selectorNameInput,
java.util.List<java.lang.String> elementNames,
java.util.List<java.lang.String> filterNames,
java.lang.String filter)
Creates the test query schema file
|
static void |
createQuerySchema(java.lang.String schemaFile,
java.lang.String querySchemaName,
java.lang.String dataSchemaNameInput,
java.lang.String selectorNameInput,
java.util.List<java.lang.String> elementNames,
java.util.List<java.lang.String> filterNames,
java.lang.String filter,
boolean append,
org.apache.hadoop.fs.FileSystem fs,
boolean hdfs)
Creates the test query schema file
|
static void |
createQuerySchema(java.lang.String schemaFile,
java.lang.String querySchemaName,
java.lang.String dataSchemaNameInput,
java.lang.String selectorNameInput,
java.util.List<java.lang.String> elementNames,
java.util.List<java.lang.String> filterNames,
java.lang.String filter,
boolean append,
org.apache.hadoop.fs.FileSystem fs,
boolean hdfs,
java.util.HashMap<java.lang.String,java.lang.String> additionalFields)
Creates the test query schema file
|
static void |
deleteESTestIndex(java.lang.String index)
Method to delete an ES index
|
static void |
executeCommand(java.lang.ProcessBuilder p)
Method to execute process
|
static java.util.List<QueryResponseJSON> |
readResultsFile(java.io.File file)
Converts the result file into an ArrayList of QueryResponseJSON objects
|
static java.lang.String |
writeToTmpFile(java.util.List<java.lang.String> list,
java.lang.String fileName,
java.lang.String suffix)
Write the ArrayList |
public static void deleteESTestIndex(java.lang.String index)
public static void executeCommand(java.lang.ProcessBuilder p) throws java.io.IOException
java.io.IOException
public static void addElement(org.w3c.dom.Document doc, org.w3c.dom.Element rootElement, java.lang.String elementName, java.lang.String typeIn, java.lang.String isArrayIn, java.lang.String partitionerIn)
public static void createQuerySchema(java.lang.String schemaFile, java.lang.String querySchemaName, java.lang.String dataSchemaNameInput, java.lang.String selectorNameInput, java.util.List<java.lang.String> elementNames, java.util.List<java.lang.String> filterNames, java.lang.String filter) throws java.io.IOException
java.io.IOException
public static void createQuerySchema(java.lang.String schemaFile, java.lang.String querySchemaName, java.lang.String dataSchemaNameInput, java.lang.String selectorNameInput, java.util.List<java.lang.String> elementNames, java.util.List<java.lang.String> filterNames, java.lang.String filter, boolean append, org.apache.hadoop.fs.FileSystem fs, boolean hdfs) throws java.io.IOException
java.io.IOException
public static void createQuerySchema(java.lang.String schemaFile, java.lang.String querySchemaName, java.lang.String dataSchemaNameInput, java.lang.String selectorNameInput, java.util.List<java.lang.String> elementNames, java.util.List<java.lang.String> filterNames, java.lang.String filter, boolean append, org.apache.hadoop.fs.FileSystem fs, boolean hdfs, java.util.HashMap<java.lang.String,java.lang.String> additionalFields) throws java.io.IOException
java.io.IOException
public static java.util.List<QueryResponseJSON> readResultsFile(java.io.File file) throws java.io.IOException
java.io.IOException
- - IOException
public static java.lang.String writeToTmpFile(java.util.List<java.lang.String> list, java.lang.String fileName, java.lang.String suffix) throws java.io.IOException
java.io.IOException
- - IOException