Github user smarthi commented on a diff in the pull request:
https://github.com/apache/incubator-pirk/pull/69#discussion_r75327898
--- Diff:
src/main/java/org/apache/pirk/responder/wideskies/spark/ComputeResponse.java ---
@@ -316,23 +311,15 @@ public void performQuery() throws Exception
/**
* Method to perform the query given an input RDD of MapWritables
- *
+ *
*/
public void performQuery(JavaRDD<MapWritable> inputRDD) throws
PIRException
{
logger.info("Performing query: ");
- // If we are using distributed exp tables -- Create the expTable file
in hdfs for this query, if it doesn't exist
- if ((queryInfo.getUseHDFSExpLookupTable() || useHDFSLookupTable) &&
query.getExpFileBasedLookup().isEmpty())
- {
- // <queryHash, <<power>,<element^power mod N^2>>
- JavaPairRDD<Integer,Iterable<Tuple2<Integer,BigInteger>>>
expCalculations = ComputeExpLookupTable.computeExpTable(sc, fs, bVars, query,
queryInput,
--- End diff --
It seems 'Safely Unsafe', will revert this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
