Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 876DA200B5F for ; Fri, 29 Jul 2016 21:43:08 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 86028160A6E; Fri, 29 Jul 2016 19:43:08 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 363F6160AAC for ; Fri, 29 Jul 2016 21:43:06 +0200 (CEST) Received: (qmail 44543 invoked by uid 500); 29 Jul 2016 19:43:05 -0000 Mailing-List: contact commits-help@pirk.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@pirk.incubator.apache.org Delivered-To: mailing list commits@pirk.incubator.apache.org Received: (qmail 44503 invoked by uid 99); 29 Jul 2016 19:43:05 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 29 Jul 2016 19:43:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id BDD3DC1105 for ; Fri, 29 Jul 2016 19:43:04 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -3.307 X-Spam-Level: X-Spam-Status: No, score=-3.307 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, KAM_MANYCOMMENTS=1.2, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-1.287] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id i5tW2JSFQ4rM for ; Fri, 29 Jul 2016 19:42:59 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id 5D77760D1F for ; Fri, 29 Jul 2016 19:42:48 +0000 (UTC) Received: (qmail 43969 invoked by uid 99); 29 Jul 2016 19:42:47 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 29 Jul 2016 19:42:47 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 0BE09EEB01; Fri, 29 Jul 2016 19:42:47 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: eawilliams@apache.org To: commits@pirk.incubator.apache.org Date: Fri, 29 Jul 2016 19:43:04 -0000 Message-Id: <0fbbbe6b74594820b18fb6bdcad7bd49@git.apache.org> In-Reply-To: <658b3cdafaa441319446e1b63269f49d@git.apache.org> References: <658b3cdafaa441319446e1b63269f49d@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [19/47] incubator-pirk git commit: updating website javadocs archived-at: Fri, 29 Jul 2016 19:43:08 -0000 http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/cb436a97/javadocs/test/org/apache/pirk/responder/wideskies/spark/EncRowCalc.html ---------------------------------------------------------------------- diff --git a/javadocs/test/org/apache/pirk/responder/wideskies/spark/EncRowCalc.html b/javadocs/test/org/apache/pirk/responder/wideskies/spark/EncRowCalc.html deleted file mode 100644 index ce58457..0000000 --- a/javadocs/test/org/apache/pirk/responder/wideskies/spark/EncRowCalc.html +++ /dev/null @@ -1,275 +0,0 @@ - - - - - -EncRowCalc - - - - - - - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - -
-
org.apache.pirk.responder.wideskies.spark
-

Class EncRowCalc

-
-
-
    -
  • java.lang.Object
    • -
  • -
      -
    • org.apache.pirk.responder.wideskies.spark.EncRowCalc
      • -
    -
    • -
-
-
    -
  • -
    -
    All Implemented Interfaces:
    -
    java.io.Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>>,java.lang.Long,java.math.BigInteger>
    -
    -
    -
    -
    public class EncRowCalc
-extends java.lang.Object
-implements org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>>,java.lang.Long,java.math.BigInteger>
    -
    Function to calculate the encrypted rows of the encrypted query -

    - For each row (as indicated by key = hash(selector)), iterates over each dataElement and calculates the column values. -

    - Emits <colNum, colVal>

    -
    See Also:
    Serialized Form
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Summary

      - - - - - - - - - - -
      Methods 
      Modifier and TypeMethod and Description
      java.lang.Iterable<scala.Tuple2<java.lang.Long,java.math.BigInteger>>call(scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>> hashDocTuple) 
      -
        -
      • - - -

        Methods inherited from class java.lang.Object

        -equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
        • -
      -
      • -
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Detail

      - - - -
        -
      • -

        call

        -
        public java.lang.Iterable<scala.Tuple2<java.lang.Long,java.math.BigInteger>> call(scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>> hashDocTuple)
-                                                                           throws java.lang.Exception
        -
        -
        Specified by:
        -
        call in interface org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>>,java.lang.Long,java.math.BigInteger>
        -
        Throws:
        -
        java.lang.Exception
        -
        • -
      -
      • -
    -
    • -
-
-
- - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - - http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/cb436a97/javadocs/test/org/apache/pirk/responder/wideskies/spark/EncRowCalcPrecomputedCache.html ---------------------------------------------------------------------- diff --git a/javadocs/test/org/apache/pirk/responder/wideskies/spark/EncRowCalcPrecomputedCache.html b/javadocs/test/org/apache/pirk/responder/wideskies/spark/EncRowCalcPrecomputedCache.html deleted file mode 100644 index 157786a..0000000 --- a/javadocs/test/org/apache/pirk/responder/wideskies/spark/EncRowCalcPrecomputedCache.html +++ /dev/null @@ -1,271 +0,0 @@ - - - - - -EncRowCalcPrecomputedCache - - - - - - - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - -
-
org.apache.pirk.responder.wideskies.spark
-

Class EncRowCalcPrecomputedCache

-
-
-
    -
  • java.lang.Object
    • -
  • -
      -
    • org.apache.pirk.responder.wideskies.spark.EncRowCalcPrecomputedCache
      • -
    -
    • -
-
-
    -
  • -
    -
    All Implemented Interfaces:
    -
    java.io.Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<java.lang.Integer,scala.Tuple2<java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>>>,java.lang.Long,java.math.BigInteger>
    -
    -
    -
    -
    public class EncRowCalcPrecomputedCache
-extends java.lang.Object
-implements org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<java.lang.Integer,scala.Tuple2<java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>>>,java.lang.Long,java.math.BigInteger>
    -
    Functionality for computing the encrypted rows using a pre-computed, passed in modular exponentiation lookup table
    -
    See Also:
    Serialized Form
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Summary

      - - - - - - - - - - -
      Methods 
      Modifier and TypeMethod and Description
      java.lang.Iterable<scala.Tuple2<java.lang.Long,java.math.BigInteger>>call(scala.Tuple2<java.lang.Integer,scala.Tuple2<java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>>> hashDocTuple) 
      -
        -
      • - - -

        Methods inherited from class java.lang.Object

        -equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
        • -
      -
      • -
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Detail

      - - - -
        -
      • -

        call

        -
        public java.lang.Iterable<scala.Tuple2<java.lang.Long,java.math.BigInteger>> call(scala.Tuple2<java.lang.Integer,scala.Tuple2<java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>>> hashDocTuple)
-                                                                           throws java.lang.Exception
        -
        -
        Specified by:
        -
        call in interface org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<java.lang.Integer,scala.Tuple2<java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>,java.lang.Iterable<java.util.ArrayList<java.math.BigInteger>>>>,java.lang.Long,java.math.BigInteger>
        -
        Throws:
        -
        java.lang.Exception
        -
        • -
      -
      • -
    -
    • -
-
-
- - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - - http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/cb436a97/javadocs/test/org/apache/pirk/responder/wideskies/spark/ExpKeyFilenameMap.html ---------------------------------------------------------------------- diff --git a/javadocs/test/org/apache/pirk/responder/wideskies/spark/ExpKeyFilenameMap.html b/javadocs/test/org/apache/pirk/responder/wideskies/spark/ExpKeyFilenameMap.html deleted file mode 100644 index 3a7483b..0000000 --- a/javadocs/test/org/apache/pirk/responder/wideskies/spark/ExpKeyFilenameMap.html +++ /dev/null @@ -1,269 +0,0 @@ - - - - - -ExpKeyFilenameMap - - - - - - - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - -
-
org.apache.pirk.responder.wideskies.spark
-

Class ExpKeyFilenameMap

-
-
-
    -
  • java.lang.Object
    • -
  • -
      -
    • org.apache.pirk.responder.wideskies.spark.ExpKeyFilenameMap
      • -
    -
    • -
-
-
    -
  • -
    -
    All Implemented Interfaces:
    -
    java.io.Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<java.util.Iterator<scala.Tuple2<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>>>,java.lang.Integer,java.lang.String>
    -
    -
    -
    -
    public class ExpKeyFilenameMap
-extends java.lang.Object
-implements org.apache.spark.api.java.function.PairFlatMapFunction<java.util.Iterator<scala.Tuple2<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>>>,java.lang.Integer,java.lang.String>
    -
    Class to map the query hash to its modular exponentiation lookup file in hdfs
    -
    See Also:
    Serialized Form
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Summary

      - - - - - - - - - - -
      Methods 
      Modifier and TypeMethod and Description
      java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.lang.String>>call(java.util.Iterator<scala.Tuple2<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>>> iter) 
      -
        -
      • - - -

        Methods inherited from class java.lang.Object

        -equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
        • -
      -
      • -
    -
    • -
-
-
-
    -
  • - -
      -
    • - - -

      Constructor Detail

      - - - -
        -
      • -

        ExpKeyFilenameMap

        -
        public ExpKeyFilenameMap(BroadcastVars bbVarsIn)
        -
        • -
      -
      • -
    - -
      -
    • - - -

      Method Detail

      - - - -
        -
      • -

        call

        -
        public java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.lang.String>> call(java.util.Iterator<scala.Tuple2<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>>> iter)
-                                                                          throws java.lang.Exception
        -
        -
        Specified by:
        -
        call in interface org.apache.spark.api.java.function.PairFlatMapFunction<java.util.Iterator<scala.Tuple2<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>>>,java.lang.Integer,java.lang.String>
        -
        Throws:
        -
        java.lang.Exception
        -
        • -
      -
      • -
    -
    • -
-
-
- - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - - http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/cb436a97/javadocs/test/org/apache/pirk/responder/wideskies/spark/ExpTableGenerator.html ---------------------------------------------------------------------- diff --git a/javadocs/test/org/apache/pirk/responder/wideskies/spark/ExpTableGenerator.html b/javadocs/test/org/apache/pirk/responder/wideskies/spark/ExpTableGenerator.html deleted file mode 100644 index 0c4872d..0000000 --- a/javadocs/test/org/apache/pirk/responder/wideskies/spark/ExpTableGenerator.html +++ /dev/null @@ -1,270 +0,0 @@ - - - - - -ExpTableGenerator - - - - - - - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - -
-
org.apache.pirk.responder.wideskies.spark
-

Class ExpTableGenerator

-
-
-
    -
  • java.lang.Object
    • -
  • -
      -
    • org.apache.pirk.responder.wideskies.spark.ExpTableGenerator
      • -
    -
    • -
-
-
    -
  • -
    -
    All Implemented Interfaces:
    -
    java.io.Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<java.lang.Integer,java.lang.Integer,scala.Tuple2<java.lang.Integer,java.math.BigInteger>>
    -
    -
    -
    -
    public class ExpTableGenerator
-extends java.lang.Object
-implements org.apache.spark.api.java.function.PairFlatMapFunction<java.lang.Integer,java.lang.Integer,scala.Tuple2<java.lang.Integer,java.math.BigInteger>>
    -
    Class to generate the query element modular exponentiations -

    -
    See Also:
    Serialized Form
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Summary

      - - - - - - - - - - -
      Methods 
      Modifier and TypeMethod and Description
      java.lang.Iterable<scala.Tuple2<java.lang.Integer,scala.Tuple2<java.lang.Integer,java.math.BigInteger>>>call(java.lang.Integer queryHashKey) 
      -
        -
      • - - -

        Methods inherited from class java.lang.Object

        -equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
        • -
      -
      • -
    -
    • -
-
-
-
    -
  • - -
      -
    • - - -

      Constructor Detail

      - - - -
        -
      • -

        ExpTableGenerator

        -
        public ExpTableGenerator(BroadcastVars bbVarsIn)
        -
        • -
      -
      • -
    - -
      -
    • - - -

      Method Detail

      - - - -
        -
      • -

        call

        -
        public java.lang.Iterable<scala.Tuple2<java.lang.Integer,scala.Tuple2<java.lang.Integer,java.math.BigInteger>>> call(java.lang.Integer queryHashKey)
-                                                                                                              throws java.lang.Exception
        -
        -
        Specified by:
        -
        call in interface org.apache.spark.api.java.function.PairFlatMapFunction<java.lang.Integer,java.lang.Integer,scala.Tuple2<java.lang.Integer,java.math.BigInteger>>
        -
        Throws:
        -
        java.lang.Exception
        -
        • -
      -
      • -
    -
    • -
-
-
- - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - - http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/cb436a97/javadocs/test/org/apache/pirk/responder/wideskies/spark/FilterData.html ---------------------------------------------------------------------- diff --git a/javadocs/test/org/apache/pirk/responder/wideskies/spark/FilterData.html b/javadocs/test/org/apache/pirk/responder/wideskies/spark/FilterData.html deleted file mode 100644 index b1ce90d..0000000 --- a/javadocs/test/org/apache/pirk/responder/wideskies/spark/FilterData.html +++ /dev/null @@ -1,274 +0,0 @@ - - - - - -FilterData - - - - - - - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - -
-
org.apache.pirk.responder.wideskies.spark
-

Class FilterData

-
-
-
    -
  • java.lang.Object
    • -
  • -
      -
    • org.apache.pirk.responder.wideskies.spark.FilterData
      • -
    -
    • -
-
-
    -
  • -
    -
    All Implemented Interfaces:
    -
    java.io.Serializable, org.apache.spark.api.java.function.Function<org.apache.hadoop.io.MapWritable,java.lang.Boolean>
    -
    -
    -
    -
    public class FilterData
-extends java.lang.Object
-implements org.apache.spark.api.java.function.Function<org.apache.hadoop.io.MapWritable,java.lang.Boolean>
    -
    Class to filter data as per the provided Filter (via the QuerySchema)
    -
    See Also:
    Serialized Form
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Summary

      - - - - - - - - - - -
      Methods 
      Modifier and TypeMethod and Description
      java.lang.Booleancall(org.apache.hadoop.io.MapWritable dataElement) 
      -
        -
      • - - -

        Methods inherited from class java.lang.Object

        -equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
        • -
      -
      • -
    -
    • -
-
-
-
    -
  • - -
      -
    • - - -

      Constructor Detail

      - - - -
        -
      • -

        FilterData

        -
        public FilterData(Accumulators accumIn,
-          BroadcastVars bbVarsIn)
-           throws java.lang.Exception
        -
        Throws:
        -
        java.lang.Exception
        -
        • -
      -
      • -
    - -
      -
    • - - -

      Method Detail

      - - - -
        -
      • -

        call

        -
        public java.lang.Boolean call(org.apache.hadoop.io.MapWritable dataElement)
-                       throws java.lang.Exception
        -
        -
        Specified by:
        -
        call in interface org.apache.spark.api.java.function.Function<org.apache.hadoop.io.MapWritable,java.lang.Boolean>
        -
        Throws:
        -
        java.lang.Exception
        -
        • -
      -
      • -
    -
    • -
-
-
- - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - - http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/cb436a97/javadocs/test/org/apache/pirk/responder/wideskies/spark/HashSelectorsAndPartitionData.html ---------------------------------------------------------------------- diff --git a/javadocs/test/org/apache/pirk/responder/wideskies/spark/HashSelectorsAndPartitionData.html b/javadocs/test/org/apache/pirk/responder/wideskies/spark/HashSelectorsAndPartitionData.html deleted file mode 100644 index 3a6e715..0000000 --- a/javadocs/test/org/apache/pirk/responder/wideskies/spark/HashSelectorsAndPartitionData.html +++ /dev/null @@ -1,272 +0,0 @@ - - - - - -HashSelectorsAndPartitionData - - - - - - - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - -
-
org.apache.pirk.responder.wideskies.spark
-

Class HashSelectorsAndPartitionData

-
-
-
    -
  • java.lang.Object
    • -
  • -
      -
    • org.apache.pirk.responder.wideskies.spark.HashSelectorsAndPartitionData
      • -
    -
    • -
-
-
    -
  • -
    -
    All Implemented Interfaces:
    -
    java.io.Serializable, org.apache.spark.api.java.function.PairFunction<org.apache.hadoop.io.MapWritable,java.lang.Integer,java.util.ArrayList<java.math.BigInteger>>
    -
    -
    -
    -
    public class HashSelectorsAndPartitionData
-extends java.lang.Object
-implements org.apache.spark.api.java.function.PairFunction<org.apache.hadoop.io.MapWritable,java.lang.Integer,java.util.ArrayList<java.math.BigInteger>>
    -
    Function to extract the selector by queryType from each dataElement, perform a keyed hash of the selector, extract the partitions of the dataElement, and - output <hash(selector), dataPartitions>
    -
    See Also:
    Serialized Form
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Summary

      - - - - - - - - - - -
      Methods 
      Modifier and TypeMethod and Description
      scala.Tuple2<java.lang.Integer,java.util.ArrayList<java.math.BigInteger>>call(org.apache.hadoop.io.MapWritable doc) 
      -
        -
      • - - -

        Methods inherited from class java.lang.Object

        -equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
        • -
      -
      • -
    -
    • -
-
-
-
    -
  • - - - -
      -
    • - - -

      Method Detail

      - - - -
        -
      • -

        call

        -
        public scala.Tuple2<java.lang.Integer,java.util.ArrayList<java.math.BigInteger>> call(org.apache.hadoop.io.MapWritable doc)
-                                                                               throws java.lang.Exception
        -
        -
        Specified by:
        -
        call in interface org.apache.spark.api.java.function.PairFunction<org.apache.hadoop.io.MapWritable,java.lang.Integer,java.util.ArrayList<java.math.BigInteger>>
        -
        Throws:
        -
        java.lang.Exception
        -
        • -
      -
      • -
    -
    • -
-
-
- - -
- - - - - -
-
- - - -
- -
-
-
    -
  • Summary: 
    • -
  • Nested | 
    • -
  • Field | 
    • -
  • Constr | 
    • -
  • Method
    • -
- -
- - -
- - - http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/cb436a97/javadocs/test/org/apache/pirk/responder/wideskies/spark/class-use/Accumulators.html ---------------------------------------------------------------------- diff --git a/javadocs/test/org/apache/pirk/responder/wideskies/spark/class-use/Accumulators.html b/javadocs/test/org/apache/pirk/responder/wideskies/spark/class-use/Accumulators.html deleted file mode 100644 index cc6fdce..0000000 --- a/javadocs/test/org/apache/pirk/responder/wideskies/spark/class-use/Accumulators.html +++ /dev/null @@ -1,166 +0,0 @@ - - - - - -Uses of Class org.apache.pirk.responder.wideskies.spark.Accumulators - - - - - - - -
- - - - - -
-
-
    -
  • Prev
    • -
  • Next
    • -
- - -
- -
- - -
- -
-

Uses of Class
org.apache.pirk.responder.wideskies.spark.Accumulators

-
-
- -
- -
- - - - - -
-
-
    -
  • Prev
    • -
  • Next
    • -
- - -
- -
- - -
- - -