public static void createSchemaFiles(FileSystem fs,boolean hdfs,String filter) throws Exception {
  if (!hdfs) {
    createDataSchema(false);
  }
 else {
    createDataSchema(fs,true);
  }
  DataSchemaLoader.initialize();
  List<String> dnsHostnameQueryElements=Arrays.asList(DATE,SRCIP,DSTIP,QTYPE,RCODE,IPS);
  List<String> dnsHostnameQueryFilterElements=Collections.singletonList(QNAME);
  TestUtils.createQuerySchema(DNS_HOSTNAME_QUERY_FILE,DNS_HOSTNAME_QUERY,TEST_DATA_SCHEMA_NAME,QNAME,dnsHostnameQueryElements,dnsHostnameQueryFilterElements,filter);
  if (hdfs) {
    TestUtils.createQuerySchema(DNS_HOSTNAME_QUERY_FILE_HDFS,DNS_HOSTNAME_QUERY,TEST_DATA_SCHEMA_NAME,QNAME,dnsHostnameQueryElements,dnsHostnameQueryFilterElements,filter,false,fs,hdfs);
  }
  List<String> dnsIPQueryElements=Arrays.asList(SRCIP,DSTIP,IPS);
  List<String> dnsIPQueryFilterElements=Collections.singletonList(QNAME);
  TestUtils.createQuerySchema(DNS_IP_QUERY_FILE,DNS_IP_QUERY,TEST_DATA_SCHEMA_NAME,IPS,dnsIPQueryElements,dnsIPQueryFilterElements,filter);
  if (hdfs) {
    TestUtils.createQuerySchema(DNS_IP_QUERY_FILE_HDFS,DNS_IP_QUERY,TEST_DATA_SCHEMA_NAME,IPS,dnsIPQueryElements,dnsIPQueryFilterElements,filter,false,fs,hdfs);
  }
  List<String> dnsNXQueryElements=Arrays.asList(QNAME,SRCIP,DSTIP);
  List<String> dnsNXQueryFilterElements=Collections.singletonList(QNAME);
  TestUtils.createQuerySchema(DNS_NXDOMAIN_QUERY_FILE,DNS_NXDOMAIN_QUERY,TEST_DATA_SCHEMA_NAME,QNAME,dnsNXQueryElements,dnsNXQueryFilterElements,filter);
  if (hdfs) {
    TestUtils.createQuerySchema(DNS_NXDOMAIN_QUERY_FILE_HDFS,DNS_NXDOMAIN_QUERY,TEST_DATA_SCHEMA_NAME,QNAME,dnsNXQueryElements,dnsNXQueryFilterElements,filter,false,fs,hdfs);
  }
  List<String> dnsSrcIPQueryElements=Arrays.asList(QNAME,DSTIP,IPS);
  List<String> dnsSrcIPQueryFilterElements=Arrays.asList(SRCIP,IPS);
  TestUtils.createQuerySchema(DNS_SRCIP_QUERY_FILE,DNS_SRCIP_QUERY,TEST_DATA_SCHEMA_NAME,SRCIP,dnsSrcIPQueryElements,dnsSrcIPQueryFilterElements,filter);
  if (hdfs) {
    TestUtils.createQuerySchema(DNS_SRCIP_QUERY_FILE_HDFS,DNS_SRCIP_QUERY,TEST_DATA_SCHEMA_NAME,SRCIP,dnsSrcIPQueryElements,dnsSrcIPQueryFilterElements,filter,false,fs,hdfs);
  }
  List<String> dnsSrcIPQueryNoFilterElements=Arrays.asList(QNAME,DSTIP,IPS);
  TestUtils.createQuerySchema(DNS_SRCIP_QUERY_NO_FILTER_FILE,DNS_SRCIP_QUERY_NO_FILTER,TEST_DATA_SCHEMA_NAME,SRCIP,dnsSrcIPQueryNoFilterElements,null,null);
  if (hdfs) {
    TestUtils.createQuerySchema(DNS_SRCIP_QUERY_NO_FILTER_FILE_HDFS,DNS_SRCIP_QUERY_NO_FILTER,TEST_DATA_SCHEMA_NAME,SRCIP,dnsSrcIPQueryNoFilterElements,null,null,false,fs,hdfs);
  }
  QuerySchemaLoader.initialize();
}

public static void createSchemaFiles ( FileSystem fs , boolean hdfs , String filter ) throws Exception { if ( ! hdfs ) { createDataSchema ( false ) ; } else { createDataSchema ( fs , true ) ; } DataSchemaLoader . initialize ( ) ; List < String > dnsHostnameQueryElements = Arrays . asList ( DATE , SRCIP , DSTIP , QTYPE , RCODE , IPS ) ; List < String > dnsHostnameQueryFilterElements = Collections . singletonList ( QNAME ) ; TestUtils . createQuerySchema ( DNS_HOSTNAME_QUERY_FILE , DNS_HOSTNAME_QUERY , TEST_DATA_SCHEMA_NAME , QNAME , dnsHostnameQueryElements , dnsHostnameQueryFilterElements , filter ) ; if ( hdfs ) { TestUtils . createQuerySchema ( DNS_HOSTNAME_QUERY_FILE_HDFS , DNS_HOSTNAME_QUERY , TEST_DATA_SCHEMA_NAME , QNAME , dnsHostnameQueryElements , dnsHostnameQueryFilterElements , filter , false , fs , hdfs ) ; } List < String > dnsIPQueryElements = Arrays . asList ( SRCIP , DSTIP , IPS ) ; List < String > dnsIPQueryFilterElements = Collections . singletonList ( QNAME ) ; TestUtils . createQuerySchema ( DNS_IP_QUERY_FILE , DNS_IP_QUERY , TEST_DATA_SCHEMA_NAME , IPS , dnsIPQueryElements , dnsIPQueryFilterElements , filter ) ; if ( hdfs ) { TestUtils . createQuerySchema ( DNS_IP_QUERY_FILE_HDFS , DNS_IP_QUERY , TEST_DATA_SCHEMA_NAME , IPS , dnsIPQueryElements , dnsIPQueryFilterElements , filter , false , fs , hdfs ) ; } List < String > dnsNXQueryElements = Arrays . asList ( QNAME , SRCIP , DSTIP ) ; List < String > dnsNXQueryFilterElements = Collections . singletonList ( QNAME ) ; TestUtils . createQuerySchema ( DNS_NXDOMAIN_QUERY_FILE , DNS_NXDOMAIN_QUERY , TEST_DATA_SCHEMA_NAME , QNAME , dnsNXQueryElements , dnsNXQueryFilterElements , filter ) ; if ( hdfs ) { TestUtils . createQuerySchema ( DNS_NXDOMAIN_QUERY_FILE_HDFS , DNS_NXDOMAIN_QUERY , TEST_DATA_SCHEMA_NAME , QNAME , dnsNXQueryElements , dnsNXQueryFilterElements , filter , false , fs , hdfs ) ; } List < String > dnsSrcIPQueryElements = Arrays . asList ( QNAME , DSTIP , IPS ) ; List < String > dnsSrcIPQueryFilterElements = Arrays . asList ( SRCIP , IPS ) ; TestUtils . createQuerySchema ( DNS_SRCIP_QUERY_FILE , DNS_SRCIP_QUERY , TEST_DATA_SCHEMA_NAME , SRCIP , dnsSrcIPQueryElements , dnsSrcIPQueryFilterElements , filter ) ; if ( hdfs ) { TestUtils . createQuerySchema ( DNS_SRCIP_QUERY_FILE_HDFS , DNS_SRCIP_QUERY , TEST_DATA_SCHEMA_NAME , SRCIP , dnsSrcIPQueryElements , dnsSrcIPQueryFilterElements , filter , false , fs , hdfs ) ; } List < String > dnsSrcIPQueryNoFilterElements = Arrays . asList ( QNAME , DSTIP , IPS ) ; TestUtils . createQuerySchema ( DNS_SRCIP_QUERY_NO_FILTER_FILE , DNS_SRCIP_QUERY_NO_FILTER , TEST_DATA_SCHEMA_NAME , SRCIP , dnsSrcIPQueryNoFilterElements , null , null ) ; if ( hdfs ) { TestUtils . createQuerySchema ( DNS_SRCIP_QUERY_NO_FILTER_FILE_HDFS , DNS_SRCIP_QUERY_NO_FILTER , TEST_DATA_SCHEMA_NAME , SRCIP , dnsSrcIPQueryNoFilterElements , null , null , false , fs , hdfs ) ; } QuerySchemaLoader . initialize ( ) ; }
create and load the data and query schema files used for testing < p > writes both local and hdfs schema files if hdfs = true - - only updates the corresponding properties for the local files
