public class DistTestSuite
extends java.lang.Object
Constructor and Description |
---|
DistTestSuite() |
Modifier and Type | Method and Description |
---|---|
static java.util.List<QueryResponseJSON> |
performQuery(java.lang.String queryType,
java.util.ArrayList<java.lang.String> selectors,
org.apache.hadoop.fs.FileSystem fs,
boolean isSpark,
int numThreads,
boolean isStreaming) |
static void |
testESInputMR(org.apache.hadoop.fs.FileSystem fs,
java.util.List<org.json.simple.JSONObject> dataElements) |
static void |
testESInputSpark(org.apache.hadoop.fs.FileSystem fs,
java.util.List<org.json.simple.JSONObject> dataElements) |
static void |
testESInputSparkStreaming(org.apache.hadoop.fs.FileSystem fs,
java.util.List<org.json.simple.JSONObject> pirDataElements) |
static void |
testJSONInputMR(org.apache.hadoop.fs.FileSystem fs,
java.util.List<org.json.simple.JSONObject> dataElements) |
static void |
testJSONInputSpark(org.apache.hadoop.fs.FileSystem fs,
java.util.List<org.json.simple.JSONObject> dataElements) |
static void |
testJSONInputSparkStreaming(org.apache.hadoop.fs.FileSystem fs,
java.util.List<org.json.simple.JSONObject> pirDataElements) |
static void |
testSparkStreaming(org.apache.hadoop.fs.FileSystem fs,
java.util.List<org.json.simple.JSONObject> pirDataElements) |
public static void testJSONInputMR(org.apache.hadoop.fs.FileSystem fs, java.util.List<org.json.simple.JSONObject> dataElements) throws java.lang.Exception
java.lang.Exception
public static void testESInputMR(org.apache.hadoop.fs.FileSystem fs, java.util.List<org.json.simple.JSONObject> dataElements) throws java.lang.Exception
java.lang.Exception
public static void testJSONInputSpark(org.apache.hadoop.fs.FileSystem fs, java.util.List<org.json.simple.JSONObject> dataElements) throws java.lang.Exception
java.lang.Exception
public static void testESInputSpark(org.apache.hadoop.fs.FileSystem fs, java.util.List<org.json.simple.JSONObject> dataElements) throws java.lang.Exception
java.lang.Exception
public static void testSparkStreaming(org.apache.hadoop.fs.FileSystem fs, java.util.List<org.json.simple.JSONObject> pirDataElements) throws java.lang.Exception
java.lang.Exception
public static void testJSONInputSparkStreaming(org.apache.hadoop.fs.FileSystem fs, java.util.List<org.json.simple.JSONObject> pirDataElements) throws java.lang.Exception
java.lang.Exception
public static void testESInputSparkStreaming(org.apache.hadoop.fs.FileSystem fs, java.util.List<org.json.simple.JSONObject> pirDataElements) throws java.lang.Exception
java.lang.Exception
public static java.util.List<QueryResponseJSON> performQuery(java.lang.String queryType, java.util.ArrayList<java.lang.String> selectors, org.apache.hadoop.fs.FileSystem fs, boolean isSpark, int numThreads, boolean isStreaming) throws java.lang.Exception
java.lang.Exception