http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/PIRException.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/PIRException.html b/docs/org/apache/pirk/utils/PIRException.html index cdad624..db494f4 100644 --- a/docs/org/apache/pirk/utils/PIRException.html +++ b/docs/org/apache/pirk/utils/PIRException.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:44 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:32 EDT 2016 --> <title>PIRException</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/QueryParserUtils.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/QueryParserUtils.html b/docs/org/apache/pirk/utils/QueryParserUtils.html index ef3e459..d9714ee 100644 --- a/docs/org/apache/pirk/utils/QueryParserUtils.html +++ b/docs/org/apache/pirk/utils/QueryParserUtils.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:44 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:32 EDT 2016 --> <title>QueryParserUtils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/QueryResultsWriter.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/QueryResultsWriter.html b/docs/org/apache/pirk/utils/QueryResultsWriter.html index a137cab..f074d6c 100644 --- a/docs/org/apache/pirk/utils/QueryResultsWriter.html +++ b/docs/org/apache/pirk/utils/QueryResultsWriter.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:44 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:32 EDT 2016 --> <title>QueryResultsWriter</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/StopListUtils.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/StopListUtils.html b/docs/org/apache/pirk/utils/StopListUtils.html index 2288c4c..c914a26 100644 --- a/docs/org/apache/pirk/utils/StopListUtils.html +++ b/docs/org/apache/pirk/utils/StopListUtils.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:44 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:32 EDT 2016 --> <title>StopListUtils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/StringUtils.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/StringUtils.html b/docs/org/apache/pirk/utils/StringUtils.html index f2efb35..04e715a 100644 --- a/docs/org/apache/pirk/utils/StringUtils.html +++ b/docs/org/apache/pirk/utils/StringUtils.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:44 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:32 EDT 2016 --> <title>StringUtils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/SystemConfiguration.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/SystemConfiguration.html b/docs/org/apache/pirk/utils/SystemConfiguration.html index a0d2568..8fd91ba 100644 --- a/docs/org/apache/pirk/utils/SystemConfiguration.html +++ b/docs/org/apache/pirk/utils/SystemConfiguration.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:44 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:32 EDT 2016 --> <title>SystemConfiguration</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/CSVOutputUtils.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/CSVOutputUtils.html b/docs/org/apache/pirk/utils/class-use/CSVOutputUtils.html index 706f043..b1542e8 100644 --- a/docs/org/apache/pirk/utils/class-use/CSVOutputUtils.html +++ b/docs/org/apache/pirk/utils/class-use/CSVOutputUtils.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.CSVOutputUtils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/EpochDateParser.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/EpochDateParser.html b/docs/org/apache/pirk/utils/class-use/EpochDateParser.html index 3084976..77aa8e7 100644 --- a/docs/org/apache/pirk/utils/class-use/EpochDateParser.html +++ b/docs/org/apache/pirk/utils/class-use/EpochDateParser.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.EpochDateParser</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/FileConst.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/FileConst.html b/docs/org/apache/pirk/utils/class-use/FileConst.html index 8ab7f4a..4571c42 100644 --- a/docs/org/apache/pirk/utils/class-use/FileConst.html +++ b/docs/org/apache/pirk/utils/class-use/FileConst.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.FileConst</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/FileIOUtils.Callable.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/FileIOUtils.Callable.html b/docs/org/apache/pirk/utils/class-use/FileIOUtils.Callable.html index 0600e7b..beed893 100644 --- a/docs/org/apache/pirk/utils/class-use/FileIOUtils.Callable.html +++ b/docs/org/apache/pirk/utils/class-use/FileIOUtils.Callable.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Interface org.apache.pirk.utils.FileIOUtils.Callable</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/FileIOUtils.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/FileIOUtils.html b/docs/org/apache/pirk/utils/class-use/FileIOUtils.html index ed59883..dbe0322 100644 --- a/docs/org/apache/pirk/utils/class-use/FileIOUtils.html +++ b/docs/org/apache/pirk/utils/class-use/FileIOUtils.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.FileIOUtils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/HDFS.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/HDFS.html b/docs/org/apache/pirk/utils/class-use/HDFS.html index 92022ae..d96a21e 100644 --- a/docs/org/apache/pirk/utils/class-use/HDFS.html +++ b/docs/org/apache/pirk/utils/class-use/HDFS.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.HDFS</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/ISO8601DateParser.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/ISO8601DateParser.html b/docs/org/apache/pirk/utils/class-use/ISO8601DateParser.html index 47d2341..bc9c32a 100644 --- a/docs/org/apache/pirk/utils/class-use/ISO8601DateParser.html +++ b/docs/org/apache/pirk/utils/class-use/ISO8601DateParser.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.ISO8601DateParser</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/KeyedHash.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/KeyedHash.html b/docs/org/apache/pirk/utils/class-use/KeyedHash.html index b904b1a..cb49df3 100644 --- a/docs/org/apache/pirk/utils/class-use/KeyedHash.html +++ b/docs/org/apache/pirk/utils/class-use/KeyedHash.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.KeyedHash</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/PIRException.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/PIRException.html b/docs/org/apache/pirk/utils/class-use/PIRException.html index 70200cb..1d9f51b 100644 --- a/docs/org/apache/pirk/utils/class-use/PIRException.html +++ b/docs/org/apache/pirk/utils/class-use/PIRException.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.PIRException</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/QueryParserUtils.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/QueryParserUtils.html b/docs/org/apache/pirk/utils/class-use/QueryParserUtils.html index a78b8ae..196381e 100644 --- a/docs/org/apache/pirk/utils/class-use/QueryParserUtils.html +++ b/docs/org/apache/pirk/utils/class-use/QueryParserUtils.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.QueryParserUtils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/QueryResultsWriter.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/QueryResultsWriter.html b/docs/org/apache/pirk/utils/class-use/QueryResultsWriter.html index 7bb4795..1debbb4 100644 --- a/docs/org/apache/pirk/utils/class-use/QueryResultsWriter.html +++ b/docs/org/apache/pirk/utils/class-use/QueryResultsWriter.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.QueryResultsWriter</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/StopListUtils.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/StopListUtils.html b/docs/org/apache/pirk/utils/class-use/StopListUtils.html index 6bea1b0..ffdf2d7 100644 --- a/docs/org/apache/pirk/utils/class-use/StopListUtils.html +++ b/docs/org/apache/pirk/utils/class-use/StopListUtils.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.StopListUtils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/StringUtils.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/StringUtils.html b/docs/org/apache/pirk/utils/class-use/StringUtils.html index 82a1d7b..565748d 100644 --- a/docs/org/apache/pirk/utils/class-use/StringUtils.html +++ b/docs/org/apache/pirk/utils/class-use/StringUtils.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.StringUtils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/class-use/SystemConfiguration.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/class-use/SystemConfiguration.html b/docs/org/apache/pirk/utils/class-use/SystemConfiguration.html index a0575ca..402a6c5 100644 --- a/docs/org/apache/pirk/utils/class-use/SystemConfiguration.html +++ b/docs/org/apache/pirk/utils/class-use/SystemConfiguration.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.utils.SystemConfiguration</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/package-frame.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/package-frame.html b/docs/org/apache/pirk/utils/package-frame.html index 63c8c6c..a7c36ca 100644 --- a/docs/org/apache/pirk/utils/package-frame.html +++ b/docs/org/apache/pirk/utils/package-frame.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>org.apache.pirk.utils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/package-summary.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/package-summary.html b/docs/org/apache/pirk/utils/package-summary.html index a3458ea..ca98137 100644 --- a/docs/org/apache/pirk/utils/package-summary.html +++ b/docs/org/apache/pirk/utils/package-summary.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>org.apache.pirk.utils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/package-tree.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/package-tree.html b/docs/org/apache/pirk/utils/package-tree.html index f504ee6..7967d09 100644 --- a/docs/org/apache/pirk/utils/package-tree.html +++ b/docs/org/apache/pirk/utils/package-tree.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>org.apache.pirk.utils Class Hierarchy</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/utils/package-use.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/utils/package-use.html b/docs/org/apache/pirk/utils/package-use.html index 5011a15..b3e1e1c 100644 --- a/docs/org/apache/pirk/utils/package-use.html +++ b/docs/org/apache/pirk/utils/package-use.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:46 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Package org.apache.pirk.utils</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/wideskies/standalone/StandaloneTest.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/wideskies/standalone/StandaloneTest.html b/docs/org/apache/pirk/wideskies/standalone/StandaloneTest.html index b9b90ba..bc94400 100644 --- a/docs/org/apache/pirk/wideskies/standalone/StandaloneTest.html +++ b/docs/org/apache/pirk/wideskies/standalone/StandaloneTest.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>StandaloneTest</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/wideskies/standalone/class-use/StandaloneTest.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/wideskies/standalone/class-use/StandaloneTest.html b/docs/org/apache/pirk/wideskies/standalone/class-use/StandaloneTest.html index 6487b28..aafc920 100644 --- a/docs/org/apache/pirk/wideskies/standalone/class-use/StandaloneTest.html +++ b/docs/org/apache/pirk/wideskies/standalone/class-use/StandaloneTest.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:46 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Class org.apache.pirk.wideskies.standalone.StandaloneTest</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/wideskies/standalone/package-frame.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/wideskies/standalone/package-frame.html b/docs/org/apache/pirk/wideskies/standalone/package-frame.html index 9e77680..4b68b09 100644 --- a/docs/org/apache/pirk/wideskies/standalone/package-frame.html +++ b/docs/org/apache/pirk/wideskies/standalone/package-frame.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>org.apache.pirk.wideskies.standalone</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/wideskies/standalone/package-summary.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/wideskies/standalone/package-summary.html b/docs/org/apache/pirk/wideskies/standalone/package-summary.html index 5a7a279..ef7f7f3 100644 --- a/docs/org/apache/pirk/wideskies/standalone/package-summary.html +++ b/docs/org/apache/pirk/wideskies/standalone/package-summary.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>org.apache.pirk.wideskies.standalone</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/wideskies/standalone/package-tree.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/wideskies/standalone/package-tree.html b/docs/org/apache/pirk/wideskies/standalone/package-tree.html index 3569bfc..d092cb9 100644 --- a/docs/org/apache/pirk/wideskies/standalone/package-tree.html +++ b/docs/org/apache/pirk/wideskies/standalone/package-tree.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>org.apache.pirk.wideskies.standalone Class Hierarchy</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/org/apache/pirk/wideskies/standalone/package-use.html ---------------------------------------------------------------------- diff --git a/docs/org/apache/pirk/wideskies/standalone/package-use.html b/docs/org/apache/pirk/wideskies/standalone/package-use.html index 78c25bb..45770d3 100644 --- a/docs/org/apache/pirk/wideskies/standalone/package-use.html +++ b/docs/org/apache/pirk/wideskies/standalone/package-use.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:46 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Uses of Package org.apache.pirk.wideskies.standalone</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/overview-frame.html ---------------------------------------------------------------------- diff --git a/docs/overview-frame.html b/docs/overview-frame.html index c6d72ab..37f06ee 100644 --- a/docs/overview-frame.html +++ b/docs/overview-frame.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Overview List</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> @@ -27,6 +27,7 @@ <li><a href="org/apache/pirk/responder/wideskies/spark/package-frame.html" target="packageFrame">org.apache.pirk.responder.wideskies.spark</a></li> <li><a href="org/apache/pirk/responder/wideskies/spark/streaming/package-frame.html" target="packageFrame">org.apache.pirk.responder.wideskies.spark.streaming</a></li> <li><a href="org/apache/pirk/responder/wideskies/standalone/package-frame.html" target="packageFrame">org.apache.pirk.responder.wideskies.standalone</a></li> +<li><a href="org/apache/pirk/responder/wideskies/storm/package-frame.html" target="packageFrame">org.apache.pirk.responder.wideskies.storm</a></li> <li><a href="org/apache/pirk/response/wideskies/package-frame.html" target="packageFrame">org.apache.pirk.response.wideskies</a></li> <li><a href="org/apache/pirk/schema/data/package-frame.html" target="packageFrame">org.apache.pirk.schema.data</a></li> <li><a href="org/apache/pirk/schema/data/partitioner/package-frame.html" target="packageFrame">org.apache.pirk.schema.data.partitioner</a></li> @@ -34,6 +35,7 @@ <li><a href="org/apache/pirk/schema/query/filter/package-frame.html" target="packageFrame">org.apache.pirk.schema.query.filter</a></li> <li><a href="org/apache/pirk/schema/response/package-frame.html" target="packageFrame">org.apache.pirk.schema.response</a></li> <li><a href="org/apache/pirk/serialization/package-frame.html" target="packageFrame">org.apache.pirk.serialization</a></li> +<li><a href="org/apache/pirk/storm/package-frame.html" target="packageFrame">org.apache.pirk.storm</a></li> <li><a href="org/apache/pirk/test/distributed/package-frame.html" target="packageFrame">org.apache.pirk.test.distributed</a></li> <li><a href="org/apache/pirk/test/distributed/testsuite/package-frame.html" target="packageFrame">org.apache.pirk.test.distributed.testsuite</a></li> <li><a href="org/apache/pirk/test/utils/package-frame.html" target="packageFrame">org.apache.pirk.test.utils</a></li> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/overview-summary.html ---------------------------------------------------------------------- diff --git a/docs/overview-summary.html b/docs/overview-summary.html index f586f6e..d88976f 100644 --- a/docs/overview-summary.html +++ b/docs/overview-summary.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:46 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:34 EDT 2016 --> <title>Overview</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> @@ -131,33 +131,41 @@ <td class="colLast"> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><a href="org/apache/pirk/response/wideskies/package-summary.html">org.apache.pirk.response.wideskies</a></td> +<td class="colFirst"><a href="org/apache/pirk/responder/wideskies/storm/package-summary.html">org.apache.pirk.responder.wideskies.storm</a></td> <td class="colLast"> </td> </tr> <tr class="altColor"> -<td class="colFirst"><a href="org/apache/pirk/schema/data/package-summary.html">org.apache.pirk.schema.data</a></td> +<td class="colFirst"><a href="org/apache/pirk/response/wideskies/package-summary.html">org.apache.pirk.response.wideskies</a></td> <td class="colLast"> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><a href="org/apache/pirk/schema/data/partitioner/package-summary.html">org.apache.pirk.schema.data.partitioner</a></td> +<td class="colFirst"><a href="org/apache/pirk/schema/data/package-summary.html">org.apache.pirk.schema.data</a></td> <td class="colLast"> </td> </tr> <tr class="altColor"> -<td class="colFirst"><a href="org/apache/pirk/schema/query/package-summary.html">org.apache.pirk.schema.query</a></td> +<td class="colFirst"><a href="org/apache/pirk/schema/data/partitioner/package-summary.html">org.apache.pirk.schema.data.partitioner</a></td> <td class="colLast"> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><a href="org/apache/pirk/schema/query/filter/package-summary.html">org.apache.pirk.schema.query.filter</a></td> +<td class="colFirst"><a href="org/apache/pirk/schema/query/package-summary.html">org.apache.pirk.schema.query</a></td> <td class="colLast"> </td> </tr> <tr class="altColor"> -<td class="colFirst"><a href="org/apache/pirk/schema/response/package-summary.html">org.apache.pirk.schema.response</a></td> +<td class="colFirst"><a href="org/apache/pirk/schema/query/filter/package-summary.html">org.apache.pirk.schema.query.filter</a></td> <td class="colLast"> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><a href="org/apache/pirk/schema/response/package-summary.html">org.apache.pirk.schema.response</a></td> +<td class="colLast"> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/pirk/serialization/package-summary.html">org.apache.pirk.serialization</a></td> <td class="colLast"> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><a href="org/apache/pirk/storm/package-summary.html">org.apache.pirk.storm</a></td> +<td class="colLast"> </td> +</tr> <tr class="altColor"> <td class="colFirst"><a href="org/apache/pirk/test/distributed/package-summary.html">org.apache.pirk.test.distributed</a></td> <td class="colLast"> </td> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/overview-tree.html ---------------------------------------------------------------------- diff --git a/docs/overview-tree.html b/docs/overview-tree.html index 5894134..1e92bdc 100644 --- a/docs/overview-tree.html +++ b/docs/overview-tree.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:46 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Class Hierarchy</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> @@ -81,6 +81,7 @@ <li><a href="org/apache/pirk/responder/wideskies/spark/package-tree.html">org.apache.pirk.responder.wideskies.spark</a>, </li> <li><a href="org/apache/pirk/responder/wideskies/spark/streaming/package-tree.html">org.apache.pirk.responder.wideskies.spark.streaming</a>, </li> <li><a href="org/apache/pirk/responder/wideskies/standalone/package-tree.html">org.apache.pirk.responder.wideskies.standalone</a>, </li> +<li><a href="org/apache/pirk/responder/wideskies/storm/package-tree.html">org.apache.pirk.responder.wideskies.storm</a>, </li> <li><a href="org/apache/pirk/response/wideskies/package-tree.html">org.apache.pirk.response.wideskies</a>, </li> <li><a href="org/apache/pirk/schema/data/package-tree.html">org.apache.pirk.schema.data</a>, </li> <li><a href="org/apache/pirk/schema/data/partitioner/package-tree.html">org.apache.pirk.schema.data.partitioner</a>, </li> @@ -88,6 +89,7 @@ <li><a href="org/apache/pirk/schema/query/filter/package-tree.html">org.apache.pirk.schema.query.filter</a>, </li> <li><a href="org/apache/pirk/schema/response/package-tree.html">org.apache.pirk.schema.response</a>, </li> <li><a href="org/apache/pirk/serialization/package-tree.html">org.apache.pirk.serialization</a>, </li> +<li><a href="org/apache/pirk/storm/package-tree.html">org.apache.pirk.storm</a>, </li> <li><a href="org/apache/pirk/test/distributed/package-tree.html">org.apache.pirk.test.distributed</a>, </li> <li><a href="org/apache/pirk/test/distributed/testsuite/package-tree.html">org.apache.pirk.test.distributed.testsuite</a>, </li> <li><a href="org/apache/pirk/test/utils/package-tree.html">org.apache.pirk.test.utils</a>, </li> @@ -107,6 +109,22 @@ <li type="circle">org.apache.pirk.inputformat.hadoop.<a href="org/apache/pirk/inputformat/hadoop/TextArrayWritable.html" title="class in org.apache.pirk.inputformat.hadoop"><span class="strong">TextArrayWritable</span></a></li> </ul> </li> +<li type="circle">org.apache.storm.topology.base.BaseComponent (implements org.apache.storm.topology.IComponent) +<ul> +<li type="circle">org.apache.storm.topology.base.BaseBasicBolt (implements org.apache.storm.topology.IBasicBolt) +<ul> +<li type="circle">org.apache.pirk.responder.wideskies.storm.<a href="org/apache/pirk/responder/wideskies/storm/PartitionDataBolt.html" title="class in org.apache.pirk.responder.wideskies.storm"><span class="strong">PartitionDataBolt</span></a></li> +</ul> +</li> +<li type="circle">org.apache.storm.topology.base.BaseRichBolt (implements org.apache.storm.topology.IRichBolt) +<ul> +<li type="circle">org.apache.pirk.responder.wideskies.storm.<a href="org/apache/pirk/responder/wideskies/storm/EncColMultBolt.html" title="class in org.apache.pirk.responder.wideskies.storm"><span class="strong">EncColMultBolt</span></a></li> +<li type="circle">org.apache.pirk.responder.wideskies.storm.<a href="org/apache/pirk/responder/wideskies/storm/EncRowCalcBolt.html" title="class in org.apache.pirk.responder.wideskies.storm"><span class="strong">EncRowCalcBolt</span></a></li> +<li type="circle">org.apache.pirk.responder.wideskies.storm.<a href="org/apache/pirk/responder/wideskies/storm/OutputBolt.html" title="class in org.apache.pirk.responder.wideskies.storm"><span class="strong">OutputBolt</span></a></li> +</ul> +</li> +</ul> +</li> <li type="circle">org.apache.pirk.test.utils.<a href="org/apache/pirk/test/utils/BaseTests.html" title="class in org.apache.pirk.test.utils"><span class="strong">BaseTests</span></a></li> <li type="circle">org.apache.pirk.benchmark.<a href="org/apache/pirk/benchmark/BenchmarkDriver.html" title="class in org.apache.pirk.benchmark"><span class="strong">BenchmarkDriver</span></a></li> <li type="circle">org.apache.pirk.responder.wideskies.spark.<a href="org/apache/pirk/responder/wideskies/spark/BroadcastVars.html" title="class in org.apache.pirk.responder.wideskies.spark"><span class="strong">BroadcastVars</span></a> (implements java.io.Serializable)</li> @@ -164,6 +182,7 @@ <li type="circle">org.apache.pirk.utils.<a href="org/apache/pirk/utils/ISO8601DateParser.html" title="class in org.apache.pirk.utils"><span class="strong">ISO8601DateParser</span></a></li> <li type="circle">org.apache.pirk.general.<a href="org/apache/pirk/general/ISO8601DateParserTest.html" title="class in org.apache.pirk.general"><span class="strong">ISO8601DateParserTest</span></a></li> <li type="circle">org.apache.pirk.schema.data.partitioner.<a href="org/apache/pirk/schema/data/partitioner/ISO8601DatePartitioner.html" title="class in org.apache.pirk.schema.data.partitioner"><span class="strong">ISO8601DatePartitioner</span></a> (implements org.apache.pirk.schema.data.partitioner.<a href="org/apache/pirk/schema/data/partitioner/DataPartitioner.html" title="interface in org.apache.pirk.schema.data.partitioner">DataPartitioner</a>)</li> +<li type="circle">org.apache.pirk.storm.<a href="org/apache/pirk/storm/KafkaStormIntegrationTest.html" title="class in org.apache.pirk.storm"><span class="strong">KafkaStormIntegrationTest</span></a></li> <li type="circle">org.apache.pirk.utils.<a href="org/apache/pirk/utils/KeyedHash.html" title="class in org.apache.pirk.utils"><span class="strong">KeyedHash</span></a></li> <li type="circle">org.apache.pirk.general.<a href="org/apache/pirk/general/KeyedHashTest.html" title="class in org.apache.pirk.general"><span class="strong">KeyedHashTest</span></a></li> <li type="circle">org.apache.pirk.schema.data.<a href="org/apache/pirk/schema/data/LoadDataSchemaTest.html" title="class in org.apache.pirk.schema.data"><span class="strong">LoadDataSchemaTest</span></a></li> @@ -182,6 +201,7 @@ <li type="circle">org.apache.pirk.benchmark.<a href="org/apache/pirk/benchmark/PaillierBenchmark.PaillierBenchmarkState.html" title="class in org.apache.pirk.benchmark"><span class="strong">PaillierBenchmark.PaillierBenchmarkState</span></a></li> <li type="circle">org.apache.pirk.general.<a href="org/apache/pirk/general/PaillierTest.html" title="class in org.apache.pirk.general"><span class="strong">PaillierTest</span></a></li> <li type="circle">org.apache.pirk.general.<a href="org/apache/pirk/general/PartitionUtilsTest.html" title="class in org.apache.pirk.general"><span class="strong">PartitionUtilsTest</span></a></li> +<li type="circle">org.apache.pirk.responder.wideskies.storm.<a href="org/apache/pirk/responder/wideskies/storm/PirkTopology.html" title="class in org.apache.pirk.responder.wideskies.storm"><span class="strong">PirkTopology</span></a></li> <li type="circle">org.apache.pirk.encryption.<a href="org/apache/pirk/encryption/PrimeGenerator.html" title="class in org.apache.pirk.encryption"><span class="strong">PrimeGenerator</span></a></li> <li type="circle">org.apache.pirk.schema.data.partitioner.<a href="org/apache/pirk/schema/data/partitioner/PrimitiveTypePartitioner.html" title="class in org.apache.pirk.schema.data.partitioner"><span class="strong">PrimitiveTypePartitioner</span></a> (implements org.apache.pirk.schema.data.partitioner.<a href="org/apache/pirk/schema/data/partitioner/DataPartitioner.html" title="interface in org.apache.pirk.schema.data.partitioner">DataPartitioner</a>)</li> <li type="circle">org.apache.pirk.querier.wideskies.<a href="org/apache/pirk/querier/wideskies/Querier.html" title="class in org.apache.pirk.querier.wideskies"><span class="strong">Querier</span></a> (implements java.io.Serializable, org.apache.pirk.serialization.<a href="org/apache/pirk/serialization/Storable.html" title="interface in org.apache.pirk.serialization">Storable</a>)</li> @@ -228,8 +248,16 @@ <li type="circle">org.apache.pirk.wideskies.standalone.<a href="org/apache/pirk/wideskies/standalone/StandaloneTest.html" title="class in org.apache.pirk.wideskies.standalone"><span class="strong">StandaloneTest</span></a></li> <li type="circle">org.apache.pirk.schema.query.filter.<a href="org/apache/pirk/schema/query/filter/StopListFilter.html" title="class in org.apache.pirk.schema.query.filter"><span class="strong">StopListFilter</span></a> (implements org.apache.pirk.schema.query.filter.<a href="org/apache/pirk/schema/query/filter/DataFilter.html" title="interface in org.apache.pirk.schema.query.filter">DataFilter</a>)</li> <li type="circle">org.apache.pirk.utils.<a href="org/apache/pirk/utils/StopListUtils.html" title="class in org.apache.pirk.utils"><span class="strong">StopListUtils</span></a></li> +<li type="circle">org.apache.pirk.responder.wideskies.storm.<a href="org/apache/pirk/responder/wideskies/storm/StormConstants.html" title="class in org.apache.pirk.responder.wideskies.storm"><span class="strong">StormConstants</span></a></li> +<li type="circle">org.apache.pirk.responder.wideskies.storm.<a href="org/apache/pirk/responder/wideskies/storm/StormUtils.html" title="class in org.apache.pirk.responder.wideskies.storm"><span class="strong">StormUtils</span></a></li> +<li type="circle">org.apache.storm.kafka.StringScheme (implements org.apache.storm.spout.Scheme) +<ul> +<li type="circle">org.apache.pirk.responder.wideskies.storm.<a href="org/apache/pirk/responder/wideskies/storm/PirkHashScheme.html" title="class in org.apache.pirk.responder.wideskies.storm"><span class="strong">PirkHashScheme</span></a> (implements org.apache.storm.spout.Scheme)</li> +</ul> +</li> <li type="circle">org.apache.pirk.utils.<a href="org/apache/pirk/utils/StringUtils.html" title="class in org.apache.pirk.utils"><span class="strong">StringUtils</span></a></li> <li type="circle">org.apache.pirk.utils.<a href="org/apache/pirk/utils/SystemConfiguration.html" title="class in org.apache.pirk.utils"><span class="strong">SystemConfiguration</span></a></li> +<li type="circle">org.apache.pirk.storm.<a href="org/apache/pirk/storm/SystemTime.html" title="class in org.apache.pirk.storm"><span class="strong">SystemTime</span></a> (implements kafka.utils.Time)</li> <li type="circle">org.apache.pirk.test.utils.<a href="org/apache/pirk/test/utils/TestUtils.html" title="class in org.apache.pirk.test.utils"><span class="strong">TestUtils</span></a></li> <li type="circle">java.lang.Throwable (implements java.io.Serializable) <ul> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/package-list ---------------------------------------------------------------------- diff --git a/docs/package-list b/docs/package-list index d803e59..92eb193 100644 --- a/docs/package-list +++ b/docs/package-list @@ -13,6 +13,7 @@ org.apache.pirk.responder.wideskies.mapreduce org.apache.pirk.responder.wideskies.spark org.apache.pirk.responder.wideskies.spark.streaming org.apache.pirk.responder.wideskies.standalone +org.apache.pirk.responder.wideskies.storm org.apache.pirk.response.wideskies org.apache.pirk.schema.data org.apache.pirk.schema.data.partitioner @@ -20,6 +21,7 @@ org.apache.pirk.schema.query org.apache.pirk.schema.query.filter org.apache.pirk.schema.response org.apache.pirk.serialization +org.apache.pirk.storm org.apache.pirk.test.distributed org.apache.pirk.test.distributed.testsuite org.apache.pirk.test.utils http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/docs/serialized-form.html ---------------------------------------------------------------------- diff --git a/docs/serialized-form.html b/docs/serialized-form.html index 6620279..37ff7e7 100644 --- a/docs/serialized-form.html +++ b/docs/serialized-form.html @@ -2,7 +2,7 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:50:45 EDT 2016 --> +<!-- Generated by javadoc (version 1.7.0_80) on Tue Aug 30 09:57:33 EDT 2016 --> <title>Serialized Form</title> <meta name="date" content="2016-08-30"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> @@ -652,6 +652,289 @@ </ul> </li> <li class="blockList"> +<h2 title="Package">Package org.apache.pirk.responder.wideskies.storm</h2> +<ul class="blockList"> +<li class="blockList"><a name="org.apache.pirk.responder.wideskies.storm.EncColMultBolt"> +<!-- --> +</a> +<h3>Class <a href="org/apache/pirk/responder/wideskies/storm/EncColMultBolt.html" title="class in org.apache.pirk.responder.wideskies.storm">org.apache.pirk.responder.wideskies.storm.EncColMultBolt</a> extends org.apache.storm.topology.base.BaseRichBolt implements Serializable</h3> +<dl class="nameValue"> +<dt>serialVersionUID:</dt> +<dd>1L</dd> +</dl> +<ul class="blockList"> +<li class="blockList"><a name="serializedForm"> +<!-- --> +</a> +<h3>Serialized Fields</h3> +<ul class="blockList"> +<li class="blockList"> +<h4>outputCollector</h4> +<pre>org.apache.storm.task.OutputCollector outputCollector</pre> +</li> +<li class="blockList"> +<h4>nSquared</h4> +<pre>java.math.BigInteger nSquared</pre> +</li> +<li class="blockList"> +<h4>numFlushSignals</h4> +<pre>long numFlushSignals</pre> +</li> +<li class="blockList"> +<h4>totalFlushSignals</h4> +<pre>java.lang.Long totalFlushSignals</pre> +</li> +<li class="blockList"> +<h4>resultsMap</h4> +<pre>java.util.Map<K,V> resultsMap</pre> +</li> +<li class="blockList"> +<h4>colVal1</h4> +<pre>java.math.BigInteger colVal1</pre> +</li> +<li class="blockListLast"> +<h4>colMult</h4> +<pre>java.math.BigInteger colMult</pre> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.pirk.responder.wideskies.storm.EncRowCalcBolt"> +<!-- --> +</a> +<h3>Class <a href="org/apache/pirk/responder/wideskies/storm/EncRowCalcBolt.html" title="class in org.apache.pirk.responder.wideskies.storm">org.apache.pirk.responder.wideskies.storm.EncRowCalcBolt</a> extends org.apache.storm.topology.base.BaseRichBolt implements Serializable</h3> +<dl class="nameValue"> +<dt>serialVersionUID:</dt> +<dd>1L</dd> +</dl> +<ul class="blockList"> +<li class="blockList"><a name="serializedForm"> +<!-- --> +</a> +<h3>Serialized Fields</h3> +<ul class="blockList"> +<li class="blockList"> +<h4>outputCollector</h4> +<pre>org.apache.storm.task.OutputCollector outputCollector</pre> +</li> +<li class="blockList"> +<h4>limitHitsPerSelector</h4> +<pre>java.lang.Boolean limitHitsPerSelector</pre> +</li> +<li class="blockList"> +<h4>maxHitsPerSelector</h4> +<pre>java.lang.Long maxHitsPerSelector</pre> +</li> +<li class="blockList"> +<h4>totalEndSigs</h4> +<pre>java.lang.Long totalEndSigs</pre> +</li> +<li class="blockList"> +<h4>rowDivisions</h4> +<pre>int rowDivisions</pre> +</li> +<li class="blockList"> +<h4>saltColumns</h4> +<pre>java.lang.Boolean saltColumns</pre> +</li> +<li class="blockList"> +<h4>splitPartitions</h4> +<pre>java.lang.Boolean splitPartitions</pre> +</li> +<li class="blockList"> +<h4>rand</h4> +<pre>java.util.Random rand</pre> +</li> +<li class="blockList"> +<h4>hitsByRow</h4> +<pre>java.util.Map<K,V> hitsByRow</pre> +</li> +<li class="blockList"> +<h4>colIndexByRow</h4> +<pre>java.util.Map<K,V> colIndexByRow</pre> +</li> +<li class="blockList"> +<h4>matrixElements</h4> +<pre>java.util.List<E> matrixElements</pre> +</li> +<li class="blockList"> +<h4>dataArray</h4> +<pre>java.util.List<E> dataArray</pre> +</li> +<li class="blockList"> +<h4>numEndSigs</h4> +<pre>int numEndSigs</pre> +</li> +<li class="blockList"> +<h4>buffering</h4> +<pre>boolean buffering</pre> +</li> +<li class="blockListLast"> +<h4>bufferedValues</h4> +<pre>java.util.List<E> bufferedValues</pre> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.pirk.responder.wideskies.storm.OutputBolt"> +<!-- --> +</a> +<h3>Class <a href="org/apache/pirk/responder/wideskies/storm/OutputBolt.html" title="class in org.apache.pirk.responder.wideskies.storm">org.apache.pirk.responder.wideskies.storm.OutputBolt</a> extends org.apache.storm.topology.base.BaseRichBolt implements Serializable</h3> +<dl class="nameValue"> +<dt>serialVersionUID:</dt> +<dd>1L</dd> +</dl> +<ul class="blockList"> +<li class="blockList"><a name="serializedForm"> +<!-- --> +</a> +<h3>Serialized Fields</h3> +<ul class="blockList"> +<li class="blockList"> +<h4>outputCollector</h4> +<pre>org.apache.storm.task.OutputCollector outputCollector</pre> +</li> +<li class="blockList"> +<h4>queryInfo</h4> +<pre><a href="org/apache/pirk/query/wideskies/QueryInfo.html" title="class in org.apache.pirk.query.wideskies">QueryInfo</a> queryInfo</pre> +</li> +<li class="blockList"> +<h4>response</h4> +<pre><a href="org/apache/pirk/response/wideskies/Response.html" title="class in org.apache.pirk.response.wideskies">Response</a> response</pre> +</li> +<li class="blockList"> +<h4>outputFile</h4> +<pre>java.lang.String outputFile</pre> +</li> +<li class="blockList"> +<h4>hdfs</h4> +<pre>boolean hdfs</pre> +</li> +<li class="blockList"> +<h4>hdfsUri</h4> +<pre>java.lang.String hdfsUri</pre> +</li> +<li class="blockList"> +<h4>flushCounter</h4> +<pre>java.lang.Integer flushCounter</pre> +</li> +<li class="blockList"> +<h4>tuplesToAck</h4> +<pre>java.util.List<E> tuplesToAck</pre> +</li> +<li class="blockList"> +<h4>totalFlushSigs</h4> +<pre>java.lang.Integer totalFlushSigs</pre> +</li> +<li class="blockList"> +<h4>localStore</h4> +<pre><a href="org/apache/pirk/serialization/LocalFileSystemStore.html" title="class in org.apache.pirk.serialization">LocalFileSystemStore</a> localStore</pre> +</li> +<li class="blockList"> +<h4>hadoopStore</h4> +<pre><a href="org/apache/pirk/serialization/HadoopFileSystemStore.html" title="class in org.apache.pirk.serialization">HadoopFileSystemStore</a> hadoopStore</pre> +</li> +<li class="blockList"> +<h4>resultsMap</h4> +<pre>java.util.Map<K,V> resultsMap</pre> +</li> +<li class="blockList"> +<h4>colVal</h4> +<pre>java.math.BigInteger colVal</pre> +</li> +<li class="blockList"> +<h4>colMult</h4> +<pre>java.math.BigInteger colMult</pre> +</li> +<li class="blockListLast"> +<h4>nSquared</h4> +<pre>java.math.BigInteger nSquared</pre> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.pirk.responder.wideskies.storm.PartitionDataBolt"> +<!-- --> +</a> +<h3>Class <a href="org/apache/pirk/responder/wideskies/storm/PartitionDataBolt.html" title="class in org.apache.pirk.responder.wideskies.storm">org.apache.pirk.responder.wideskies.storm.PartitionDataBolt</a> extends org.apache.storm.topology.base.BaseBasicBolt implements Serializable</h3> +<dl class="nameValue"> +<dt>serialVersionUID:</dt> +<dd>1L</dd> +</dl> +<ul class="blockList"> +<li class="blockList"><a name="serializedForm"> +<!-- --> +</a> +<h3>Serialized Fields</h3> +<ul class="blockList"> +<li class="blockList"> +<h4>queryInfo</h4> +<pre><a href="org/apache/pirk/query/wideskies/QueryInfo.html" title="class in org.apache.pirk.query.wideskies">QueryInfo</a> queryInfo</pre> +</li> +<li class="blockList"> +<h4>queryType</h4> +<pre>java.lang.String queryType</pre> +</li> +<li class="blockList"> +<h4>qSchema</h4> +<pre><a href="org/apache/pirk/schema/query/QuerySchema.html" title="class in org.apache.pirk.schema.query">QuerySchema</a> qSchema</pre> +</li> +<li class="blockList"> +<h4>embedSelector</h4> +<pre>boolean embedSelector</pre> +</li> +<li class="blockList"> +<h4>splitPartitions</h4> +<pre>boolean splitPartitions</pre> +</li> +<li class="blockList"> +<h4>json</h4> +<pre>org.json.simple.JSONObject json</pre> +</li> +<li class="blockListLast"> +<h4>partitions</h4> +<pre>java.util.List<E> partitions</pre> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.pirk.responder.wideskies.storm.PirkHashScheme"> +<!-- --> +</a> +<h3>Class <a href="org/apache/pirk/responder/wideskies/storm/PirkHashScheme.html" title="class in org.apache.pirk.responder.wideskies.storm">org.apache.pirk.responder.wideskies.storm.PirkHashScheme</a> extends org.apache.storm.kafka.StringScheme implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"><a name="serializedForm"> +<!-- --> +</a> +<h3>Serialized Fields</h3> +<ul class="blockList"> +<li class="blockList"> +<h4>queryInfo</h4> +<pre><a href="org/apache/pirk/query/wideskies/QueryInfo.html" title="class in org.apache.pirk.query.wideskies">QueryInfo</a> queryInfo</pre> +</li> +<li class="blockList"> +<h4>initialized</h4> +<pre>boolean initialized</pre> +</li> +<li class="blockList"> +<h4>qSchema</h4> +<pre><a href="org/apache/pirk/schema/query/QuerySchema.html" title="class in org.apache.pirk.schema.query">QuerySchema</a> qSchema</pre> +</li> +<li class="blockListLast"> +<h4>conf</h4> +<pre>org.apache.storm.Config conf</pre> +</li> +</ul> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"> <h2 title="Package">Package org.apache.pirk.response.wideskies</h2> <ul class="blockList"> <li class="blockList"><a name="org.apache.pirk.response.wideskies.Response"> http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/querier/wideskies/decrypt/DecryptResponse.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/querier/wideskies/decrypt/DecryptResponse.java b/src/main/java/org/apache/pirk/querier/wideskies/decrypt/DecryptResponse.java index eae288f..dfa61ac 100644 --- a/src/main/java/org/apache/pirk/querier/wideskies/decrypt/DecryptResponse.java +++ b/src/main/java/org/apache/pirk/querier/wideskies/decrypt/DecryptResponse.java @@ -89,7 +89,7 @@ public class DecryptResponse public Map<String,List<QueryResponseJSON>> decrypt(int numThreads) throws InterruptedException, PIRException { Map<String,List<QueryResponseJSON>> resultMap = new HashMap<>(); // selector -> ArrayList of hits - + QueryInfo queryInfo = response.getQueryInfo(); Paillier paillier = querier.getPaillier(); @@ -161,10 +161,10 @@ public class DecryptResponse } es.shutdown(); - + return resultMap; } - + // Method to perform basic decryption of each raw response element - does not // extract and reconstruct the data elements private List<BigInteger> decryptElements(TreeMap<Integer,BigInteger> elements, Paillier paillier) http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java b/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java index f5d24d7..55846fd 100644 --- a/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java +++ b/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java @@ -108,15 +108,15 @@ public class ResponderProps static final String STORMSALTCOLUMNS = "storm.saltColumns"; static final String STORMNUMROWDIVS = "storm.rowDivs"; - static final String[] STORMPROPS = new String[]{HDFSURI, USEHDFS, KAFKATOPIC, KAFKACLIENTID, KAFKAZK, KAFKAFORCEFROMSTART, STORMTOPONAME, STORMWORKERS, + static final String[] STORMPROPS = new String[] {HDFSURI, USEHDFS, KAFKATOPIC, KAFKACLIENTID, KAFKAZK, KAFKAFORCEFROMSTART, STORMTOPONAME, STORMWORKERS, STORMNUMACKERS, STORMRECEIVEBUFFERS, STORMSENDBUFFERS, STORMTRANSFERBUFFERS, STORMMAXSPOUTPENDING, STORMHEAPMEMORY, STORMCHILDOPTS, STORMMAXWORKERHEAP, - STORMCOMPONENTONHEAP, STORMSPOUTPAR, STORMPARTITIONDATABOLTPAR, STORMENCROWCALCBOLTPAR, STORMENCCOLMULTBOLTPAR, STORMFLUSHFREQUENCY, STORMSPLITPARTITIONS, - STORMSALTCOLUMNS, STORMNUMROWDIVS}; + STORMCOMPONENTONHEAP, STORMSPOUTPAR, STORMPARTITIONDATABOLTPAR, STORMENCROWCALCBOLTPAR, STORMENCCOLMULTBOLTPAR, STORMFLUSHFREQUENCY, + STORMSPLITPARTITIONS, STORMSALTCOLUMNS, STORMNUMROWDIVS}; - static final List<String> PROPSLIST = Arrays.asList((String[]) ArrayUtils.addAll(new String[]{PLATFORM, QUERYINPUT, DATAINPUTFORMAT, INPUTDATA, BASEQUERY, ESRESOURCE, ESQUERY, OUTPUTFILE, - BASEINPUTFORMAT, STOPLISTFILE, NUMREDUCETASKS, USELOCALCACHE, LIMITHITSPERSELECTOR, MAXHITSPERSELECTOR, MAPMEMORY, REDUCEMEMORY, MAPJAVAOPTS, - REDUCEJAVAOPTS, QUERYSCHEMAS, DATASCHEMAS, NUMEXPLOOKUPPARTS, USEHDFSLOOKUPTABLE, NUMDATAPARTITIONS, NUMCOLMULTPARTITIONS, USEMODEXPJOIN, - COLMULTREDUCEBYKEY, ALLOWEMBEDDEDQUERYSCHEMAS, BATCHSECONDS, WINDOWLENGTH, USEQUEUESTREAM, MAXBATCHES, STOPGRACEFULLY}, STORMPROPS)); + static final List<String> PROPSLIST = Arrays.asList((String[]) ArrayUtils.addAll(new String[] {PLATFORM, QUERYINPUT, DATAINPUTFORMAT, INPUTDATA, BASEQUERY, + ESRESOURCE, ESQUERY, OUTPUTFILE, BASEINPUTFORMAT, STOPLISTFILE, NUMREDUCETASKS, USELOCALCACHE, LIMITHITSPERSELECTOR, MAXHITSPERSELECTOR, MAPMEMORY, + REDUCEMEMORY, MAPJAVAOPTS, REDUCEJAVAOPTS, QUERYSCHEMAS, DATASCHEMAS, NUMEXPLOOKUPPARTS, USEHDFSLOOKUPTABLE, NUMDATAPARTITIONS, NUMCOLMULTPARTITIONS, + USEMODEXPJOIN, COLMULTREDUCEBYKEY, ALLOWEMBEDDEDQUERYSCHEMAS, BATCHSECONDS, WINDOWLENGTH, USEQUEUESTREAM, MAXBATCHES, STOPGRACEFULLY}, STORMPROPS)); /** * Validates the responder properties @@ -135,7 +135,8 @@ public class ResponderProps } String platform = SystemConfiguration.getProperty(PLATFORM).toLowerCase(); - if (!platform.equals("mapreduce") && !platform.equals("spark") && !platform.equals("sparkstreaming") && !platform.equals("storm") && !platform.equals("standalone")) + if (!platform.equals("mapreduce") && !platform.equals("spark") && !platform.equals("sparkstreaming") && !platform.equals("storm") + && !platform.equals("standalone")) { logger.info("Unsupported platform: " + platform); valid = false; http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/responder/wideskies/common/ComputeEncryptedRow.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/responder/wideskies/common/ComputeEncryptedRow.java b/src/main/java/org/apache/pirk/responder/wideskies/common/ComputeEncryptedRow.java index 0050e29..0065094 100644 --- a/src/main/java/org/apache/pirk/responder/wideskies/common/ComputeEncryptedRow.java +++ b/src/main/java/org/apache/pirk/responder/wideskies/common/ComputeEncryptedRow.java @@ -140,8 +140,8 @@ public class ComputeEncryptedRow { e.printStackTrace(); } - logger.debug("rowIndex = {} colCounter = {} part = {} part binary = {} exp = {} i = {} partition = {} = {}", - rowIndex, colCounter, part.toString(), part.toString(2), exp, i, dataPartitions.getBigInteger(i), dataPartitions.getBigInteger(i).toString(2)); + logger.debug("rowIndex = {} colCounter = {} part = {} part binary = {} exp = {} i = {} partition = {} = {}", rowIndex, colCounter, part.toString(), + part.toString(2), exp, i, dataPartitions.getBigInteger(i), dataPartitions.getBigInteger(i).toString(2)); returnPairs.add(new Tuple2<>(colCounter, exp)); @@ -206,8 +206,8 @@ public class ComputeEncryptedRow e.printStackTrace(); } - logger.debug("rowIndex = {} colCounter = {} part = {} part binary = {} exp = {} i = {}", - rowIndex, colCounter, part.toString(), part.toString(2), exp, i); + logger.debug("rowIndex = {} colCounter = {} part = {} part binary = {} exp = {} i = {}", rowIndex, colCounter, part.toString(), part.toString(2), exp, + i); returnPairs.add(new Tuple2<>(colCounter, exp)); @@ -306,8 +306,8 @@ public class ComputeEncryptedRow e.printStackTrace(); } - logger.debug("rowIndex = {} colCounter = {} part = {} part binary = {} exp = {} i = {} partition = {} = {}", - rowIndex, colCounter, part.toString(), part.toString(2), exp, i, dataPartitions.getBigInteger(i), dataPartitions.getBigInteger(i).toString(2)); + logger.debug("rowIndex = {} colCounter = {} part = {} part binary = {} exp = {} i = {} partition = {} = {}", rowIndex, colCounter, part.toString(), + part.toString(2), exp, i, dataPartitions.getBigInteger(i), dataPartitions.getBigInteger(i).toString(2)); returnPairs.add(new Tuple2<>(colCounter, exp)); @@ -328,8 +328,7 @@ public class ComputeEncryptedRow * <p> * Emits {@code Tuple2<<colNum, colVal>>} */ - public static List<Tuple2<Long,BigInteger>> computeEncRow(List<BigInteger> dataPartitions, Query query, int rowIndex, int colIndex) - throws IOException + public static List<Tuple2<Long,BigInteger>> computeEncRow(List<BigInteger> dataPartitions, Query query, int rowIndex, int colIndex) throws IOException { List<Tuple2<Long,BigInteger>> returnPairs = new ArrayList<>(); @@ -356,8 +355,8 @@ public class ComputeEncryptedRow break; } - logger.debug("rowIndex = {} colCounter = {} part = {} part binary = {} exp = {} i = {} partition = {} = {}", - rowIndex, colCounter, part.toString(), part.toString(2), exp, i, dataPartitions.get(i), dataPartitions.get(i).toString(2)); + logger.debug("rowIndex = {} colCounter = {} part = {} part binary = {} exp = {} i = {} partition = {} = {}", rowIndex, colCounter, part.toString(), + part.toString(2), exp, i, dataPartitions.get(i), dataPartitions.get(i).toString(2)); returnPairs.add(new Tuple2<Long,BigInteger>(colCounter, exp)); http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/responder/wideskies/storm/EncColMultBolt.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/responder/wideskies/storm/EncColMultBolt.java b/src/main/java/org/apache/pirk/responder/wideskies/storm/EncColMultBolt.java index 08c9917..8831e4e 100644 --- a/src/main/java/org/apache/pirk/responder/wideskies/storm/EncColMultBolt.java +++ b/src/main/java/org/apache/pirk/responder/wideskies/storm/EncColMultBolt.java @@ -40,8 +40,8 @@ import java.util.Map; * EncRowCalcBolts send flush signals to the EncColMultBolts indicating that they have finished sending all tuples for a session. Whenever a flush signal is * received from a EncRowCalcBolt, the num of received flush signals is tallied until each EncRowCalcBolt has emitted a flush signal. * <p> - * Once a flush signal has been received from each EncRowCalcBolt, all {@code <columnIndex, aggregate colVal product>} tuples are sent to the OutputBolt and a session_end - * signal is sent back to each EncRowMultBolt. + * Once a flush signal has been received from each EncRowCalcBolt, all {@code <columnIndex, aggregate colVal product>} tuples are sent to the OutputBolt and a + * session_end signal is sent back to each EncRowMultBolt. * <p> * The EncRowMultBolts buffer their output from the time that they send a flush signal to the EncColMultBolts until the time that they receive a session_end * signal from all of the EncColMultBolts. @@ -123,8 +123,8 @@ public class EncColMultBolt extends BaseRichBolt @Override public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) { - outputFieldsDeclarer.declareStream(StormConstants.ENCCOLMULTBOLT_ID, - new Fields(StormConstants.COLUMN_INDEX_ECM_FIELD, StormConstants.COLUMN_PRODUCT_FIELD)); + outputFieldsDeclarer + .declareStream(StormConstants.ENCCOLMULTBOLT_ID, new Fields(StormConstants.COLUMN_INDEX_ECM_FIELD, StormConstants.COLUMN_PRODUCT_FIELD)); outputFieldsDeclarer.declareStream(StormConstants.ENCCOLMULTBOLT_SESSION_END, new Fields("finished")); } } http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/responder/wideskies/storm/EncRowCalcBolt.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/responder/wideskies/storm/EncRowCalcBolt.java b/src/main/java/org/apache/pirk/responder/wideskies/storm/EncRowCalcBolt.java index 639a52b..324fbf1 100644 --- a/src/main/java/org/apache/pirk/responder/wideskies/storm/EncRowCalcBolt.java +++ b/src/main/java/org/apache/pirk/responder/wideskies/storm/EncRowCalcBolt.java @@ -155,8 +155,8 @@ public class EncRowCalcBolt extends BaseRichBolt @Override public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) { - outputFieldsDeclarer.declareStream(StormConstants.ENCROWCALCBOLT_DATASTREAM_ID, - new Fields(StormConstants.COLUMN_INDEX_ERC_FIELD, StormConstants.ENCRYPTED_VALUE_FIELD, StormConstants.SALT)); + outputFieldsDeclarer.declareStream(StormConstants.ENCROWCALCBOLT_DATASTREAM_ID, new Fields(StormConstants.COLUMN_INDEX_ERC_FIELD, + StormConstants.ENCRYPTED_VALUE_FIELD, StormConstants.SALT)); outputFieldsDeclarer.declareStream(StormConstants.ENCROWCALCBOLT_FLUSH_SIG, new Fields(StormConstants.FLUSH)); } http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/responder/wideskies/storm/PirkTopology.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/responder/wideskies/storm/PirkTopology.java b/src/main/java/org/apache/pirk/responder/wideskies/storm/PirkTopology.java index ddfca8b..6540ecc 100644 --- a/src/main/java/org/apache/pirk/responder/wideskies/storm/PirkTopology.java +++ b/src/main/java/org/apache/pirk/responder/wideskies/storm/PirkTopology.java @@ -120,7 +120,8 @@ public class PirkTopology // b2.setMemoryLoad(5000); // b2.setCPULoad(150.0); - BoltDeclarer b3 = builder.setBolt(StormConstants.ENCCOLMULTBOLT_ID, ecmbolt, enccolmultboltParallelism) + BoltDeclarer b3 = builder + .setBolt(StormConstants.ENCCOLMULTBOLT_ID, ecmbolt, enccolmultboltParallelism) .fieldsGrouping(StormConstants.ENCROWCALCBOLT_ID, StormConstants.ENCROWCALCBOLT_DATASTREAM_ID, new Fields(StormConstants.COLUMN_INDEX_ERC_FIELD, StormConstants.SALT)) .allGrouping(StormConstants.ENCROWCALCBOLT_ID, StormConstants.ENCROWCALCBOLT_FLUSH_SIG); http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/test/utils/BaseTests.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/test/utils/BaseTests.java b/src/main/java/org/apache/pirk/test/utils/BaseTests.java index b0c9326..7536d8f 100644 --- a/src/main/java/org/apache/pirk/test/utils/BaseTests.java +++ b/src/main/java/org/apache/pirk/test/utils/BaseTests.java @@ -95,8 +95,8 @@ public class BaseTests logger.info("Completed testDNSHostnameQuery(): "); } - public static void checkDNSHostnameQueryResults(List<QueryResponseJSON> results, boolean isDistributed, int numExpectedResults, - boolean testFalsePositive, List<JSONObject> dataElements) + public static void checkDNSHostnameQueryResults(List<QueryResponseJSON> results, boolean isDistributed, int numExpectedResults, boolean testFalsePositive, + List<JSONObject> dataElements) { QuerySchema qSchema = QuerySchemaRegistry.get(Inputs.DNS_HOSTNAME_QUERY); logger.info("results:"); http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/test/utils/TestUtils.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/test/utils/TestUtils.java b/src/main/java/org/apache/pirk/test/utils/TestUtils.java index 6573a12..be01fb4 100644 --- a/src/main/java/org/apache/pirk/test/utils/TestUtils.java +++ b/src/main/java/org/apache/pirk/test/utils/TestUtils.java @@ -268,8 +268,9 @@ public class TestUtils /** * Converts the result file into an ArrayList of QueryResponseJSON objects - * @throws IOException - * @throws FileNotFoundException + * + * @throws IOException + * @throws FileNotFoundException */ public static List<QueryResponseJSON> readResultsFile(File file) throws FileNotFoundException, IOException { http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/main/java/org/apache/pirk/utils/QueryResultsWriter.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/utils/QueryResultsWriter.java b/src/main/java/org/apache/pirk/utils/QueryResultsWriter.java index 65470e4..2d37e6b 100644 --- a/src/main/java/org/apache/pirk/utils/QueryResultsWriter.java +++ b/src/main/java/org/apache/pirk/utils/QueryResultsWriter.java @@ -31,7 +31,6 @@ import org.apache.pirk.schema.response.QueryResponseJSON; public class QueryResultsWriter { - /** * Writes elements of the resultMap to output file, one line for each element, where each line is a string representation of the corresponding * QueryResponseJSON object http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/f4bdc01e/src/test/java/org/apache/pirk/storm/KafkaStormIntegrationTest.java ---------------------------------------------------------------------- diff --git a/src/test/java/org/apache/pirk/storm/KafkaStormIntegrationTest.java b/src/test/java/org/apache/pirk/storm/KafkaStormIntegrationTest.java index 906c337..fc4e703 100644 --- a/src/test/java/org/apache/pirk/storm/KafkaStormIntegrationTest.java +++ b/src/test/java/org/apache/pirk/storm/KafkaStormIntegrationTest.java @@ -125,7 +125,6 @@ public class KafkaStormIntegrationTest KafkaProducer producer = new KafkaProducer<String,String>(createKafkaProducerConfig()); loadTestData(producer); - logger.info("Test (splitPartitions,saltColumns) = (true,true)"); SystemConfiguration.setProperty("storm.splitPartitions", "true"); SystemConfiguration.setProperty("storm.saltColumns", "true"); @@ -196,14 +195,15 @@ public class KafkaStormIntegrationTest { iLocalCluster.submitTopology("pirk_integration_test", config, topology); logger.info("Pausing for setup."); - //Thread.sleep(4000); - //KafkaProducer producer = new KafkaProducer<String,String>(createKafkaProducerConfig()); - //loadTestData(producer); - //Thread.sleep(10000); - while(OutputBolt.latch.getCount() == testCountDown){ + // Thread.sleep(4000); + // KafkaProducer producer = new KafkaProducer<String,String>(createKafkaProducerConfig()); + // loadTestData(producer); + // Thread.sleep(10000); + while (OutputBolt.latch.getCount() == testCountDown) + { Thread.sleep(1000); } - testCountDown -=1; + testCountDown -= 1; logger.info("Finished..."); } @@ -248,7 +248,7 @@ public class KafkaStormIntegrationTest zkClient = new ZkClient(zookeeperLocalCluster.getConnectString(), 60000, 60000, ZKStringSerializer$.MODULE$); ZkUtils zkUtils = new ZkUtils(zkClient, new ZkConnection(zookeeperLocalCluster.getConnectString()), false); - //ZkUtils zkUtils = ZkUtils.apply(zookeeperLocalCluster.getConnectString(), 60000, 60000, false); + // ZkUtils zkUtils = ZkUtils.apply(zookeeperLocalCluster.getConnectString(), 60000, 60000, false); AdminUtils.createTopic(zkUtils, topic, 1, 1, new Properties()); }
