public void performQuery() throws IOException, PIRException {
  logger.info("Performing query: ");
  JavaDStream<MapWritable> inputRDD=null;
  if (dataInputFormat.equals(InputFormatConst.BASE_FORMAT)) {
    inputRDD=readData();
  }
 else   if (dataInputFormat.equals(InputFormatConst.ES)) {
    inputRDD=readDataES();
  }
 else {
    throw new PIRException("Unknown data input format " + dataInputFormat);
  }
  performQuery(inputRDD);
}

public void performQuery ( ) throws IOException , PIRException { logger . info ( "Performing query: " ) ; JavaDStream < MapWritable > inputRDD = null ; if ( dataInputFormat . equals ( InputFormatConst . BASE_FORMAT ) ) { inputRDD = readData ( ) ; } else if ( dataInputFormat . equals ( InputFormatConst . ES ) ) { inputRDD = readDataES ( ) ; } else { throw new PIRException ( "Unknown data input format " + dataInputFormat ) ; } performQuery ( inputRDD ) ; }
method to read in data from an allowed input source / format and perform the query
