http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 64a0dc3..a6c0c0c 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_25) on Thu Aug 11 09:54:10 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 --> <title>KafkaSink</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 921d22e..d257930 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_25) on Thu Aug 11 09:54:10 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 --> <title>KafkaSource</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -175,7 +175,7 @@ implements <a href="../../../../../org/apache/gearpump/streaming/transaction/api <!-- --> </a> <h3>Methods inherited from class org.apache.gearpump.streaming.kafka.lib.source.<a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">AbstractKafkaSource</a></h3> -<code><a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#addCheckpointStore-kafka.common.TopicAndPartition-org.apache.gearpump.streaming.transaction.api.CheckpointStore-">addCheckpointStore</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#close--">close</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#open-org.apache.gearpump.streaming.task.TaskContext-long-">open</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#read--">read</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#setCheckpointStore-org.apache.gearpump.streaming.transaction.api.CheckpointStoreFactory-">setCheckpointStore</a></code></li> +<code><a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#addCheckpointStore-kafka.common.TopicAndPartition-org.apache.gearpump.streaming.transaction.api.CheckpointStore-">addCheckpointStore</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#close--">close</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#getWatermark--">getWatermark</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">open</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#read--">read</a>, <a href="../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#setCheckpointStore-org.apache.gearpump.streaming.transaction.api.CheckpointStoreFactory-">setCheckpointStore</a></code></li > </ul> <ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> @@ -196,7 +196,7 @@ implements <a href="../../../../../org/apache/gearpump/streaming/transaction/api <!-- --> </a> <h3>Methods inherited from interface org.apache.gearpump.streaming.source.<a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a></h3> -<code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#close--">close</a>, <a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-long-">open</a>, <a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#read--">read</a></code></li> +<code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#close--">close</a>, <a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#getWatermark--">getWatermark</a>, <a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">open</a>, <a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#read--">read</a></code></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 89dec61..e42a5d1 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_25) on Thu Aug 11 09:54:10 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 --> <title>KafkaStoreFactory</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 48c5a23..f6c99d3 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_25) on Thu Aug 11 09:54:10 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 --> <title>KafkaDSL</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 232aff6..37a0d0c 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.dsl</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 968bac9..b42fdc1 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.dsl</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> @@ -43,7 +43,7 @@ <div class="subNav"> <ul class="navList"> <li><a href="../../../../../../org/apache/gearpump/streaming/kafka/package-summary.html">Prev Package</a></li> -<li><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html">Next Package</a></li> +<li><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/package-summary.html">Next Package</a></li> </ul> <ul class="navList"> <li><a href="../../../../../../index.html?org/apache/gearpump/streaming/kafka/dsl/package-summary.html" target="_top">Frames</a></li> @@ -111,7 +111,7 @@ <div class="subNav"> <ul class="navList"> <li><a href="../../../../../../org/apache/gearpump/streaming/kafka/package-summary.html">Prev Package</a></li> -<li><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html">Next Package</a></li> +<li><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/package-summary.html">Next Package</a></li> </ul> <ul class="navList"> <li><a href="../../../../../../index.html?org/apache/gearpump/streaming/kafka/dsl/package-summary.html" target="_top">Frames</a></li> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 5825680..e1c0cca 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.dsl Class Hierarchy</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../script.js"></script> </head> @@ -43,7 +43,7 @@ <div class="subNav"> <ul class="navList"> <li><a href="../../../../../../org/apache/gearpump/streaming/kafka/package-tree.html">Prev</a></li> -<li><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html">Next</a></li> +<li><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/package-tree.html">Next</a></li> </ul> <ul class="navList"> <li><a href="../../../../../../index.html?org/apache/gearpump/streaming/kafka/dsl/package-tree.html" target="_top">Frames</a></li> @@ -106,7 +106,7 @@ <div class="subNav"> <ul class="navList"> <li><a href="../../../../../../org/apache/gearpump/streaming/kafka/package-tree.html">Prev</a></li> -<li><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html">Next</a></li> +<li><a href="../../../../../../org/apache/gearpump/streaming/kafka/lib/package-tree.html">Next</a></li> </ul> <ul class="navList"> <li><a href="../../../../../../index.html?org/apache/gearpump/streaming/kafka/dsl/package-tree.html" target="_top">Frames</a></li> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 a2ba0d3..da7a1d4 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 --> <title>AbstractKafkaSink.KafkaProducerFactory</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 4f3f049..0c85abd 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 --> <title>AbstractKafkaSink</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 6de594b..8b2f84d 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.sink</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 ddfa204..432631a 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.sink</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> @@ -42,7 +42,7 @@ </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/dsl/package-summary.html">Prev Package</a></li> +<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/package-summary.html">Prev Package</a></li> <li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/package-summary.html">Next Package</a></li> </ul> <ul class="navList"> @@ -128,7 +128,7 @@ </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/dsl/package-summary.html">Prev Package</a></li> +<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/package-summary.html">Prev Package</a></li> <li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/package-summary.html">Next Package</a></li> </ul> <ul class="navList"> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 6aaee76..2f9d2b0 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.sink Class Hierarchy</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> @@ -42,7 +42,7 @@ </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/dsl/package-tree.html">Prev</a></li> +<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/package-tree.html">Prev</a></li> <li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/package-tree.html">Next</a></li> </ul> <ul class="navList"> @@ -113,7 +113,7 @@ </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/dsl/package-tree.html">Prev</a></li> +<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/package-tree.html">Prev</a></li> <li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/package-tree.html">Next</a></li> </ul> <ul class="navList"> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 0cd9136..9450506 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_25) on Thu Aug 11 09:54:16 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:19 PST 2016 --> <title>AbstractKafkaSource</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -49,7 +49,7 @@ var activeTableTab = "activeTableTab"; <div class="subNav"> <ul class="navList"> <li>Prev Class</li> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../../../index.html?org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" target="_top">Frames</a></li> @@ -122,17 +122,7 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/transacti <div class="block">Contains implementation for Kafka source connectors, users should use <a href="../../../../../../../org/apache/gearpump/streaming/kafka/KafkaSource.html" title="class in org.apache.gearpump.streaming.kafka"><code>KafkaSource</code></a>. <p> - This is a TimeReplayableSource which is able to replay messages given a start time. - Each kafka message is tagged with a timestamp by - <a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api"><code>MessageDecoder</code></a> and the (timestamp, offset) - mapping is stored to a <a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/CheckpointStore.html" title="interface in org.apache.gearpump.streaming.transaction.api"><code>CheckpointStore</code></a>. - On recovery, we could retrieve the previously stored offset from the - <a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/CheckpointStore.html" title="interface in org.apache.gearpump.streaming.transaction.api"><code>CheckpointStore</code></a> by timestamp and start to read - from there. - <p> - kafka message is wrapped into gearpump <a href="../../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump"><code>Message</code></a> and further filtered by a - <a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/TimeStampFilter.html" title="interface in org.apache.gearpump.streaming.transaction.api"><code>TimeStampFilter</code></a> - such that obsolete messages are dropped.</div> + This is a TimeReplayableSource which is able to replay messages from kafka given a start time.</div> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../../../serialized-form.html#org.apache.gearpump.streaming.kafka.lib.source.AbstractKafkaSource">Serialized Form</a></dd> @@ -192,21 +182,29 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/transacti </td> </tr> <tr id="i2" class="altColor"> +<td class="colFirst"><code>java.time.Instant</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#getWatermark--">getWatermark</a></span>()</code> +<div class="block">Returns a watermark + no timestamp earlier than the watermark + should enter the system</div> +</td> +</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/source/AbstractKafkaSource.html#open-org.apache.gearpump.streaming.task.TaskContext-long-">open</a></span>(<a href="../../../../../../../org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a> context, - long startTime)</code> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">open</a></span>(<a href="../../../../../../../org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a> context, + java.time.Instant startTime)</code> <div class="block">Opens connection to data source invoked in onStart() method of <a href="../../../../../../../org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source"><code>DataSourceTask</code></a></div> </td> </tr> -<tr id="i3" class="rowColor"> +<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="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> </td> </tr> -<tr id="i4" class="altColor"> +<tr id="i5" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#setCheckpointStore-org.apache.gearpump.streaming.transaction.api.CheckpointStoreFactory-">setCheckpointStore</a></span>(<a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/CheckpointStoreFactory.html" title="interface in org.apache.gearpump.streaming.transaction.api">CheckpointStoreFactory</a> checkpointStoreFactory)</code> <div class="block">Sets store factory which creates a checkpoint store @@ -284,21 +282,21 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/transacti </dl> </li> </ul> -<a name="open-org.apache.gearpump.streaming.task.TaskContext-long-"> +<a name="open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>open</h4> <pre>public void open(<a href="../../../../../../../org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a> context, - long startTime)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-long-">DataSource</a></code></span></div> + java.time.Instant startTime)</pre> +<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">DataSource</a></code></span></div> <div class="block">Opens connection to data source invoked in onStart() method of <a href="../../../../../../../org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source"><code>DataSourceTask</code></a> <p></div> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-long-">open</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> +<dd><code><a href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">open</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="paramLabel">Parameters:</span></dt> <dd><code>context</code> - is the task context at runtime</dd> <dd><code>startTime</code> - is the start time of system</dd> @@ -338,6 +336,25 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/transacti </dl> </li> </ul> +<a name="getWatermark--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getWatermark</h4> +<pre>public java.time.Instant getWatermark()</pre> +<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#getWatermark--">DataSource</a></code></span></div> +<div class="block">Returns a watermark + no timestamp earlier than the watermark + should enter the system</div> +<dl> +<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> +<dd><code><a href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#getWatermark--">getWatermark</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>(undocumented)</dd> +</dl> +</li> +</ul> <a name="addCheckpointStore-kafka.common.TopicAndPartition-org.apache.gearpump.streaming.transaction.api.CheckpointStore-"> <!-- --> </a> @@ -376,7 +393,7 @@ implements <a href="../../../../../../../org/apache/gearpump/streaming/transacti <div class="subNav"> <ul class="navList"> <li>Prev Class</li> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../../../index.html?org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" target="_top">Frames</a></li> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html deleted file mode 100644 index 0a9f1e9..0000000 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html +++ /dev/null @@ -1,289 +0,0 @@ -<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> -<!-- NewPage --> -<html lang="en"> -<head> -<!-- Generated by javadoc (1.8.0_25) on Thu Aug 11 09:54:16 PDT 2016 --> -<title>DefaultMessageDecoder</title> -<meta name="date" content="2016-08-11"> -<link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> -<script type="text/javascript" src="../../../../../../../script.js"></script> -</head> -<body> -<script type="text/javascript"><!-- - try { - if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="DefaultMessageDecoder"; - } - } - catch(err) { - } -//--> -var methods = {"i0":10}; -var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; -var altColor = "altColor"; -var rowColor = "rowColor"; -var tableTab = "tableTab"; -var activeTableTab = "activeTableTab"; -</script> -<noscript> -<div>JavaScript is disabled on your browser.</div> -</noscript> -<!-- ========= START OF TOP NAVBAR ======= --> -<div class="topNav"><a name="navbar.top"> -<!-- --> -</a> -<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> -<a name="navbar.top.firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../../../../../overview-summary.html">Overview</a></li> -<li><a href="package-summary.html">Package</a></li> -<li class="navBarCell1Rev">Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../../../../../index-all.html">Index</a></li> -<li><a href="../../../../../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Next Class</span></a></li> -</ul> -<ul class="navList"> -<li><a href="../../../../../../../index.html?org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" target="_top">Frames</a></li> -<li><a href="DefaultMessageDecoder.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_top"> -<li><a href="../../../../../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_top"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<div> -<ul class="subNavList"> -<li>Summary: </li> -<li>Nested | </li> -<li>Field | </li> -<li><a href="#constructor.summary">Constr</a> | </li> -<li><a href="#method.summary">Method</a></li> -</ul> -<ul class="subNavList"> -<li>Detail: </li> -<li>Field | </li> -<li><a href="#constructor.detail">Constr</a> | </li> -<li><a href="#method.detail">Method</a></li> -</ul> -</div> -<a name="skip.navbar.top"> -<!-- --> -</a></div> -<!-- ========= END OF TOP NAVBAR ========= --> -<!-- ======== START OF CLASS DATA ======== --> -<div class="header"> -<div class="subTitle">org.apache.gearpump.streaming.kafka.lib.source</div> -<h2 title="Class DefaultMessageDecoder" class="title">Class DefaultMessageDecoder</h2> -</div> -<div class="contentContainer"> -<ul class="inheritance"> -<li>java.lang.Object</li> -<li> -<ul class="inheritance"> -<li>org.apache.gearpump.streaming.kafka.lib.source.DefaultMessageDecoder</li> -</ul> -</li> -</ul> -<div class="description"> -<ul class="blockList"> -<li class="blockList"> -<dl> -<dt>All Implemented Interfaces:</dt> -<dd>java.io.Serializable, <a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a></dd> -</dl> -<hr> -<br> -<pre>public class <span class="typeNameLabel">DefaultMessageDecoder</span> -extends java.lang.Object -implements <a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a></pre> -<dl> -<dt><span class="seeLabel">See Also:</span></dt> -<dd><a href="../../../../../../../serialized-form.html#org.apache.gearpump.streaming.kafka.lib.source.DefaultMessageDecoder">Serialized Form</a></dd> -</dl> -</li> -</ul> -</div> -<div class="summary"> -<ul class="blockList"> -<li class="blockList"> -<!-- ======== CONSTRUCTOR SUMMARY ======== --> -<ul class="blockList"> -<li class="blockList"><a name="constructor.summary"> -<!-- --> -</a> -<h3>Constructor Summary</h3> -<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation"> -<caption><span>Constructors</span><span class="tabEnd"> </span></caption> -<tr> -<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/source/DefaultMessageDecoder.html#DefaultMessageDecoder--">DefaultMessageDecoder</a></span>()</code> </td> -</tr> -</table> -</li> -</ul> -<!-- ========== METHOD SUMMARY =========== --> -<ul class="blockList"> -<li class="blockList"><a name="method.summary"> -<!-- --> -</a> -<h3>Method Summary</h3> -<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> -<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> -<tr> -<th class="colFirst" scope="col">Modifier and Type</th> -<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="colLast"><code><span class="memberNameLink"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html#fromBytes-byte:A-byte:A-">fromBytes</a></span>(byte[] key, - byte[] value)</code> </td> -</tr> -</table> -<ul class="blockList"> -<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> -<!-- --> -</a> -<h3>Methods inherited from class java.lang.Object</h3> -<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li> -</ul> -</li> -</ul> -</li> -</ul> -</div> -<div class="details"> -<ul class="blockList"> -<li class="blockList"> -<!-- ========= CONSTRUCTOR DETAIL ======== --> -<ul class="blockList"> -<li class="blockList"><a name="constructor.detail"> -<!-- --> -</a> -<h3>Constructor Detail</h3> -<a name="DefaultMessageDecoder--"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>DefaultMessageDecoder</h4> -<pre>public DefaultMessageDecoder()</pre> -</li> -</ul> -</li> -</ul> -<!-- ============ METHOD DETAIL ========== --> -<ul class="blockList"> -<li class="blockList"><a name="method.detail"> -<!-- --> -</a> -<h3>Method Detail</h3> -<a name="fromBytes-byte:A-byte:A-"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>fromBytes</h4> -<pre>public <a href="../../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> fromBytes(byte[] key, - byte[] value)</pre> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html#fromBytes-byte:A-byte:A-">fromBytes</a></code> in interface <code><a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>key</code> - key of a kafka message, can be NULL</dd> -<dd><code>value</code> - value of a kafka message</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>a gearpump Message</dd> -</dl> -</li> -</ul> -</li> -</ul> -</li> -</ul> -</div> -</div> -<!-- ========= END OF CLASS DATA ========= --> -<!-- ======= START OF BOTTOM NAVBAR ====== --> -<div class="bottomNav"><a name="navbar.bottom"> -<!-- --> -</a> -<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> -<a name="navbar.bottom.firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../../../../../overview-summary.html">Overview</a></li> -<li><a href="package-summary.html">Package</a></li> -<li class="navBarCell1Rev">Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../../../../../index-all.html">Index</a></li> -<li><a href="../../../../../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Next Class</span></a></li> -</ul> -<ul class="navList"> -<li><a href="../../../../../../../index.html?org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" target="_top">Frames</a></li> -<li><a href="DefaultMessageDecoder.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_bottom"> -<li><a href="../../../../../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_bottom"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<div> -<ul class="subNavList"> -<li>Summary: </li> -<li>Nested | </li> -<li>Field | </li> -<li><a href="#constructor.summary">Constr</a> | </li> -<li><a href="#method.summary">Method</a></li> -</ul> -<ul class="subNavList"> -<li>Detail: </li> -<li>Field | </li> -<li><a href="#constructor.detail">Constr</a> | </li> -<li><a href="#method.detail">Method</a></li> -</ul> -</div> -<a name="skip.navbar.bottom"> -<!-- --> -</a></div> -<!-- ======== END OF BOTTOM NAVBAR ======= --> -</body> -</html> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html deleted file mode 100644 index a502f70..0000000 --- a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html +++ /dev/null @@ -1,289 +0,0 @@ -<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> -<!-- NewPage --> -<html lang="en"> -<head> -<!-- Generated by javadoc (1.8.0_25) on Thu Aug 11 09:54:16 PDT 2016 --> -<title>StringMessageDecoder</title> -<meta name="date" content="2016-08-11"> -<link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> -<script type="text/javascript" src="../../../../../../../script.js"></script> -</head> -<body> -<script type="text/javascript"><!-- - try { - if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="StringMessageDecoder"; - } - } - catch(err) { - } -//--> -var methods = {"i0":10}; -var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; -var altColor = "altColor"; -var rowColor = "rowColor"; -var tableTab = "tableTab"; -var activeTableTab = "activeTableTab"; -</script> -<noscript> -<div>JavaScript is disabled on your browser.</div> -</noscript> -<!-- ========= START OF TOP NAVBAR ======= --> -<div class="topNav"><a name="navbar.top"> -<!-- --> -</a> -<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> -<a name="navbar.top.firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../../../../../overview-summary.html">Overview</a></li> -<li><a href="package-summary.html">Package</a></li> -<li class="navBarCell1Rev">Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../../../../../index-all.html">Index</a></li> -<li><a href="../../../../../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Prev Class</span></a></li> -<li>Next Class</li> -</ul> -<ul class="navList"> -<li><a href="../../../../../../../index.html?org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html" target="_top">Frames</a></li> -<li><a href="StringMessageDecoder.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_top"> -<li><a href="../../../../../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_top"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<div> -<ul class="subNavList"> -<li>Summary: </li> -<li>Nested | </li> -<li>Field | </li> -<li><a href="#constructor.summary">Constr</a> | </li> -<li><a href="#method.summary">Method</a></li> -</ul> -<ul class="subNavList"> -<li>Detail: </li> -<li>Field | </li> -<li><a href="#constructor.detail">Constr</a> | </li> -<li><a href="#method.detail">Method</a></li> -</ul> -</div> -<a name="skip.navbar.top"> -<!-- --> -</a></div> -<!-- ========= END OF TOP NAVBAR ========= --> -<!-- ======== START OF CLASS DATA ======== --> -<div class="header"> -<div class="subTitle">org.apache.gearpump.streaming.kafka.lib.source</div> -<h2 title="Class StringMessageDecoder" class="title">Class StringMessageDecoder</h2> -</div> -<div class="contentContainer"> -<ul class="inheritance"> -<li>java.lang.Object</li> -<li> -<ul class="inheritance"> -<li>org.apache.gearpump.streaming.kafka.lib.source.StringMessageDecoder</li> -</ul> -</li> -</ul> -<div class="description"> -<ul class="blockList"> -<li class="blockList"> -<dl> -<dt>All Implemented Interfaces:</dt> -<dd>java.io.Serializable, <a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a></dd> -</dl> -<hr> -<br> -<pre>public class <span class="typeNameLabel">StringMessageDecoder</span> -extends java.lang.Object -implements <a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a></pre> -<dl> -<dt><span class="seeLabel">See Also:</span></dt> -<dd><a href="../../../../../../../serialized-form.html#org.apache.gearpump.streaming.kafka.lib.source.StringMessageDecoder">Serialized Form</a></dd> -</dl> -</li> -</ul> -</div> -<div class="summary"> -<ul class="blockList"> -<li class="blockList"> -<!-- ======== CONSTRUCTOR SUMMARY ======== --> -<ul class="blockList"> -<li class="blockList"><a name="constructor.summary"> -<!-- --> -</a> -<h3>Constructor Summary</h3> -<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation"> -<caption><span>Constructors</span><span class="tabEnd"> </span></caption> -<tr> -<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/source/StringMessageDecoder.html#StringMessageDecoder--">StringMessageDecoder</a></span>()</code> </td> -</tr> -</table> -</li> -</ul> -<!-- ========== METHOD SUMMARY =========== --> -<ul class="blockList"> -<li class="blockList"><a name="method.summary"> -<!-- --> -</a> -<h3>Method Summary</h3> -<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> -<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> -<tr> -<th class="colFirst" scope="col">Modifier and Type</th> -<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="colLast"><code><span class="memberNameLink"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html#fromBytes-byte:A-byte:A-">fromBytes</a></span>(byte[] key, - byte[] value)</code> </td> -</tr> -</table> -<ul class="blockList"> -<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> -<!-- --> -</a> -<h3>Methods inherited from class java.lang.Object</h3> -<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li> -</ul> -</li> -</ul> -</li> -</ul> -</div> -<div class="details"> -<ul class="blockList"> -<li class="blockList"> -<!-- ========= CONSTRUCTOR DETAIL ======== --> -<ul class="blockList"> -<li class="blockList"><a name="constructor.detail"> -<!-- --> -</a> -<h3>Constructor Detail</h3> -<a name="StringMessageDecoder--"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>StringMessageDecoder</h4> -<pre>public StringMessageDecoder()</pre> -</li> -</ul> -</li> -</ul> -<!-- ============ METHOD DETAIL ========== --> -<ul class="blockList"> -<li class="blockList"><a name="method.detail"> -<!-- --> -</a> -<h3>Method Detail</h3> -<a name="fromBytes-byte:A-byte:A-"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>fromBytes</h4> -<pre>public <a href="../../../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> fromBytes(byte[] key, - byte[] value)</pre> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html#fromBytes-byte:A-byte:A-">fromBytes</a></code> in interface <code><a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>key</code> - key of a kafka message, can be NULL</dd> -<dd><code>value</code> - value of a kafka message</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>a gearpump Message</dd> -</dl> -</li> -</ul> -</li> -</ul> -</li> -</ul> -</div> -</div> -<!-- ========= END OF CLASS DATA ========= --> -<!-- ======= START OF BOTTOM NAVBAR ====== --> -<div class="bottomNav"><a name="navbar.bottom"> -<!-- --> -</a> -<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> -<a name="navbar.bottom.firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../../../../../overview-summary.html">Overview</a></li> -<li><a href="package-summary.html">Package</a></li> -<li class="navBarCell1Rev">Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../../../../../index-all.html">Index</a></li> -<li><a href="../../../../../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">Prev Class</span></a></li> -<li>Next Class</li> -</ul> -<ul class="navList"> -<li><a href="../../../../../../../index.html?org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html" target="_top">Frames</a></li> -<li><a href="StringMessageDecoder.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_bottom"> -<li><a href="../../../../../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_bottom"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<div> -<ul class="subNavList"> -<li>Summary: </li> -<li>Nested | </li> -<li>Field | </li> -<li><a href="#constructor.summary">Constr</a> | </li> -<li><a href="#method.summary">Method</a></li> -</ul> -<ul class="subNavList"> -<li>Detail: </li> -<li>Field | </li> -<li><a href="#constructor.detail">Constr</a> | </li> -<li><a href="#method.detail">Method</a></li> -</ul> -</div> -<a name="skip.navbar.bottom"> -<!-- --> -</a></div> -<!-- ======== END OF BOTTOM NAVBAR ======= --> -</body> -</html> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 f754f91..8f85abf 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 --> <title>ExponentialBackoffSleeper</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 48ff9e3..9e0221f 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 --> <title>FetchThread.FetchThreadFactory</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 55d9450..340378b 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 --> <title>FetchThread</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 599129d..91d2406 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 --> <title>KafkaConsumer</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 8d270b4..384a394 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 --> <title>KafkaMessage</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 c0e298a..1594a88 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source.consumer</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 7e19094..68ad86b 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source.consumer</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 9714988..599a8e6 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source.consumer Class Hierarchy</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 0e41a7e..2364466 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_25) on Thu Aug 11 09:54:15 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:19 PST 2016 --> <title>DefaultPartitionGrouper</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 71085be..4acf315 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_25) on Thu Aug 11 09:54:15 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:19 PST 2016 --> <title>PartitionGrouper</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 e957417..1b70f11 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source.grouper</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 4c67d87..66e200f 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source.grouper</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 955447e..9a738a3 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source.grouper Class Hierarchy</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 fc720a6..e3f187b 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> @@ -14,8 +14,7 @@ <h2 title="Classes">Classes</h2> <ul title="Classes"> <li><a href="AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source" target="classFrame">AbstractKafkaSource</a></li> -<li><a href="DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source" target="classFrame">DefaultMessageDecoder</a></li> -<li><a href="StringMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source" target="classFrame">StringMessageDecoder</a></li> +<li><a href="DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source" target="classFrame">DefaultKafkaMessageDecoder</a></li> </ul> </div> </body> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 9e52045..2b32284 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> @@ -89,11 +89,7 @@ </td> </tr> <tr class="rowColor"> -<td class="colFirst"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">DefaultMessageDecoder</a></td> -<td class="colLast"> </td> -</tr> -<tr class="altColor"> -<td class="colFirst"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">StringMessageDecoder</a></td> +<td class="colFirst"><a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">DefaultKafkaMessageDecoder</a></td> <td class="colLast"> </td> </tr> </tbody> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 c51e3f8..ecefd92 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.source Class Hierarchy</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head> @@ -81,8 +81,7 @@ <li type="circle">java.lang.Object <ul> <li type="circle">org.apache.gearpump.streaming.kafka.lib.source.<a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">AbstractKafkaSource</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/TimeReplayableSource.html" title="interface in org.apache.gearpump.streaming.transaction.api">TimeReplayableSource</a>)</li> -<li type="circle">org.apache.gearpump.streaming.kafka.lib.source.<a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">DefaultMessageDecoder</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a>)</li> -<li type="circle">org.apache.gearpump.streaming.kafka.lib.source.<a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">StringMessageDecoder</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="../../../../../../../org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a>)</li> +<li type="circle">org.apache.gearpump.streaming.kafka.lib.source.<a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">DefaultKafkaMessageDecoder</span></a> (implements org.apache.gearpump.streaming.kafka.lib.<a href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html" title="interface in org.apache.gearpump.streaming.kafka.lib">KafkaMessageDecoder</a>)</li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 69d9ed1..851d08e 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 --> <title>AbstractKafkaStoreFactory</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 9ebee60..d7768d2 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_25) on Thu Aug 11 09:54:09 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 --> <title>KafkaStore</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 b3acd98..e02784e 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.store</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 ceca4dd..928ee58 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.store</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <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/6091d5f1/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 bf041e7..4d1b290 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_25) on Thu Aug 11 09:54:17 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 --> <title>org.apache.gearpump.streaming.kafka.lib.store Class Hierarchy</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../../../script.js"></script> </head>
