public class Inputs
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DATA_SCHEMA_FILE_HDFS |
static java.lang.String |
DATA_SCHEMA_FILE_LOCALFS |
static java.lang.String |
DATE |
static java.lang.String |
DNS_HOSTNAME_QUERY |
static java.lang.String |
DNS_HOSTNAME_QUERY_FILE |
static java.lang.String |
DNS_HOSTNAME_QUERY_FILE_HDFS |
static java.lang.String |
DNS_IP_QUERY |
static java.lang.String |
DNS_IP_QUERY_FILE |
static java.lang.String |
DNS_IP_QUERY_FILE_HDFS |
static java.lang.String |
DNS_NXDOMAIN_QUERY |
static java.lang.String |
DNS_NXDOMAIN_QUERY_FILE |
static java.lang.String |
DNS_NXDOMAIN_QUERY_FILE_HDFS |
static java.lang.String |
DNS_SRCIP_QUERY |
static java.lang.String |
DNS_SRCIP_QUERY_FILE |
static java.lang.String |
DNS_SRCIP_QUERY_FILE_HDFS |
static java.lang.String |
DNS_SRCIP_QUERY_NO_FILTER |
static java.lang.String |
DNS_SRCIP_QUERY_NO_FILTER_FILE |
static java.lang.String |
DNS_SRCIP_QUERY_NO_FILTER_FILE_HDFS |
static java.lang.String |
DSTIP |
static java.lang.String |
HDFS_QUERY_FILES |
static java.lang.String |
IPS |
static java.lang.String |
LOCALFS_QUERY_FILES |
static java.lang.String |
QNAME |
static java.lang.String |
QTYPE |
static java.lang.String |
RCODE |
static java.lang.String |
SRCIP |
static java.lang.String |
TEST_DATA_SCHEMA_NAME |
Constructor and Description |
---|
Inputs() |
Modifier and Type | Method and Description |
---|---|
static void |
createESInput()
Creates Elasticsearch input
|
static java.util.ArrayList<org.json.simple.JSONObject> |
createJSONDataElements()
Creates PIR JSON input
|
static java.util.List<org.json.simple.JSONObject> |
createJSONInput(org.apache.hadoop.fs.FileSystem fs)
Creates JSON input and writes to hdfs
|
static void |
createSchemaFiles(org.apache.hadoop.fs.FileSystem fs,
boolean hdfs,
java.lang.String filter)
Create and load the data and query schema files used for testing
|
static void |
createSchemaFiles(java.lang.String filter)
Create and load the data and query schema files used for testing
|
static java.lang.String |
createStopList(org.apache.hadoop.fs.FileSystem fs,
boolean hdfs)
Creates stoplist file
|
static void |
deleteESInput()
Delete the ElasticSearch indices that was used for functional testing
|
static java.util.ArrayList<org.json.simple.JSONObject> |
getRcode3JSONDataElements()
Creates an ArrayList of JSONObjects with RCODE value of 3
|
public static final java.lang.String DATE
public static final java.lang.String QNAME
public static final java.lang.String SRCIP
public static final java.lang.String DSTIP
public static final java.lang.String QTYPE
public static final java.lang.String RCODE
public static final java.lang.String IPS
public static final java.lang.String DNS_HOSTNAME_QUERY
public static final java.lang.String DNS_IP_QUERY
public static final java.lang.String DNS_NXDOMAIN_QUERY
public static final java.lang.String DNS_SRCIP_QUERY
public static final java.lang.String DNS_SRCIP_QUERY_NO_FILTER
public static final java.lang.String DNS_HOSTNAME_QUERY_FILE
public static final java.lang.String DNS_IP_QUERY_FILE
public static final java.lang.String DNS_NXDOMAIN_QUERY_FILE
public static final java.lang.String DNS_SRCIP_QUERY_FILE
public static final java.lang.String DNS_SRCIP_QUERY_NO_FILTER_FILE
public static final java.lang.String DNS_HOSTNAME_QUERY_FILE_HDFS
public static final java.lang.String DNS_IP_QUERY_FILE_HDFS
public static final java.lang.String DNS_NXDOMAIN_QUERY_FILE_HDFS
public static final java.lang.String DNS_SRCIP_QUERY_FILE_HDFS
public static final java.lang.String DNS_SRCIP_QUERY_NO_FILTER_FILE_HDFS
public static final java.lang.String LOCALFS_QUERY_FILES
public static final java.lang.String HDFS_QUERY_FILES
public static final java.lang.String TEST_DATA_SCHEMA_NAME
public static final java.lang.String DATA_SCHEMA_FILE_LOCALFS
public static final java.lang.String DATA_SCHEMA_FILE_HDFS
public static void deleteESInput()
public static java.util.ArrayList<org.json.simple.JSONObject> createJSONDataElements()
public static java.util.ArrayList<org.json.simple.JSONObject> getRcode3JSONDataElements()
public static java.util.List<org.json.simple.JSONObject> createJSONInput(org.apache.hadoop.fs.FileSystem fs)
public static void createESInput()
public static java.lang.String createStopList(org.apache.hadoop.fs.FileSystem fs, boolean hdfs) throws java.io.IOException, PIRException
java.io.IOException
PIRException
public static void createSchemaFiles(java.lang.String filter) throws java.lang.Exception
java.lang.Exception
public static void createSchemaFiles(org.apache.hadoop.fs.FileSystem fs, boolean hdfs, java.lang.String filter) throws java.lang.Exception
Writes both local and hdfs schema files if hdfs=true -- only updates the corresponding properties for the local files
java.lang.Exception