Mailing-List: contact commits-help@pirk.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@pirk.incubator.apache.org
Date: Fri, 19 Aug 2016 19:35:20 +0000 (UTC)
From: "ASF GitHub Bot (JIRA)" <jira@apache.org>
To: commits@pirk.incubator.apache.org
Message-ID: <JIRA.12989650.1468548804000.357930.1471635320622@Atlassian.JIRA>
In-Reply-To: <JIRA.12989650.1468548804000@Atlassian.JIRA>
References: <JIRA.12989650.1468548804000@Atlassian.JIRA> <JIRA.12989650.1468548804176@arcas>
Subject: [jira] [Commented] (PIRK-4) Add Streaming Implementation for Apache
 Storm
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Fri, 19 Aug 2016 19:35:24 -0000


    [ https://issues.apache.org/jira/browse/PIRK-4?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428705#comment-15428705 ] 

ASF GitHub Bot commented on PIRK-4:
-----------------------------------

Github user clharris commented on a diff in the pull request:

    https://github.com/apache/incubator-pirk/pull/74#discussion_r75539766
  
    --- Diff: src/main/java/org/apache/pirk/responder/wideskies/common/ComputeEncryptedRow.java ---
    @@ -319,4 +314,80 @@ public static void loadCacheFromHDFS(FileSystem fs, String hdfsFileName, Query q
     
         return returnPairs;
       }
    +
    +  /**
    +   * Method to compute the encrypted row elements for a query from extracted data partitions in the form of ArrayList<<BigInteger>>
    +   * <p/>
    +   * For each row (as indicated by key = hash(selector)), iterates over the dataPartitions and calculates the column values.
    +   * <p/>
    +   * Uses a static LRU cache for the modular exponentiation
    +   * <p/>
    +   * Caller is responsible for keeping track of the colIndex and the the maxHitsPerSelector values
    +   * <p/>
    +   * Emits {@code Tuple2<<colNum, colVal>>}
    +   */
    +  public static ArrayList<Tuple2<Long,BigInteger>> computeEncRow(ArrayList<BigInteger> dataPartitions, Query query, int rowIndex, int colIndex)
    +      throws IOException
    +  {
    +    ArrayList<Tuple2<Long,BigInteger>> returnPairs = new ArrayList<Tuple2<Long,BigInteger>>();
    --- End diff --
    
    Will do.


> Add Streaming Implementation for Apache Storm
> ---------------------------------------------
>
>                 Key: PIRK-4
>                 URL: https://issues.apache.org/jira/browse/PIRK-4
>             Project: PIRK
>          Issue Type: Task
>          Components: Responder
>            Reporter: Chris Harris
>            Assignee: Chris Harris
>
> Per the Pirk Roadmap, this is a feature to add support for Apache Storm


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)