http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-frame.html index 9381dd4..c165c57 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib.format</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-summary.html index d86b24b..3946a80 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib.format</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-tree.html index 2c5c762..af1c5a9 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/format/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib.format Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-frame.html index 1bee015..ed9b3c5 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-summary.html index e3d2ddf..91d04ed 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-tree.html index 8470d6b..b0a177b 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html index 01a4bdd..42a37f3 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:38 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:25 CEST 2017 --> <title>FileSizeRotation</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/Rotation.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/Rotation.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/Rotation.html index d7092f0..b90196e 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/Rotation.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/Rotation.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:38 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:25 CEST 2017 --> <title>Rotation</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-frame.html index d12450c..9bc3922 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib.rotation</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-summary.html index 0af6338..43f9201 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib.rotation</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-tree.html index 2797a7a..4ebf786 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/lib/rotation/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop.lib.rotation Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-frame.html index 0fd9aab..6b4baae 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-summary.html index 4d361fa..de04328 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-tree.html index 35cf3a6..23ae083 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/hadoop/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.hadoop Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Graph.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Graph.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Graph.html index 30b4bfa..25e8043 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Graph.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Graph.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>Graph</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Processor.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Processor.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Processor.html index 1275d8d..5cb8593 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Processor.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Processor.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>Processor</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/StreamApplication.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/StreamApplication.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/StreamApplication.html index 93fccc7..c112fd9 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/StreamApplication.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/StreamApplication.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>StreamApplication</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Task.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Task.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Task.html index 0565d22..1782257 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Task.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/Task.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>Task</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -183,7 +183,7 @@ extends <a href="../../../../../org/apache/gearpump/streaming/task/Task.html" ti </tr> <tr id="i0" class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/javaapi/Task.html#onNext-org.apache.gearpump.Message-">onNext</a></span>(<a href="../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> msg)</code> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/javaapi/Task.html#onNext-org.apache.gearpump.Message-">onNext</a></span>(<a href="../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a> msg)</code> <div class="block">Method called for each message received.</div> </td> </tr> @@ -316,7 +316,7 @@ extends <a href="../../../../../org/apache/gearpump/streaming/task/Task.html" ti <ul class="blockList"> <li class="blockList"> <h4>onNext</h4> -<pre>public void onNext(<a href="../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> msg)</pre> +<pre>public void onNext(<a href="../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a> msg)</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/gearpump/streaming/task/TaskInterface.html#onNext-org.apache.gearpump.Message-">TaskInterface</a></code></span></div> <div class="block">Method called for each message received. <p></div> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html index d8e09ab..dad6e48 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.javaapi</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html index 73c802b..23ca518 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.javaapi</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html index 99b1943..d77d1a0 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.javaapi Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html index 3bfddee..db30e9a 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>KafkaSink</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html index 562a0c5..0a845f9 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>KafkaSource</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html index 3a9b6bd..3a0bbab 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>KafkaStoreFactory</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html index 4c29267..7a267a9 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>KafkaDSL</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html index 167ba47..8b5034d 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.dsl</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html index 1f2569a..caf4ba7 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.dsl</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html index 39cd848..bd0098d 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.dsl Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html index 7f11f14..08dca49 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>KafkaMessageDecoder</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html index bc690b0..d29db26 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>MessageAndWatermark</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> @@ -137,7 +137,7 @@ implements scala.Product, scala.Serializable</pre> <th class="colOne" scope="col">Constructor and Description</th> </tr> <tr class="altColor"> -<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html#MessageAndWatermark-org.apache.gearpump.Message-java.time.Instant-">MessageAndWatermark</a></span>(<a href="../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> message, +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html#MessageAndWatermark-org.apache.gearpump.Message-java.time.Instant-">MessageAndWatermark</a></span>(<a href="../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a> message, java.time.Instant watermark)</code> </td> </tr> </table> @@ -156,7 +156,7 @@ implements scala.Product, scala.Serializable</pre> <th class="colLast" scope="col">Method and Description</th> </tr> <tr id="i0" class="altColor"> -<td class="colFirst"><code><a href="../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a></code></td> +<td class="colFirst"><code><a href="../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html#message--">message</a></span>()</code> </td> </tr> <tr id="i1" class="rowColor"> @@ -205,7 +205,7 @@ implements scala.Product, scala.Serializable</pre> <ul class="blockListLast"> <li class="blockList"> <h4>MessageAndWatermark</h4> -<pre>public MessageAndWatermark(<a href="../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> message, +<pre>public MessageAndWatermark(<a href="../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a> message, java.time.Instant watermark)</pre> </li> </ul> @@ -223,7 +223,7 @@ implements scala.Product, scala.Serializable</pre> <ul class="blockList"> <li class="blockList"> <h4>message</h4> -<pre>public <a href="../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> message()</pre> +<pre>public <a href="../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a> message()</pre> </li> </ul> <a name="watermark--"> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html index 5cd1c36..d739b90 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html index f44a210..e5b743e 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html index 5d4f334..294d476 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html index 2a5d16c..9bb4faf 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>AbstractKafkaSink.KafkaProducerFactory</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html index 95caf40..9fbf9eb 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>AbstractKafkaSink</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> @@ -206,7 +206,7 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/sink/Data </tr> <tr id="i3" class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html#write-org.apache.gearpump.Message-">write</a></span>(<a href="../../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> message)</code> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html#write-org.apache.gearpump.Message-">write</a></span>(<a href="../../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a> message)</code> <div class="block">Writes message into data sink invoked at onNext() method of <a href="../../../../../../../org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><code>Task</code></a></div> </td> @@ -296,7 +296,7 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/sink/Data <ul class="blockList"> <li class="blockList"> <h4>write</h4> -<pre>public void write(<a href="../../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> message)</pre> +<pre>public void write(<a href="../../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a> message)</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../../org/apache/gearpump/streaming/sink/DataSink.html#write-org.apache.gearpump.Message-">DataSink</a></code></span></div> <div class="block">Writes message into data sink invoked at onNext() method of <a href="../../../../../../../org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><code>Task</code></a></div> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html index 6e759de..782c0f1 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.sink</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html index 9ae21ee..c0ce671 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.sink</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html index e71be30..e6fa79c 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.sink Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html index a575984..3150dae 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>AbstractKafkaSource</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> @@ -197,7 +197,7 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/transacti </td> </tr> <tr id="i4" class="altColor"> -<td class="colFirst"><code><a href="../../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a></code></td> +<td class="colFirst"><code><a href="../../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#read--">read</a></span>()</code> <div class="block">Reads a record from incoming queue, decodes, filters and checkpoints offsets before returns a Message.</div> @@ -308,14 +308,15 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/transacti <ul class="blockList"> <li class="blockList"> <h4>read</h4> -<pre>public <a href="../../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> read()</pre> +<pre>public <a href="../../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a> read()</pre> <div class="block">Reads a record from incoming queue, decodes, filters and checkpoints offsets - before returns a Message. Message can be null if the incoming queue is empty.</div> + before returns a Message. Message can be null if the incoming queue is empty. + <p></div> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#read--">read</a></code> in interface <code><a href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a></code></dd> <dt><span class="returnLabel">Returns:</span></dt> -<dd>a <a href="../../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump"><code>Message</code></a> or null</dd> +<dd>a <a href="../../../../../../../org/apache/gearpump/Message.html" title="interface in org.apache.gearpump"><code>Message</code></a> or null</dd> </dl> </li> </ul> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html index 53a083f..2b4d2ee 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>DefaultKafkaMessageDecoder</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/ExponentialBackoffSleeper.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/ExponentialBackoffSleeper.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/ExponentialBackoffSleeper.html index 43711c8..fbe4b7e 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/ExponentialBackoffSleeper.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/ExponentialBackoffSleeper.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>ExponentialBackoffSleeper</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.FetchThreadFactory.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.FetchThreadFactory.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.FetchThreadFactory.html index e6b4a96..ac68563 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.FetchThreadFactory.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.FetchThreadFactory.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>FetchThread.FetchThreadFactory</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.html index 6fc654c..fef3c4f 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>FetchThread</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaConsumer.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaConsumer.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaConsumer.html index 5588ddb..82c7cc6 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaConsumer.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaConsumer.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>KafkaConsumer</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessage.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessage.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessage.html index 2e26175..ff91dc7 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessage.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessage.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>KafkaMessage</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-frame.html index 7bdf672..44808b1 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source.consumer</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-summary.html index a379358..8033609 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source.consumer</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-tree.html index 8d385fc..acb0be4 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/consumer/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source.consumer Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html index 6d2fc2f..77c19ca 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:39 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:27 CEST 2017 --> <title>DefaultPartitionGrouper</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/PartitionGrouper.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/PartitionGrouper.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/PartitionGrouper.html index 4478309..7361ce9 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/PartitionGrouper.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/PartitionGrouper.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:39 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:27 CEST 2017 --> <title>PartitionGrouper</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-frame.html index 4297920..c5b8368 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source.grouper</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-summary.html index a99201f..659a54a 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source.grouper</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-tree.html index df839ca..217b0cd 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/grouper/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source.grouper Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-frame.html index 53296c8..c43babe 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-summary.html index f9e0338..8e7f1aa 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-tree.html index 4b6a2be..e08dfe5 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.source Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html index 597cb7b..2a568d4 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:35 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:22 CEST 2017 --> <title>AbstractKafkaStoreFactory</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html index 610a96a..9051254 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:35 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:22 CEST 2017 --> <title>KafkaStore</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-frame.html index 5fcfde3..8201cc2 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.store</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-summary.html index 1e11a2e..df87f44 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.store</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-tree.html index f8e2fd9..ca2761a 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-tree.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/store/package-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.store Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.KafkaClientFactory.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.KafkaClientFactory.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.KafkaClientFactory.html index 4215a4c..577e40b 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.KafkaClientFactory.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.KafkaClientFactory.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>KafkaClient.KafkaClientFactory</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.html index aeb9c44..5299d2c 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:23 CEST 2017 --> <title>KafkaClient</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-frame.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-frame.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-frame.html index a88df08..0ed74a5 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-frame.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.util</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-summary.html index 18986d2..2d19a9f 100644 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-summary.html +++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/util/package-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:28 CEST 2017 --> <title>org.apache.gearpump.streaming.kafka.lib.util</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head>
