question: 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 ) ; }
target:  Method to read in data from an allowed input source/format and perform the query