You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by es...@apache.org on 2021/11/26 19:11:09 UTC
[bahir-website] branch asf-site updated: Publishing from 7981d313dbed835c3c629c8c4d793f3480ff481f
This is an automated email from the ASF dual-hosted git repository.
eskabetxe pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/bahir-website.git
The following commit(s) were added to refs/heads/asf-site by this push:
new f47c091 Publishing from 7981d313dbed835c3c629c8c4d793f3480ff481f
f47c091 is described below
commit f47c0911730c4599b414596be339503ea7d724da
Author: Joao Boto <jb...@idealista.com>
AuthorDate: Fri Nov 26 20:10:50 2021 +0100
Publishing from 7981d313dbed835c3c629c8c4d793f3480ff481f
---
content/community-members/index.html | 6 +-
content/community/index.html | 2 +-
content/contributing-extensions/index.html | 2 +-
content/contributing/index.html | 2 +-
content/docs/flink/1.0/documentation/index.html | 2 +-
.../flink/1.0/flink-streaming-activemq/index.html | 2 +-
.../docs/flink/1.0/flink-streaming-akka/index.html | 2 +-
.../flink/1.0/flink-streaming-flume/index.html | 2 +-
.../flink/1.0/flink-streaming-netty/index.html | 2 +-
.../flink/1.0/flink-streaming-redis/index.html | 2 +-
.../docs/flink/current/documentation/index.html | 2 +-
.../current/flink-streaming-activemq/index.html | 2 +-
.../flink/current/flink-streaming-akka/index.html | 2 +-
.../flink/current/flink-streaming-flume/index.html | 2 +-
.../current/flink-streaming-influxdb/index.html | 2 +-
.../current/flink-streaming-influxdb2/index.html | 537 +++++++++++++++++++++
.../flink/current/flink-streaming-kudu/index.html | 2 +-
.../flink/current/flink-streaming-netty/index.html | 2 +-
.../flink/current/flink-streaming-pinot/index.html | 376 +++++++++++++++
.../flink/current/flink-streaming-redis/index.html | 2 +-
content/docs/flink/overview/index.html | 2 +-
content/docs/spark/2.0.0/documentation/index.html | 2 +-
.../2.0.0/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.0.0/spark-streaming-akka/index.html | 2 +-
.../spark/2.0.0/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.0.0/spark-streaming-twitter/index.html | 2 +-
.../spark/2.0.0/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.0.1/documentation/index.html | 2 +-
.../2.0.1/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.0.1/spark-streaming-akka/index.html | 2 +-
.../spark/2.0.1/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.0.1/spark-streaming-twitter/index.html | 2 +-
.../spark/2.0.1/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.0.2/documentation/index.html | 2 +-
.../2.0.2/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.0.2/spark-streaming-akka/index.html | 2 +-
.../spark/2.0.2/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.0.2/spark-streaming-twitter/index.html | 2 +-
.../spark/2.0.2/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.1.0/documentation/index.html | 2 +-
.../2.1.0/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.1.0/spark-streaming-akka/index.html | 2 +-
.../spark/2.1.0/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.1.0/spark-streaming-twitter/index.html | 2 +-
.../spark/2.1.0/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.1.1/documentation/index.html | 2 +-
.../docs/spark/2.1.1/spark-sql-cloudant/index.html | 2 +-
.../2.1.1/spark-sql-streaming-akka/index.html | 2 +-
.../2.1.1/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.1.1/spark-streaming-akka/index.html | 2 +-
.../spark/2.1.1/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.1.1/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.1.1/spark-streaming-twitter/index.html | 2 +-
.../spark/2.1.1/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.1.2/documentation/index.html | 2 +-
.../docs/spark/2.1.2/spark-sql-cloudant/index.html | 2 +-
.../2.1.2/spark-sql-streaming-akka/index.html | 2 +-
.../2.1.2/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.1.2/spark-streaming-akka/index.html | 2 +-
.../spark/2.1.2/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.1.2/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.1.2/spark-streaming-twitter/index.html | 2 +-
.../spark/2.1.2/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.1.3/documentation/index.html | 2 +-
.../docs/spark/2.1.3/spark-sql-cloudant/index.html | 2 +-
.../2.1.3/spark-sql-streaming-akka/index.html | 2 +-
.../2.1.3/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.1.3/spark-streaming-akka/index.html | 2 +-
.../spark/2.1.3/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.1.3/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.1.3/spark-streaming-twitter/index.html | 2 +-
.../spark/2.1.3/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.2.0/documentation/index.html | 2 +-
.../docs/spark/2.2.0/spark-sql-cloudant/index.html | 2 +-
.../2.2.0/spark-sql-streaming-akka/index.html | 2 +-
.../2.2.0/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.2.0/spark-streaming-akka/index.html | 2 +-
.../spark/2.2.0/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.2.0/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.2.0/spark-streaming-twitter/index.html | 2 +-
.../spark/2.2.0/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.2.1/documentation/index.html | 2 +-
.../docs/spark/2.2.1/spark-sql-cloudant/index.html | 2 +-
.../2.2.1/spark-sql-streaming-akka/index.html | 2 +-
.../2.2.1/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.2.1/spark-streaming-akka/index.html | 2 +-
.../spark/2.2.1/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.2.1/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.2.1/spark-streaming-twitter/index.html | 2 +-
.../spark/2.2.1/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.2.2/documentation/index.html | 2 +-
.../docs/spark/2.2.2/spark-sql-cloudant/index.html | 2 +-
.../2.2.2/spark-sql-streaming-akka/index.html | 2 +-
.../2.2.2/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.2.2/spark-streaming-akka/index.html | 2 +-
.../spark/2.2.2/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.2.2/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.2.2/spark-streaming-twitter/index.html | 2 +-
.../spark/2.2.2/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.2.3/documentation/index.html | 2 +-
.../docs/spark/2.2.3/spark-sql-cloudant/index.html | 2 +-
.../2.2.3/spark-sql-streaming-akka/index.html | 2 +-
.../2.2.3/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.2.3/spark-streaming-akka/index.html | 2 +-
.../spark/2.2.3/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.2.3/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.2.3/spark-streaming-twitter/index.html | 2 +-
.../spark/2.2.3/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.3.0/documentation/index.html | 2 +-
.../docs/spark/2.3.0/spark-sql-cloudant/index.html | 2 +-
.../2.3.0/spark-sql-streaming-akka/index.html | 2 +-
.../2.3.0/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.3.0/spark-streaming-akka/index.html | 2 +-
.../spark/2.3.0/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.3.0/spark-streaming-pubnub/index.html | 2 +-
.../spark/2.3.0/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.3.0/spark-streaming-twitter/index.html | 2 +-
.../spark/2.3.0/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.3.1/documentation/index.html | 2 +-
.../docs/spark/2.3.1/spark-sql-cloudant/index.html | 2 +-
.../2.3.1/spark-sql-streaming-akka/index.html | 2 +-
.../2.3.1/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.3.1/spark-streaming-akka/index.html | 2 +-
.../spark/2.3.1/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.3.1/spark-streaming-pubnub/index.html | 2 +-
.../spark/2.3.1/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.3.1/spark-streaming-twitter/index.html | 2 +-
.../spark/2.3.1/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.3.2/documentation/index.html | 2 +-
.../docs/spark/2.3.2/spark-sql-cloudant/index.html | 2 +-
.../2.3.2/spark-sql-streaming-akka/index.html | 2 +-
.../2.3.2/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.3.2/spark-streaming-akka/index.html | 2 +-
.../spark/2.3.2/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.3.2/spark-streaming-pubnub/index.html | 2 +-
.../spark/2.3.2/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.3.2/spark-streaming-twitter/index.html | 2 +-
.../spark/2.3.2/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.3.3/documentation/index.html | 2 +-
.../docs/spark/2.3.3/spark-sql-cloudant/index.html | 2 +-
.../2.3.3/spark-sql-streaming-akka/index.html | 2 +-
.../2.3.3/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.3.3/spark-streaming-akka/index.html | 2 +-
.../spark/2.3.3/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.3.3/spark-streaming-pubnub/index.html | 2 +-
.../spark/2.3.3/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.3.3/spark-streaming-twitter/index.html | 2 +-
.../spark/2.3.3/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.3.4/documentation/index.html | 2 +-
.../docs/spark/2.3.4/spark-sql-cloudant/index.html | 2 +-
.../2.3.4/spark-sql-streaming-akka/index.html | 2 +-
.../2.3.4/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.3.4/spark-streaming-akka/index.html | 2 +-
.../spark/2.3.4/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.3.4/spark-streaming-pubnub/index.html | 2 +-
.../spark/2.3.4/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.3.4/spark-streaming-twitter/index.html | 2 +-
.../spark/2.3.4/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/2.4.0/documentation/index.html | 2 +-
.../docs/spark/2.4.0/spark-sql-cloudant/index.html | 2 +-
.../2.4.0/spark-sql-streaming-akka/index.html | 2 +-
.../2.4.0/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/2.4.0/spark-streaming-akka/index.html | 2 +-
.../spark/2.4.0/spark-streaming-mqtt/index.html | 2 +-
.../spark/2.4.0/spark-streaming-pubnub/index.html | 2 +-
.../spark/2.4.0/spark-streaming-pubsub/index.html | 2 +-
.../spark/2.4.0/spark-streaming-twitter/index.html | 2 +-
.../spark/2.4.0/spark-streaming-zeromq/index.html | 2 +-
.../docs/spark/current/documentation/index.html | 2 +-
.../spark/current/spark-sql-cloudant/index.html | 2 +-
.../current/spark-sql-streaming-akka/index.html | 2 +-
.../current/spark-sql-streaming-mqtt/index.html | 2 +-
.../spark/current/spark-streaming-akka/index.html | 2 +-
.../spark/current/spark-streaming-mqtt/index.html | 2 +-
.../current/spark-streaming-pubnub/index.html | 2 +-
.../current/spark-streaming-pubsub/index.html | 2 +-
.../current/spark-streaming-twitter/index.html | 2 +-
.../current/spark-streaming-zeromq/index.html | 2 +-
content/docs/spark/overview/index.html | 2 +-
content/downloads/flink/index.html | 2 +-
content/downloads/spark/index.html | 2 +-
content/feed.xml | 4 +-
content/history/index.html | 2 +-
content/index.html | 2 +-
content/privacy-policy/index.html | 2 +-
.../releases/spark/2.0.0/release-notes/index.html | 2 +-
.../releases/spark/2.0.1/release-notes/index.html | 2 +-
.../releases/spark/2.0.2/release-notes/index.html | 2 +-
.../releases/spark/2.1.0/release-notes/index.html | 2 +-
.../releases/spark/2.3.3/release-notes/index.html | 2 +-
.../releases/spark/2.3.4/release-notes/index.html | 2 +-
191 files changed, 1105 insertions(+), 192 deletions(-)
diff --git a/content/community-members/index.html b/content/community-members/index.html
index ea294e4..72ffa07 100644
--- a/content/community-members/index.html
+++ b/content/community-members/index.html
@@ -332,8 +332,8 @@
<td>João Boto</td>
<td>eskabetxe</td>
<td><a href="http://github.com/eskabetxe">eskabetxe</a></td>
- <td>Committer</td>
- <td>Independent</td>
+ <td>PMC Member</td>
+ <td>idealista</td>
</tr>
<tr>
@@ -581,7 +581,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/community/index.html b/content/community/index.html
index 3992e44..4862329 100644
--- a/content/community/index.html
+++ b/content/community/index.html
@@ -257,7 +257,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/contributing-extensions/index.html b/content/contributing-extensions/index.html
index c11867f..1825033 100644
--- a/content/contributing-extensions/index.html
+++ b/content/contributing-extensions/index.html
@@ -248,7 +248,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/contributing/index.html b/content/contributing/index.html
index 8762424..ea799c4 100644
--- a/content/contributing/index.html
+++ b/content/contributing/index.html
@@ -389,7 +389,7 @@ if there is sufficient memory.
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/1.0/documentation/index.html b/content/docs/flink/1.0/documentation/index.html
index baee30a..e3cd9a8 100644
--- a/content/docs/flink/1.0/documentation/index.html
+++ b/content/docs/flink/1.0/documentation/index.html
@@ -218,7 +218,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/1.0/flink-streaming-activemq/index.html b/content/docs/flink/1.0/flink-streaming-activemq/index.html
index 368dd37..cbfcef1 100644
--- a/content/docs/flink/1.0/flink-streaming-activemq/index.html
+++ b/content/docs/flink/1.0/flink-streaming-activemq/index.html
@@ -221,7 +221,7 @@ See how to link with them for cluster execution <a href="https://ci.apache.org/p
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/1.0/flink-streaming-akka/index.html b/content/docs/flink/1.0/flink-streaming-akka/index.html
index d76a4f7..6676af0 100644
--- a/content/docs/flink/1.0/flink-streaming-akka/index.html
+++ b/content/docs/flink/1.0/flink-streaming-akka/index.html
@@ -250,7 +250,7 @@ Config config = ConfigFactory.parseFile(new File(configFile));
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/1.0/flink-streaming-flume/index.html b/content/docs/flink/1.0/flink-streaming-flume/index.html
index 1ac3bd1..2c41bef 100644
--- a/content/docs/flink/1.0/flink-streaming-flume/index.html
+++ b/content/docs/flink/1.0/flink-streaming-flume/index.html
@@ -224,7 +224,7 @@ See how to link with them for cluster execution <a href="https://ci.apache.org/p
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/1.0/flink-streaming-netty/index.html b/content/docs/flink/1.0/flink-streaming-netty/index.html
index 2190c56..58bba16 100644
--- a/content/docs/flink/1.0/flink-streaming-netty/index.html
+++ b/content/docs/flink/1.0/flink-streaming-netty/index.html
@@ -273,7 +273,7 @@ callbackUrl: register connector’s ip and port to a <code class="language-pla
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/1.0/flink-streaming-redis/index.html b/content/docs/flink/1.0/flink-streaming-redis/index.html
index 96f597a..c3f83d8 100644
--- a/content/docs/flink/1.0/flink-streaming-redis/index.html
+++ b/content/docs/flink/1.0/flink-streaming-redis/index.html
@@ -351,7 +351,7 @@ stream.addSink(new RedisSink[(String, String)](conf, new RedisExampleMapper))
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/current/documentation/index.html b/content/docs/flink/current/documentation/index.html
index b3d0a5f..b8b4e75 100644
--- a/content/docs/flink/current/documentation/index.html
+++ b/content/docs/flink/current/documentation/index.html
@@ -222,7 +222,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/current/flink-streaming-activemq/index.html b/content/docs/flink/current/flink-streaming-activemq/index.html
index 4f489a9..e814651 100644
--- a/content/docs/flink/current/flink-streaming-activemq/index.html
+++ b/content/docs/flink/current/flink-streaming-activemq/index.html
@@ -221,7 +221,7 @@ See how to link with them for cluster execution <a href="https://ci.apache.org/p
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/current/flink-streaming-akka/index.html b/content/docs/flink/current/flink-streaming-akka/index.html
index e30f503..6f4b542 100644
--- a/content/docs/flink/current/flink-streaming-akka/index.html
+++ b/content/docs/flink/current/flink-streaming-akka/index.html
@@ -250,7 +250,7 @@ Config config = ConfigFactory.parseFile(new File(configFile));
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/current/flink-streaming-flume/index.html b/content/docs/flink/current/flink-streaming-flume/index.html
index b94005d..4b51bcc 100644
--- a/content/docs/flink/current/flink-streaming-flume/index.html
+++ b/content/docs/flink/current/flink-streaming-flume/index.html
@@ -225,7 +225,7 @@ See how to link with them for cluster execution <a href="https://ci.apache.org/p
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/current/flink-streaming-influxdb/index.html b/content/docs/flink/current/flink-streaming-influxdb/index.html
index 6183430..79f0b06 100644
--- a/content/docs/flink/current/flink-streaming-influxdb/index.html
+++ b/content/docs/flink/current/flink-streaming-influxdb/index.html
@@ -235,7 +235,7 @@ dataStream.addSink(new InfluxDBSink(influxDBConfig));
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/current/flink-streaming-influxdb2/index.html b/content/docs/flink/current/flink-streaming-influxdb2/index.html
new file mode 100644
index 0000000..ae1590c
--- /dev/null
+++ b/content/docs/flink/current/flink-streaming-influxdb2/index.html
@@ -0,0 +1,537 @@
+
+
+<!DOCTYPE html>
+<html lang="en">
+ <head>
+ <meta charset="utf-8">
+ <title>Apache Flink Streaming Connector for InfluxDB2</title>
+ <meta name="description" content="Apache Flink Streaming Connector for InfluxDB2">
+ <meta name="author" content="">
+
+ <!-- Enable responsive viewport -->
+ <meta name="viewport" content="width=device-width, initial-scale=1.0">
+
+ <!-- Le HTML5 shim, for IE6-8 support of HTML elements -->
+ <!--[if lt IE 9]>
+ <script src="http://html5shim.googlecode.com/svn/trunk/html5.js"></script>
+ <![endif]-->
+
+ <!-- Le styles -->
+ <link href="/assets/themes/apache-clean/bootstrap/css/bootstrap.css" rel="stylesheet">
+ <link href="/assets/themes/apache-clean/css/style.css?body=1" rel="stylesheet" type="text/css">
+ <link href="/assets/themes/apache-clean/css/syntax.css" rel="stylesheet" type="text/css" media="screen" />
+ <!-- Le fav and touch icons -->
+ <!-- Update these with your own images
+ <link rel="shortcut icon" href="images/favicon.ico">
+ <link rel="apple-touch-icon" href="images/apple-touch-icon.png">
+ <link rel="apple-touch-icon" sizes="72x72" href="images/apple-touch-icon-72x72.png">
+ <link rel="apple-touch-icon" sizes="114x114" href="images/apple-touch-icon-114x114.png">
+ -->
+
+ <!-- make tables sortable by adding class tag "sortable" to table elements -->
+ <script src="http://www.kryogenix.org/code/browser/sorttable/sorttable.js"></script>
+
+
+ </head>
+
+ <body>
+
+
+
+<!-- Navigation -->
+<div id="nav-bar">
+ <nav id="nav-container" class="navbar navbar-inverse " role="navigation">
+ <div class="container">
+ <!-- Brand and toggle get grouped for better mobile display -->
+
+ <div class="navbar-header page-scroll">
+ <button type="button" class="navbar-toggle" data-toggle="collapse" data-target=".navbar-collapse">
+ <span class="sr-only">Toggle navigation</span>
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ </button>
+ <a class="navbar-brand page-scroll" href="/#home">Home</a>
+ </div>
+ <!-- Collect the nav links, forms, and other content for toggling -->
+ <nav class="navbar-collapse collapse" role="navigation">
+ <ul class="nav navbar-nav">
+
+
+
+ <li id="download">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">Download<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="/downloads/spark" target="_self">Bahir Spark Extensions</a></li>
+
+
+ <li><a href="/downloads/flink" target="_self">Bahir Flink Extensions</a></li>
+
+ </ul>
+
+ </li>
+
+
+
+
+ <li id="community">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">Community<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="/community" target="_self">Get Involved</a></li>
+
+
+ <li><a href="/contributing" target="_self">Contributing</a></li>
+
+
+ <li><a href="/contributing-extensions" target="_self">Contributing Extensions</a></li>
+
+
+ <li><a href="https://issues.apache.org/jira/browse/BAHIR" target="_blank">Issue Tracker</a></li>
+
+
+ <li><a href="/community#source-code" target="_self">Source Code</a></li>
+
+
+ <li><a href="/community-members" target="_self">Project Committers</a></li>
+
+ </ul>
+
+ </li>
+
+
+
+
+ <li id="documentation">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">Documentation<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="/docs/spark/overview" target="_self">Bahir Spark Extensions</a></li>
+
+
+ <li><a href="/docs/flink/overview" target="_self">Bahir Flink Extensions</a></li>
+
+ </ul>
+
+ </li>
+
+
+
+
+ <li id="github">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">GitHub<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="https://github.com/apache/bahir" target="_blank">Bahir Spark Extensions</a></li>
+
+
+ <li><a href="https://github.com/apache/bahir-flink" target="_blank">Bahir Flink Extensions</a></li>
+
+
+ <li><a href="https://github.com/apache/bahir-website" target="_blank">Bahir Website</a></li>
+
+ </ul>
+
+ </li>
+
+
+
+
+ <li id="apache">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">Apache<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="http://www.apache.org/foundation/how-it-works.html" target="_blank">Apache Software Foundation</a></li>
+
+
+ <li><a href="http://www.apache.org/licenses/" target="_blank">Apache License</a></li>
+
+
+ <li><a href="http://www.apache.org/foundation/sponsorship" target="_blank">Sponsorship</a></li>
+
+
+ <li><a href="http://www.apache.org/foundation/thanks.html" target="_blank">Thanks</a></li>
+
+
+ <li><a href="/privacy-policy" target="_self">Privacy Policy</a></li>
+
+ </ul>
+
+ </li>
+
+
+ </ul>
+ </nav><!--/.navbar-collapse -->
+ <!-- /.navbar-collapse -->
+ </div>
+ <!-- /.container -->
+ </nav>
+</div>
+
+
+ <div class="container">
+
+
+
+<!--<div class="hero-unit Apache Flink Streaming Connector for InfluxDB2">
+ <h1></h1>
+</div>
+-->
+
+<div class="row">
+ <div class="col-md-12">
+ <!--
+
+-->
+
+<h1 id="flink-influxdb-connector">Flink InfluxDB Connector</h1>
+
+<p>This connector provides a Source that parses the <a href="https://docs.influxdata.com/influxdb/v2.0/reference/syntax/line-protocol/">InfluxDB Line Protocol</a> and a Sink that can write to <a href="https://www.influxdata.com/">InfluxDB</a>. The Source implements the unified <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/sources.html">Data Source API</a>. Our sink implements the unified <a href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-14 [...]
+
+<p>The InfluxDB Source serves as an output target for <a href="https://www.influxdata.com/time-series-platform/telegraf/">Telegraf</a> (and compatible tools). Telegraf pushes data to the source. The process is push-based, so it is a stateless (non-replayable) source.</p>
+
+<p><img src="media/connector-architecture.png" alt="Flink InfluxDB Connector Architecture" /></p>
+
+<h2 id="installation">Installation</h2>
+
+<p>To use this connector, add the following dependency to your project:</p>
+
+<div class="language-xml highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.bahir<span class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-connector-influxdb2_2.12<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.1-SNAPSHOT<span class="nt"></version></span>
+<span class="nt"></dependency></span>
+</code></pre></div></div>
+
+<p>Note that the streaming connectors are not part of the binary distribution of Flink. You need to shade them into your job jar for cluster execution. See how to link with them for cluster execution <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/project-configuration.html#adding-connector-and-library-dependencies">here</a>.</p>
+
+<h2 id="compatibility">Compatibility</h2>
+
+<p>This module is compatible with InfluxDB 2.x and InfluxDB 1.8+. See more information <a href="https://github.com/influxdata/influxdb-client-java#influxdb-client-java">here</a>.</p>
+
+<h2 id="source">Source</h2>
+
+<p>The Source accepts data in the form of the <a href="https://docs.influxdata.com/influxdb/v2.0/reference/syntax/line-protocol/">Line Protocol</a>. One HTTP server per source instance is started. It parses HTTP requests to our Data Point class. That Data Point instance is deserialized by a user-provided implementation of our InfluxDBDataPointDeserializer and sent to the next Flink operator.</p>
+
+<p>When using Telegraf, use its <a href="https://docs.influxdata.com/telegraf/v1.17/plugins/#http">HTTP output plugin</a>:</p>
+
+<div class="language-toml highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nn">[[outputs.http]]</span>
+ <span class="py">url</span> <span class="p">=</span> <span class="s">"http://task-manager:8000/api/v2/write"</span>
+ <span class="py">method</span> <span class="p">=</span> <span class="s">"POST"</span>
+ <span class="py">data_format</span> <span class="p">=</span> <span class="s">"influx"</span>
+</code></pre></div></div>
+
+<p><img src="media/source-architecture.png" alt="Source Architecture" /></p>
+
+<h3 id="usage">Usage</h3>
+
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">InfluxDBSource</span><span class="o"><</span><span class="nc">Long</span><span class="o">></span> <span class="n">influxDBSource</span> <span class="o">=</span> <span class="nc">InfluxBSource</span><span class="o">.</span><span class="na">builder</span><span class="o">()</span>
+ <span class="o">.</span><span class="na">setDeserializer</span><span class="o">(</span><span class="k">new</span> <span class="nc">TestDeserializer</span><span class="o">())</span>
+ <span class="o">.</span><span class="na">build</span><span class="o">()</span>
+
+<span class="c1">// ...</span>
+
+<span class="cm">/**
+ * Implementation of InfluxDBDataPointDeserializer interface
+ * (dataPoint) -----> (element)
+ * test,longValue=1 fieldKey="fieldValue" -----------> 1L
+ * test,longValue=2 fieldKey="fieldValue" -----------> 2L
+ * test,longValue=3 fieldKey="fieldValue" -----------> 3L
+ */</span>
+<span class="kd">class</span> <span class="nc">TestDeserializer</span> <span class="kd">implements</span> <span class="nc">InfluxDBDataPointDeserializer</span><span class="o"><</span><span class="nc">Long</span><span class="o">></span> <span class="o">{</span>
+ <span class="nd">@Override</span>
+ <span class="kd">public</span> <span class="nc">Long</span> <span class="nf">deserialize</span><span class="o">(</span><span class="kd">final</span> <span class="nc">DataPoint</span> <span class="n">dataPoint</span><span class="o">)</span> <span class="o">{</span>
+ <span class="k">return</span> <span class="o">(</span><span class="nc">Long</span><span class="o">)</span> <span class="n">dataPoint</span><span class="o">.</span><span class="na">getField</span><span class="o">(</span><span class="s">"longValue"</span><span class="o">);</span>
+ <span class="o">}</span>
+<span class="o">}</span>
+</code></pre></div></div>
+
+<h3 id="options">Options</h3>
+
+<table>
+ <thead>
+ <tr>
+ <th>Option</th>
+ <th>Description</th>
+ <th style="text-align: center">Default Value</th>
+ </tr>
+ </thead>
+ <tbody>
+ <tr>
+ <td>ENQUEUE_WAIT_TIME</td>
+ <td>The time out in seconds for enqueuing an HTTP request to the queue.</td>
+ <td style="text-align: center">5</td>
+ </tr>
+ <tr>
+ <td>INGEST_QUEUE_CAPACITY</td>
+ <td>Size of queue that buffers HTTP requests data points before fetching.</td>
+ <td style="text-align: center">1000</td>
+ </tr>
+ <tr>
+ <td>MAXIMUM_LINES_PER_REQUEST</td>
+ <td>The maximum number of lines that should be parsed per HTTP request.</td>
+ <td style="text-align: center">10000</td>
+ </tr>
+ <tr>
+ <td>PORT</td>
+ <td>TCP port on which the source’s HTTP server is running on.</td>
+ <td style="text-align: center">8000</td>
+ </tr>
+ </tbody>
+</table>
+
+<h3 id="supported-data-types-in-field-set">Supported Data Types in Field Set</h3>
+
+<table>
+ <thead>
+ <tr>
+ <th>Field Set</th>
+ <th style="text-align: center">Support</th>
+ </tr>
+ </thead>
+ <tbody>
+ <tr>
+ <td>Float</td>
+ <td style="text-align: center">✅</td>
+ </tr>
+ <tr>
+ <td>Integer</td>
+ <td style="text-align: center">✅</td>
+ </tr>
+ <tr>
+ <td>UInteger</td>
+ <td style="text-align: center">❌</td>
+ </tr>
+ <tr>
+ <td>String</td>
+ <td style="text-align: center">✅</td>
+ </tr>
+ <tr>
+ <td>Boolean</td>
+ <td style="text-align: center">✅</td>
+ </tr>
+ </tbody>
+</table>
+
+<p>See InfluxDB field set value <a href="https://docs.influxdata.com/influxdb/cloud/reference/syntax/line-protocol/#field-set">data type</a>.
+The parsing limitation is related to the Apache Druid project. For more information see this <a href="https://github.com/apache/druid/issues/10993">issue</a></p>
+
+<h2 id="sink">Sink</h2>
+
+<p>The Sink writes data points to InfluxDB using the <a href="https://github.com/influxdata/influxdb-client-java">InfluxDB Java Client</a>. You provide the connection information (URL, username, password, bucket, and organization) and an implementation of <code class="language-plaintext highlighter-rouge">InfluxDBSchemaSerializer<IN></code> generic interface. The implementation of the interface overrides the <code class="language-plaintext highlighter-rouge">serialize(IN element, C [...]
+
+<p>It is possible to write multiple data points to InfluxDB simultaneously by separating each point with a new line. Batching data points in this manner results in much higher performance. The batch size can be set through the <code class="language-plaintext highlighter-rouge">WRITE_BUFFER_SIZE</code> option. By default, the buffer size is set to 1000 and can be changed to any value using the <code class="language-plaintext highlighter-rouge">setWriteBufferSize(final int bufferSize)</cod [...]
+
+<p>It is possible to write checkpoint data points to InfluxDB whenever Flink sets a checkpoint. To enable this functionality, you need to set the <code class="language-plaintext highlighter-rouge">WRITE_DATA_POINT_CHECKPOINT</code> flag to true (default is false). The checkpoint data point looks as follow:</p>
+<div class="language-text highlighter-rouge"><div class="highlight"><pre class="highlight"><code>checkpoint checkpoint=flink <timestamp>
+</code></pre></div></div>
+<p>The timestamp refers to the latest element that Flink serializes.</p>
+
+<h3 id="usage-1">Usage</h3>
+
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="c1">// The InfluxDB Sink uses the build pattern to create a Sink object</span>
+<span class="nc">InfluxDBSink</span><span class="o"><</span><span class="nc">Long</span><span class="o">></span> <span class="n">influxDBSink</span> <span class="o">=</span> <span class="nc">InfluxDBSink</span><span class="o">.</span><span class="na">builder</span><span class="o">()</span>
+ <span class="o">.</span><span class="na">setInfluxDBSchemaSerializer</span><span class="o">(</span><span class="k">new</span> <span class="nc">TestSerializer</span><span class="o">())</span>
+ <span class="o">.</span><span class="na">setInfluxDBUrl</span><span class="o">(</span><span class="n">getUrl</span><span class="o">())</span> <span class="c1">// http://localhost:8086</span>
+ <span class="o">.</span><span class="na">setInfluxDBUsername</span><span class="o">(</span><span class="n">getUsername</span><span class="o">())</span> <span class="c1">// admin</span>
+ <span class="o">.</span><span class="na">setInfluxDBPassword</span><span class="o">(</span><span class="n">getPassword</span><span class="o">())</span> <span class="c1">// admin</span>
+ <span class="o">.</span><span class="na">setInfluxDBBucket</span><span class="o">(</span><span class="n">getBucket</span><span class="o">())</span> <span class="c1">// default</span>
+ <span class="o">.</span><span class="na">setInfluxDBOrganization</span><span class="o">(</span><span class="n">getOrg</span><span class="o">())</span> <span class="c1">// influxdata</span>
+ <span class="o">.</span><span class="na">build</span><span class="o">();</span>
+
+<span class="c1">// ...</span>
+
+<span class="cm">/**
+ * Implementation of InfluxDBSchemaSerializer interface
+ * (element) -----> (dataPoint)
+ * 1L -----------> test,longValue=1 fieldKey="fieldValue"
+ * 2L -----------> test,longValue=2 fieldKey="fieldValue"
+ * 3L -----------> test,longValue=3 fieldKey="fieldValue"
+ */</span>
+<span class="kd">class</span> <span class="nc">TestSerializer</span> <span class="kd">implements</span> <span class="nc">InfluxDBSchemaSerializer</span><span class="o"><</span><span class="nc">Long</span><span class="o">></span> <span class="o">{</span>
+
+ <span class="nd">@Override</span>
+ <span class="kd">public</span> <span class="nc">Point</span> <span class="nf">serialize</span><span class="o">(</span><span class="nc">Long</span> <span class="n">element</span><span class="o">,</span> <span class="nc">Context</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">final</span> <span class="nc">Point</span> <span class="n">dataPoint</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">Point</span><span class="o">(</span><span class="s">"test"</span><span class="o">);</span>
+ <span class="n">dataPoint</span><span class="o">.</span><span class="na">addTag</span><span class="o">(</span><span class="s">"longValue"</span><span class="o">,</span> <span class="nc">String</span><span class="o">.</span><span class="na">valueOf</span><span class="o">(</span><span class="n">element</span><span class="o">));</span>
+ <span class="n">dataPoint</span><span class="o">.</span><span class="na">addField</span><span class="o">(</span><span class="s">"fieldKey"</span><span class="o">,</span> <span class="s">"fieldValue"</span><span class="o">);</span>
+ <span class="k">return</span> <span class="n">dataPoint</span><span class="o">;</span>
+ <span class="o">}</span>
+<span class="o">}</span>
+</code></pre></div></div>
+
+<h3 id="options-1">Options</h3>
+
+<table>
+ <thead>
+ <tr>
+ <th>Option</th>
+ <th>Description</th>
+ <th style="text-align: center">Default Value</th>
+ </tr>
+ </thead>
+ <tbody>
+ <tr>
+ <td>WRITE_DATA_POINT_CHECKPOINT</td>
+ <td>Determines if the checkpoint data point should be written to InfluxDB or not.</td>
+ <td style="text-align: center">false</td>
+ </tr>
+ <tr>
+ <td>WRITE_BUFFER_SIZE</td>
+ <td>Number of elements to buffer the data before writing them to InfluxDB.</td>
+ <td style="text-align: center">1000</td>
+ </tr>
+ <tr>
+ <td>INFLUXDB_URL</td>
+ <td>InfluxDB Connection URL.</td>
+ <td style="text-align: center">❌</td>
+ </tr>
+ <tr>
+ <td>INFLUXDB_USERNAME</td>
+ <td>InfluxDB username.</td>
+ <td style="text-align: center">❌</td>
+ </tr>
+ <tr>
+ <td>INFLUXDB_PASSWORD</td>
+ <td>InfluxDB password.</td>
+ <td style="text-align: center">❌</td>
+ </tr>
+ <tr>
+ <td>INFLUXDB_BUCKET</td>
+ <td>InfluxDB bucket.</td>
+ <td style="text-align: center">❌</td>
+ </tr>
+ <tr>
+ <td>INFLUXDB_ORGANIZATION</td>
+ <td>InfluxDB organization.</td>
+ <td style="text-align: center">❌</td>
+ </tr>
+ </tbody>
+</table>
+
+<h2 id="building-the-connector">Building the connector</h2>
+
+<p>The connector can be built by using maven:</p>
+
+<div class="language-bash highlighter-rouge"><div class="highlight"><pre class="highlight"><code>mvn clean <span class="nb">install</span> <span class="nt">-DskipTests</span> <span class="nt">-pl</span> flink-connector-influxdb2
+</code></pre></div></div>
+
+<h2 id="benchmarks">Benchmarks</h2>
+
+<p>Some basic benchmarks were conducted.</p>
+
+<h3 id="source-1">Source</h3>
+<p>A data generator that sends line protocol in form of HTTP requests to an REST endpoint was used for the source benchmarks.
+Throughput and latency was measured for a direct connection between the data generator and the InfluxDB source.
+A setup including Telegraf was used to benchmark the latency in a more realistic setup.</p>
+
+<h3 id="sink-1">Sink</h3>
+<p>The from sequence source was used to generate data for the sink benchmark.
+Throughput was measured without any other Flink operators, whereas the latency was measured by adding a timestamp to the event using a map operator before the sink.
+This timestamp was then compared to the insertion timestamp set by InfluxDB itself.</p>
+
+<h3 id="visualization">Visualization</h3>
+
+<p>The results of these benchmarks are visualized <a href="https://docs.google.com/presentation/d/1apd_wys0OzaiifAisABFg4B7HCydbkZXpN0OFd6cjEg/edit?usp=sharing">here</a>.</p>
+
+<h2 id="usage-and-deployment-example">Usage and Deployment Example</h2>
+
+<p>See <a href="https://github.com/Shark/flink-connector-influxdb-example"><code class="language-plaintext highlighter-rouge">Shark/flink-connector-influxdb-example</code></a> for an example showing you how to use and deploy the InfluxDB source and sink connectors in a Flink application on a Kubernetes cluster.</p>
+
+<h2 id="future-work">Future Work</h2>
+
+<ul>
+ <li>[Source] Dynamic (unprivileged) ports for HTTP server</li>
+ <li>[Source] Integration with Kubernetes service discovery in conjunction with dynamic ports</li>
+ <li>[Source] Use multi-threaded HTTP server</li>
+ <li>[Sink] Flush write buffer after an inactivity timeout</li>
+</ul>
+
+<h2 id="contributors">Contributors</h2>
+
+<!-- ALL-CONTRIBUTORS-LIST:START - Do not remove or modify this section -->
+<table>
+ <tr class="noBorder">
+ <td class="noBorder" align="center">
+ <a href="https://github.com/1p4pk"><img class="roundImg"
+ src="https://avatars.githubusercontent.com/u/32157576?v=4?s=100"width="100px;"/><br /><sub><b>Leon Papke</b></sub>
+ </a>
+ </td>
+ <td class="noBorder" align="center">
+ <a href="https://github.com/raminqaf"><img class="roundImg" src="https://avatars.githubusercontent.com/u/20357405?v=4?s=100" width="100px;" /><br /><sub><b>Ramin Gharib</b></sub>
+ </a>
+ </td>
+ <td class="noBorder" align="center">
+ <a href="https://github.com/Shark"><img class="roundImg" src="https://avatars.githubusercontent.com/u/53632?v=4?s=100" width="100px;" alt="" /> <br /><sub><b>Felix Seidel</b></sub></a>
+ </td>
+ </tr>
+</table>
+<!-- ALL-CONTRIBUTORS-LIST:END -->
+
+<p>This project follows the <a href="https://github.com/all-contributors/all-contributors">all-contributors</a> specification. Contributions of any kind welcome!</p>
+
+ </div>
+</div>
+
+
+
+ <hr>
+
+ <!-- <p>© 2021 </p>-->
+ <footer class="site-footer">
+ <div class="wrapper">
+ <div class="footer-col-wrapper">
+
+ <div style="text-align:center;">
+
+ <div>
+ Copyright © 2016-<script>document.write(new Date().getFullYear());</script> <a href="http://www.apache.org">The Apache Software Foundation</a>.
+ Licensed under the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache License, Version 2.0</a>.
+ <br>
+
+ Apache and the Apache Feather logo are trademarks of The Apache Software Foundation.
+
+ </div>
+ </div>
+ </div>
+ </div>
+</footer>
+
+ </div>
+
+
+
+
+ <script type="text/javascript">
+ (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
+ (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
+ m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
+ })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
+
+ ga('create', 'UA-79140859-1', 'bahir.apache.org');
+ ga('require', 'linkid', 'linkid.js');
+ ga('send', 'pageview');
+
+</script>
+
+
+
+ <script src="/assets/themes/apache-clean/jquery/jquery-2.1.1.min.js"></script>
+
+ <script src="/assets/themes/apache-clean/bootstrap/js/bootstrap.min.js"></script>
+
+
+ </body>
+</html>
+
diff --git a/content/docs/flink/current/flink-streaming-kudu/index.html b/content/docs/flink/current/flink-streaming-kudu/index.html
index 0bfd75b..760f16c 100644
--- a/content/docs/flink/current/flink-streaming-kudu/index.html
+++ b/content/docs/flink/current/flink-streaming-kudu/index.html
@@ -500,7 +500,7 @@ To solve this problem go to <em>System Preferences/Sharing</em> and enable Remot
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/current/flink-streaming-netty/index.html b/content/docs/flink/current/flink-streaming-netty/index.html
index 3091815..103848d 100644
--- a/content/docs/flink/current/flink-streaming-netty/index.html
+++ b/content/docs/flink/current/flink-streaming-netty/index.html
@@ -273,7 +273,7 @@ callbackUrl: register connector’s ip and port to a <code class="language-pla
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/current/flink-streaming-pinot/index.html b/content/docs/flink/current/flink-streaming-pinot/index.html
new file mode 100644
index 0000000..374b60d
--- /dev/null
+++ b/content/docs/flink/current/flink-streaming-pinot/index.html
@@ -0,0 +1,376 @@
+
+
+<!DOCTYPE html>
+<html lang="en">
+ <head>
+ <meta charset="utf-8">
+ <title>Apache Flink Streaming Connector for Pinot</title>
+ <meta name="description" content="Apache Flink Streaming Connector for Pinot">
+ <meta name="author" content="">
+
+ <!-- Enable responsive viewport -->
+ <meta name="viewport" content="width=device-width, initial-scale=1.0">
+
+ <!-- Le HTML5 shim, for IE6-8 support of HTML elements -->
+ <!--[if lt IE 9]>
+ <script src="http://html5shim.googlecode.com/svn/trunk/html5.js"></script>
+ <![endif]-->
+
+ <!-- Le styles -->
+ <link href="/assets/themes/apache-clean/bootstrap/css/bootstrap.css" rel="stylesheet">
+ <link href="/assets/themes/apache-clean/css/style.css?body=1" rel="stylesheet" type="text/css">
+ <link href="/assets/themes/apache-clean/css/syntax.css" rel="stylesheet" type="text/css" media="screen" />
+ <!-- Le fav and touch icons -->
+ <!-- Update these with your own images
+ <link rel="shortcut icon" href="images/favicon.ico">
+ <link rel="apple-touch-icon" href="images/apple-touch-icon.png">
+ <link rel="apple-touch-icon" sizes="72x72" href="images/apple-touch-icon-72x72.png">
+ <link rel="apple-touch-icon" sizes="114x114" href="images/apple-touch-icon-114x114.png">
+ -->
+
+ <!-- make tables sortable by adding class tag "sortable" to table elements -->
+ <script src="http://www.kryogenix.org/code/browser/sorttable/sorttable.js"></script>
+
+
+ </head>
+
+ <body>
+
+
+
+<!-- Navigation -->
+<div id="nav-bar">
+ <nav id="nav-container" class="navbar navbar-inverse " role="navigation">
+ <div class="container">
+ <!-- Brand and toggle get grouped for better mobile display -->
+
+ <div class="navbar-header page-scroll">
+ <button type="button" class="navbar-toggle" data-toggle="collapse" data-target=".navbar-collapse">
+ <span class="sr-only">Toggle navigation</span>
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ </button>
+ <a class="navbar-brand page-scroll" href="/#home">Home</a>
+ </div>
+ <!-- Collect the nav links, forms, and other content for toggling -->
+ <nav class="navbar-collapse collapse" role="navigation">
+ <ul class="nav navbar-nav">
+
+
+
+ <li id="download">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">Download<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="/downloads/spark" target="_self">Bahir Spark Extensions</a></li>
+
+
+ <li><a href="/downloads/flink" target="_self">Bahir Flink Extensions</a></li>
+
+ </ul>
+
+ </li>
+
+
+
+
+ <li id="community">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">Community<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="/community" target="_self">Get Involved</a></li>
+
+
+ <li><a href="/contributing" target="_self">Contributing</a></li>
+
+
+ <li><a href="/contributing-extensions" target="_self">Contributing Extensions</a></li>
+
+
+ <li><a href="https://issues.apache.org/jira/browse/BAHIR" target="_blank">Issue Tracker</a></li>
+
+
+ <li><a href="/community#source-code" target="_self">Source Code</a></li>
+
+
+ <li><a href="/community-members" target="_self">Project Committers</a></li>
+
+ </ul>
+
+ </li>
+
+
+
+
+ <li id="documentation">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">Documentation<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="/docs/spark/overview" target="_self">Bahir Spark Extensions</a></li>
+
+
+ <li><a href="/docs/flink/overview" target="_self">Bahir Flink Extensions</a></li>
+
+ </ul>
+
+ </li>
+
+
+
+
+ <li id="github">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">GitHub<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="https://github.com/apache/bahir" target="_blank">Bahir Spark Extensions</a></li>
+
+
+ <li><a href="https://github.com/apache/bahir-flink" target="_blank">Bahir Flink Extensions</a></li>
+
+
+ <li><a href="https://github.com/apache/bahir-website" target="_blank">Bahir Website</a></li>
+
+ </ul>
+
+ </li>
+
+
+
+
+ <li id="apache">
+
+ <a href="#" data-toggle="dropdown" class="dropdown-toggle">Apache<b class="caret"></b></a>
+ <ul class="dropdown-menu dropdown-left">
+
+
+ <li><a href="http://www.apache.org/foundation/how-it-works.html" target="_blank">Apache Software Foundation</a></li>
+
+
+ <li><a href="http://www.apache.org/licenses/" target="_blank">Apache License</a></li>
+
+
+ <li><a href="http://www.apache.org/foundation/sponsorship" target="_blank">Sponsorship</a></li>
+
+
+ <li><a href="http://www.apache.org/foundation/thanks.html" target="_blank">Thanks</a></li>
+
+
+ <li><a href="/privacy-policy" target="_self">Privacy Policy</a></li>
+
+ </ul>
+
+ </li>
+
+
+ </ul>
+ </nav><!--/.navbar-collapse -->
+ <!-- /.navbar-collapse -->
+ </div>
+ <!-- /.container -->
+ </nav>
+</div>
+
+
+ <div class="container">
+
+
+
+<!--<div class="hero-unit Apache Flink Streaming Connector for Pinot">
+ <h1></h1>
+</div>
+-->
+
+<div class="row">
+ <div class="col-md-12">
+ <!--
+
+-->
+
+<h1 id="flink-pinot-connector">Flink Pinot Connector</h1>
+
+<p>This connector provides a sink to <a href="http://pinot.apache.org/">Apache Pinot</a>™.<br />
+To use this connector, add the following dependency to your project:</p>
+
+<div class="language-plaintext highlighter-rouge"><div class="highlight"><pre class="highlight"><code><dependency>
+ <groupId>org.apache.bahir</groupId>
+ <artifactId>flink-connector-pinot_2.11</artifactId>
+ <version>1.1-SNAPSHOT</version>
+</dependency>
+</code></pre></div></div>
+
+<p><em>Version Compatibility</em>: This module is compatible with Pinot 0.6.0.</p>
+
+<p>Note that the streaming connectors are not part of the binary distribution of Flink. You need to link them into your job jar for cluster execution.
+See how to link with them for cluster execution <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/linking.html">here</a>.</p>
+
+<p>The sink class is called <code class="language-plaintext highlighter-rouge">PinotSink</code>.</p>
+
+<h2 id="architecture">Architecture</h2>
+<p>The Pinot sink stores elements from upstream Flink tasks in an Apache Pinot table.
+We support two execution modes</p>
+<ul>
+ <li><code class="language-plaintext highlighter-rouge">RuntimeExecutionMode.BATCH</code></li>
+ <li><code class="language-plaintext highlighter-rouge">RuntimeExecutionMode.STREAMING</code> which requires checkpointing to be enabled.</li>
+</ul>
+
+<h3 id="pinotsinkwriter">PinotSinkWriter</h3>
+<p>Whenever the sink receives elements from upstream tasks, they are received by an instance of the PinotSinkWriter.
+The <code class="language-plaintext highlighter-rouge">PinotSinkWriter</code> holds a list of <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code>s where each <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code> is capable of storing <code class="language-plaintext highlighter-rouge">maxRowsPerSegment</code> elements.
+Whenever the maximum number of elements to hold is not yet reached the <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code> is considered to be active.
+Once the maximum number of elements to hold was reached, an active <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code> gets inactivated and a new empty <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code> is created.</p>
+
+<p><img height="225" alt="PinotSinkWriter" src="docs/images/PinotSinkWriter.png" /></p>
+
+<p>Thus, there is always one active <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code> that new incoming elements will go to.
+Over time, the list of <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code> per <code class="language-plaintext highlighter-rouge">PinotSinkWriter</code> increases up to the point where a checkpoint is created.</p>
+
+<p><strong>Checkpointing</strong><br />
+On checkpoint creation <code class="language-plaintext highlighter-rouge">PinotSinkWriter.prepareCommit</code> gets called by the Flink environment.
+This triggers the creation of <code class="language-plaintext highlighter-rouge">PinotSinkCommittable</code>s where each inactive <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code> creates exactly one <code class="language-plaintext highlighter-rouge">PinotSinkCommittable</code>.</p>
+
+<p><img height="250" alt="PinotSinkWriter prepareCommit" src="docs/images/PinotSinkWriter_prepareCommit.png" /></p>
+
+<p>In order to create a <code class="language-plaintext highlighter-rouge">PinotSinkCommittable</code>, a file containing a <code class="language-plaintext highlighter-rouge">PinotWriterSegment</code>’s elements is on the shared filesystem defined via <code class="language-plaintext highlighter-rouge">FileSystemAdapter</code>.
+The file contains a list of elements in JSON format. The serialization is done via <code class="language-plaintext highlighter-rouge">JSONSerializer</code>.
+A <code class="language-plaintext highlighter-rouge">PinotSinkCommittables</code> then holds the path to the data file on the shared filesystem as well as the minimum and maximum timestamp of all contained elements (extracted via <code class="language-plaintext highlighter-rouge">EventTimeExtractor</code>).</p>
+
+<h3 id="pinotsinkglobalcommitter">PinotSinkGlobalCommitter</h3>
+<p>In order to be able to follow the guidelines for Pinot segment naming, we need to include the minimum and maximum timestamp of an element in the metadata of a segment and in its name.
+The minimum and maximum timestamp of all elements between two checkpoints is determined at a parallelism of 1 in the <code class="language-plaintext highlighter-rouge">PinotSinkGlobalCommitter</code>.
+This procedure allows recovering from failure by deleting previously uploaded segments which prevents having duplicate segments in the Pinot table.</p>
+
+<p><img height="250" alt="PinotSinkGlobalCommitter combine" src="docs/images/PinotSinkGlobalCommitter_combine.png" /></p>
+
+<p>After all <code class="language-plaintext highlighter-rouge">PinotSinkWriter</code> subtasks emitted their <code class="language-plaintext highlighter-rouge">PinotSinkCommittable</code>s, they are sent to the <code class="language-plaintext highlighter-rouge">PinotSinkGlobalCommitter</code> which first combines all collected <code class="language-plaintext highlighter-rouge">PinotSinkCommittable</code>s into a single <code class="language-plaintext highlighter-rouge">PinotSinkGlobalCo [...]
+Therefore, the minimum and maximum timestamps of all collected <code class="language-plaintext highlighter-rouge">PinotSinkCommittable</code>s is determined.
+Moreover, the <code class="language-plaintext highlighter-rouge">PinotSinkGlobalCommittable</code> holds references to all data files from the <code class="language-plaintext highlighter-rouge">PinotSinkCommittable</code>s.</p>
+
+<p>When finally committing a <code class="language-plaintext highlighter-rouge">PinotSinkGlobalCommittable</code> the following procedure is executed:</p>
+<ul>
+ <li>Read all data files from the shared filesystem (using <code class="language-plaintext highlighter-rouge">FileSystemAdapter</code>).</li>
+ <li>Generate Pinot segment names using <code class="language-plaintext highlighter-rouge">PinotSinkSegmentNameGenerator</code>.</li>
+ <li>Create Pinot segments with minimum and maximum timestamps (stored in <code class="language-plaintext highlighter-rouge">PinotSinkGlobalCommittable</code>) and previously generated segment assigned.</li>
+ <li>Upload Pinot segments to the Pinot controller</li>
+</ul>
+
+<h2 id="delivery-guarantees">Delivery Guarantees</h2>
+<p>Resulting from the above described architecture the <code class="language-plaintext highlighter-rouge">PinotSink</code> provides an at-least-once delivery guarantee.
+While the failure recovery mechanism ensures that duplicate segments are prevented, there might be temporary inconsistencies in the Pinot table which can result in downstream tasks receiving an element multiple times.</p>
+
+<h2 id="options">Options</h2>
+<p>| Option | Description |
+| ———————- | ——————————————————————————– |
+| <code class="language-plaintext highlighter-rouge">pinotControllerHost</code> | Host of the Pinot controller |
+| <code class="language-plaintext highlighter-rouge">pinotControllerPort</code> | Port of the Pinot controller |
+| <code class="language-plaintext highlighter-rouge">tableName</code> | Target Pinot table’s name |
+| <code class="language-plaintext highlighter-rouge">maxRowsPerSegment</code> | Maximum number of rows to be stored within a Pinot segment |
+| <code class="language-plaintext highlighter-rouge">tempDirPrefix</code> | Prefix for temp directories used |
+| <code class="language-plaintext highlighter-rouge">jsonSerializer</code> | Serializer used to convert elements to JSON |
+| <code class="language-plaintext highlighter-rouge">eventTimeExtractor</code> | Defines the way event times are extracted from received objects |
+| <code class="language-plaintext highlighter-rouge">segmentNameGenerator</code> | Pinot segment name generator |
+| <code class="language-plaintext highlighter-rouge">fsAdapter</code> | Filesystem adapter used to save files for sharing files across nodes |
+| <code class="language-plaintext highlighter-rouge">numCommitThreads</code> | Number of threads used in the <code class="language-plaintext highlighter-rouge">PinotSinkGlobalCommitter</code> for committing segments |</p>
+
+<h2 id="usage">Usage</h2>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">StreamExecutionEnvironment</span> <span class="n">env</span> <span class="o">=</span> <span class="o">...</span>
+<span class="c1">// Checkpointing needs to be enabled when executing in STREAMING mode</span>
+ <span class="n">env</span><span class="o">.</span><span class="na">enableCheckpointing</span><span class="o">(</span><span class="kt">long</span> <span class="n">interval</span><span class="o">);</span>
+
+ <span class="nc">DataStream</span><span class="o"><</span><span class="nc">PinotRow</span><span class="o">></span> <span class="n">dataStream</span> <span class="o">=</span> <span class="o">...</span>
+ <span class="nc">PinotSink</span> <span class="n">pinotSink</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">PinotSink</span><span class="o">.</span><span class="na">Builder</span><span class="o"><</span><span class="nc">PinotRow</span><span class="o">>(</span><span class="nc">String</span> <span class="n">pinotControllerHost</span><span class="o">,</span> <span class="nc">String</span> <span class="n">pinotControllerPort</span><span class="o">,</ [...]
+
+ <span class="c1">// Serializes a PinotRow to JSON format</span>
+ <span class="o">.</span><span class="na">withJsonSerializer</span><span class="o">(</span><span class="nc">JsonSerializer</span><span class="o"><</span><span class="nc">PinotRow</span><span class="o">></span> <span class="n">jsonSerializer</span><span class="o">)</span>
+
+ <span class="c1">// Extracts the timestamp from a PinotRow</span>
+ <span class="o">.</span><span class="na">withEventTimeExtractor</span><span class="o">(</span><span class="nc">EventTimeExtractor</span><span class="o"><</span><span class="no">IN</span><span class="o">></span> <span class="n">eventTimeExtractor</span><span class="o">)</span>
+
+ <span class="c1">// Defines the segment name generation via the predefined SimpleSegmentNameGenerator</span>
+ <span class="c1">// Exemplary segment name: tableName_minTimestamp_maxTimestamp_segmentNamePostfix_0</span>
+ <span class="o">.</span><span class="na">withSimpleSegmentNameGenerator</span><span class="o">(</span><span class="nc">String</span> <span class="n">tableName</span><span class="o">,</span> <span class="nc">String</span> <span class="n">segmentNamePostfix</span><span class="o">)</span>
+
+ <span class="c1">// Use a custom segment name generator if the SimpleSegmentNameGenerator does not work for your use case</span>
+ <span class="o">.</span><span class="na">withSegmentNameGenerator</span><span class="o">(</span><span class="nc">SegmentNameGenerator</span> <span class="n">segmentNameGenerator</span><span class="o">)</span>
+
+ <span class="c1">// Use a custom filesystem adapter. </span>
+ <span class="c1">// CAUTION: Make sure all nodes your Flink app runs on can access the shared filesystem via the provided FileSystemAdapter</span>
+ <span class="o">.</span><span class="na">withFileSystemAdapter</span><span class="o">(</span><span class="nc">FileSystemAdapter</span> <span class="n">fsAdapter</span><span class="o">)</span>
+
+ <span class="c1">// Defines the size of the Pinot segments</span>
+ <span class="o">.</span><span class="na">withMaxRowsPerSegment</span><span class="o">(</span><span class="kt">int</span> <span class="n">maxRowsPerSegment</span><span class="o">)</span>
+
+ <span class="c1">// Prefix within the local filesystem's temp directory used for storing intermediate files</span>
+ <span class="o">.</span><span class="na">withTempDirectoryPrefix</span><span class="o">(</span><span class="nc">String</span> <span class="n">tempDirPrefix</span><span class="o">)</span>
+
+ <span class="c1">// Number of threads used in the `PinotSinkGlobalCommitter` to commit a batch of segments</span>
+ <span class="c1">// Optional - Default is 4</span>
+ <span class="o">.</span><span class="na">withNumCommitThreads</span><span class="o">(</span><span class="kt">int</span> <span class="n">numCommitThreads</span><span class="o">)</span>
+
+ <span class="c1">// Builds the PinotSink</span>
+ <span class="o">.</span><span class="na">build</span><span class="o">()</span>
+ <span class="n">dataStream</span><span class="o">.</span><span class="na">addSink</span><span class="o">(</span><span class="n">pinotSink</span><span class="o">);</span>
+</code></pre></div></div>
+
+ </div>
+</div>
+
+
+
+ <hr>
+
+ <!-- <p>© 2021 </p>-->
+ <footer class="site-footer">
+ <div class="wrapper">
+ <div class="footer-col-wrapper">
+
+ <div style="text-align:center;">
+
+ <div>
+ Copyright © 2016-<script>document.write(new Date().getFullYear());</script> <a href="http://www.apache.org">The Apache Software Foundation</a>.
+ Licensed under the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache License, Version 2.0</a>.
+ <br>
+
+ Apache and the Apache Feather logo are trademarks of The Apache Software Foundation.
+
+ </div>
+ </div>
+ </div>
+ </div>
+</footer>
+
+ </div>
+
+
+
+
+ <script type="text/javascript">
+ (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
+ (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
+ m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
+ })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
+
+ ga('create', 'UA-79140859-1', 'bahir.apache.org');
+ ga('require', 'linkid', 'linkid.js');
+ ga('send', 'pageview');
+
+</script>
+
+
+
+ <script src="/assets/themes/apache-clean/jquery/jquery-2.1.1.min.js"></script>
+
+ <script src="/assets/themes/apache-clean/bootstrap/js/bootstrap.min.js"></script>
+
+
+ </body>
+</html>
+
diff --git a/content/docs/flink/current/flink-streaming-redis/index.html b/content/docs/flink/current/flink-streaming-redis/index.html
index 1a9feb9..1577c28 100644
--- a/content/docs/flink/current/flink-streaming-redis/index.html
+++ b/content/docs/flink/current/flink-streaming-redis/index.html
@@ -351,7 +351,7 @@ stream.addSink(new RedisSink[(String, String)](conf, new RedisExampleMapper))
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/flink/overview/index.html b/content/docs/flink/overview/index.html
index a1ff0c1..7e8e61a 100644
--- a/content/docs/flink/overview/index.html
+++ b/content/docs/flink/overview/index.html
@@ -209,7 +209,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.0/documentation/index.html b/content/docs/spark/2.0.0/documentation/index.html
index 74a3c8c..b0cad1e 100644
--- a/content/docs/spark/2.0.0/documentation/index.html
+++ b/content/docs/spark/2.0.0/documentation/index.html
@@ -222,7 +222,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.0/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.0.0/spark-sql-streaming-mqtt/index.html
index 73acc0f..bc9f6c5 100644
--- a/content/docs/spark/2.0.0/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.0.0/spark-sql-streaming-mqtt/index.html
@@ -314,7 +314,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.0/spark-streaming-akka/index.html b/content/docs/spark/2.0.0/spark-streaming-akka/index.html
index e31f4f5..b034ec1 100644
--- a/content/docs/spark/2.0.0/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.0.0/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.0/spark-streaming-mqtt/index.html b/content/docs/spark/2.0.0/spark-streaming-mqtt/index.html
index c88e6d7..c60398f 100644
--- a/content/docs/spark/2.0.0/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.0.0/spark-streaming-mqtt/index.html
@@ -251,7 +251,7 @@ this actor can be configured to handle failures, etc.</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.0/spark-streaming-twitter/index.html b/content/docs/spark/2.0.0/spark-streaming-twitter/index.html
index f039889..956cfc2 100644
--- a/content/docs/spark/2.0.0/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.0.0/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.0/spark-streaming-zeromq/index.html b/content/docs/spark/2.0.0/spark-streaming-zeromq/index.html
index 1131cc5..227fd20 100644
--- a/content/docs/spark/2.0.0/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.0.0/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.1/documentation/index.html b/content/docs/spark/2.0.1/documentation/index.html
index 4e41a15..5a679db 100644
--- a/content/docs/spark/2.0.1/documentation/index.html
+++ b/content/docs/spark/2.0.1/documentation/index.html
@@ -222,7 +222,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.1/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.0.1/spark-sql-streaming-mqtt/index.html
index 59d77a3..509578f 100644
--- a/content/docs/spark/2.0.1/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.0.1/spark-sql-streaming-mqtt/index.html
@@ -332,7 +332,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.1/spark-streaming-akka/index.html b/content/docs/spark/2.0.1/spark-streaming-akka/index.html
index 0762897..b7d0678 100644
--- a/content/docs/spark/2.0.1/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.0.1/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.1/spark-streaming-mqtt/index.html b/content/docs/spark/2.0.1/spark-streaming-mqtt/index.html
index f3d7cb8..062ffe4 100644
--- a/content/docs/spark/2.0.1/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.0.1/spark-streaming-mqtt/index.html
@@ -274,7 +274,7 @@ this actor can be configured to handle failures, etc.</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.1/spark-streaming-twitter/index.html b/content/docs/spark/2.0.1/spark-streaming-twitter/index.html
index 3d955f6..0fbd28a 100644
--- a/content/docs/spark/2.0.1/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.0.1/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.1/spark-streaming-zeromq/index.html b/content/docs/spark/2.0.1/spark-streaming-zeromq/index.html
index 65de020..b16b163 100644
--- a/content/docs/spark/2.0.1/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.0.1/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.2/documentation/index.html b/content/docs/spark/2.0.2/documentation/index.html
index f52d7ce..42dd9b2 100644
--- a/content/docs/spark/2.0.2/documentation/index.html
+++ b/content/docs/spark/2.0.2/documentation/index.html
@@ -222,7 +222,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.2/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.0.2/spark-sql-streaming-mqtt/index.html
index 6b9b8a2..d37e164 100644
--- a/content/docs/spark/2.0.2/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.0.2/spark-sql-streaming-mqtt/index.html
@@ -332,7 +332,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.2/spark-streaming-akka/index.html b/content/docs/spark/2.0.2/spark-streaming-akka/index.html
index 565763f..031a2c9 100644
--- a/content/docs/spark/2.0.2/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.0.2/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.2/spark-streaming-mqtt/index.html b/content/docs/spark/2.0.2/spark-streaming-mqtt/index.html
index bff226d..c5e2d16 100644
--- a/content/docs/spark/2.0.2/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.0.2/spark-streaming-mqtt/index.html
@@ -274,7 +274,7 @@ this actor can be configured to handle failures, etc.</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.2/spark-streaming-twitter/index.html b/content/docs/spark/2.0.2/spark-streaming-twitter/index.html
index 3638af5..cfe3785 100644
--- a/content/docs/spark/2.0.2/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.0.2/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.0.2/spark-streaming-zeromq/index.html b/content/docs/spark/2.0.2/spark-streaming-zeromq/index.html
index 6607fd4..1e7c653 100644
--- a/content/docs/spark/2.0.2/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.0.2/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.0/documentation/index.html b/content/docs/spark/2.1.0/documentation/index.html
index b584a6d..498e527 100644
--- a/content/docs/spark/2.1.0/documentation/index.html
+++ b/content/docs/spark/2.1.0/documentation/index.html
@@ -222,7 +222,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.0/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.1.0/spark-sql-streaming-mqtt/index.html
index bf68ce4..337bfd4 100644
--- a/content/docs/spark/2.1.0/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.1.0/spark-sql-streaming-mqtt/index.html
@@ -332,7 +332,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.0/spark-streaming-akka/index.html b/content/docs/spark/2.1.0/spark-streaming-akka/index.html
index b112b1a..329b514 100644
--- a/content/docs/spark/2.1.0/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.1.0/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.0/spark-streaming-mqtt/index.html b/content/docs/spark/2.1.0/spark-streaming-mqtt/index.html
index 90438c6..9523ecf 100644
--- a/content/docs/spark/2.1.0/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.1.0/spark-streaming-mqtt/index.html
@@ -274,7 +274,7 @@ this actor can be configured to handle failures, etc.</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.0/spark-streaming-twitter/index.html b/content/docs/spark/2.1.0/spark-streaming-twitter/index.html
index d136d12..2654609 100644
--- a/content/docs/spark/2.1.0/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.1.0/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.0/spark-streaming-zeromq/index.html b/content/docs/spark/2.1.0/spark-streaming-zeromq/index.html
index 42edfb9..8802835 100644
--- a/content/docs/spark/2.1.0/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.1.0/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/documentation/index.html b/content/docs/spark/2.1.1/documentation/index.html
index d9a3516..051d96a 100644
--- a/content/docs/spark/2.1.1/documentation/index.html
+++ b/content/docs/spark/2.1.1/documentation/index.html
@@ -232,7 +232,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/spark-sql-cloudant/index.html b/content/docs/spark/2.1.1/spark-sql-cloudant/index.html
index 9b2245d..89e791a 100644
--- a/content/docs/spark/2.1.1/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.1.1/spark-sql-cloudant/index.html
@@ -612,7 +612,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/spark-sql-streaming-akka/index.html b/content/docs/spark/2.1.1/spark-sql-streaming-akka/index.html
index 5c79bc9..6e5efc5 100644
--- a/content/docs/spark/2.1.1/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.1.1/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.1.1/spark-sql-streaming-mqtt/index.html
index 06b6f8b..9ecd779 100644
--- a/content/docs/spark/2.1.1/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.1.1/spark-sql-streaming-mqtt/index.html
@@ -331,7 +331,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/spark-streaming-akka/index.html b/content/docs/spark/2.1.1/spark-streaming-akka/index.html
index f489fca..d9b3016 100644
--- a/content/docs/spark/2.1.1/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.1.1/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/spark-streaming-mqtt/index.html b/content/docs/spark/2.1.1/spark-streaming-mqtt/index.html
index b7ac84b..e4db29c 100644
--- a/content/docs/spark/2.1.1/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.1.1/spark-streaming-mqtt/index.html
@@ -278,7 +278,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/spark-streaming-pubsub/index.html b/content/docs/spark/2.1.1/spark-streaming-pubsub/index.html
index 7af0ed5..a85a0fe 100644
--- a/content/docs/spark/2.1.1/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.1.1/spark-streaming-pubsub/index.html
@@ -255,7 +255,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/spark-streaming-twitter/index.html b/content/docs/spark/2.1.1/spark-streaming-twitter/index.html
index c60fe74..0408f65 100644
--- a/content/docs/spark/2.1.1/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.1.1/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.1/spark-streaming-zeromq/index.html b/content/docs/spark/2.1.1/spark-streaming-zeromq/index.html
index eecb317..95e2582 100644
--- a/content/docs/spark/2.1.1/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.1.1/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/documentation/index.html b/content/docs/spark/2.1.2/documentation/index.html
index e3cf87d..1090b56 100644
--- a/content/docs/spark/2.1.2/documentation/index.html
+++ b/content/docs/spark/2.1.2/documentation/index.html
@@ -234,7 +234,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/spark-sql-cloudant/index.html b/content/docs/spark/2.1.2/spark-sql-cloudant/index.html
index 8e5ecd2..995a008 100644
--- a/content/docs/spark/2.1.2/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.1.2/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/spark-sql-streaming-akka/index.html b/content/docs/spark/2.1.2/spark-sql-streaming-akka/index.html
index 7844057..0c04244 100644
--- a/content/docs/spark/2.1.2/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.1.2/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.1.2/spark-sql-streaming-mqtt/index.html
index 36e5f0a..b181885 100644
--- a/content/docs/spark/2.1.2/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.1.2/spark-sql-streaming-mqtt/index.html
@@ -332,7 +332,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/spark-streaming-akka/index.html b/content/docs/spark/2.1.2/spark-streaming-akka/index.html
index 093642d..2cef447 100644
--- a/content/docs/spark/2.1.2/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.1.2/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/spark-streaming-mqtt/index.html b/content/docs/spark/2.1.2/spark-streaming-mqtt/index.html
index 01268ec..2f559ca 100644
--- a/content/docs/spark/2.1.2/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.1.2/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/spark-streaming-pubsub/index.html b/content/docs/spark/2.1.2/spark-streaming-pubsub/index.html
index 6553f1a..7482070 100644
--- a/content/docs/spark/2.1.2/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.1.2/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/spark-streaming-twitter/index.html b/content/docs/spark/2.1.2/spark-streaming-twitter/index.html
index ec14133..2f047e4 100644
--- a/content/docs/spark/2.1.2/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.1.2/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.2/spark-streaming-zeromq/index.html b/content/docs/spark/2.1.2/spark-streaming-zeromq/index.html
index 233341c..ccac226 100644
--- a/content/docs/spark/2.1.2/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.1.2/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/documentation/index.html b/content/docs/spark/2.1.3/documentation/index.html
index e3cf87d..1090b56 100644
--- a/content/docs/spark/2.1.3/documentation/index.html
+++ b/content/docs/spark/2.1.3/documentation/index.html
@@ -234,7 +234,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/spark-sql-cloudant/index.html b/content/docs/spark/2.1.3/spark-sql-cloudant/index.html
index 4efc674..4ccd0b7 100644
--- a/content/docs/spark/2.1.3/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.1.3/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/spark-sql-streaming-akka/index.html b/content/docs/spark/2.1.3/spark-sql-streaming-akka/index.html
index 227a670..0ae9a3a 100644
--- a/content/docs/spark/2.1.3/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.1.3/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.1.3/spark-sql-streaming-mqtt/index.html
index 04710a1..c441256 100644
--- a/content/docs/spark/2.1.3/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.1.3/spark-sql-streaming-mqtt/index.html
@@ -332,7 +332,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/spark-streaming-akka/index.html b/content/docs/spark/2.1.3/spark-streaming-akka/index.html
index 3bc8baf..2a2a50d 100644
--- a/content/docs/spark/2.1.3/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.1.3/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/spark-streaming-mqtt/index.html b/content/docs/spark/2.1.3/spark-streaming-mqtt/index.html
index bb92dd9..bcf4e5e 100644
--- a/content/docs/spark/2.1.3/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.1.3/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/spark-streaming-pubsub/index.html b/content/docs/spark/2.1.3/spark-streaming-pubsub/index.html
index 5619206..0bfec5e 100644
--- a/content/docs/spark/2.1.3/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.1.3/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/spark-streaming-twitter/index.html b/content/docs/spark/2.1.3/spark-streaming-twitter/index.html
index 5435704..fa2591e 100644
--- a/content/docs/spark/2.1.3/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.1.3/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.1.3/spark-streaming-zeromq/index.html b/content/docs/spark/2.1.3/spark-streaming-zeromq/index.html
index 1db9269..fe2a3f0 100644
--- a/content/docs/spark/2.1.3/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.1.3/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/documentation/index.html b/content/docs/spark/2.2.0/documentation/index.html
index 16efd39..b1b4a37 100644
--- a/content/docs/spark/2.2.0/documentation/index.html
+++ b/content/docs/spark/2.2.0/documentation/index.html
@@ -234,7 +234,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/spark-sql-cloudant/index.html b/content/docs/spark/2.2.0/spark-sql-cloudant/index.html
index e2c51ea..2af4aff 100644
--- a/content/docs/spark/2.2.0/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.2.0/spark-sql-cloudant/index.html
@@ -612,7 +612,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/spark-sql-streaming-akka/index.html b/content/docs/spark/2.2.0/spark-sql-streaming-akka/index.html
index 248fb06..471dd1b 100644
--- a/content/docs/spark/2.2.0/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.2.0/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.2.0/spark-sql-streaming-mqtt/index.html
index 5264f80..b21e70f 100644
--- a/content/docs/spark/2.2.0/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.2.0/spark-sql-streaming-mqtt/index.html
@@ -331,7 +331,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/spark-streaming-akka/index.html b/content/docs/spark/2.2.0/spark-streaming-akka/index.html
index a3275b9..f133883 100644
--- a/content/docs/spark/2.2.0/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.2.0/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/spark-streaming-mqtt/index.html b/content/docs/spark/2.2.0/spark-streaming-mqtt/index.html
index d0d20b7..ee31c29 100644
--- a/content/docs/spark/2.2.0/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.2.0/spark-streaming-mqtt/index.html
@@ -278,7 +278,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/spark-streaming-pubsub/index.html b/content/docs/spark/2.2.0/spark-streaming-pubsub/index.html
index 56774c7..06a44fc 100644
--- a/content/docs/spark/2.2.0/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.2.0/spark-streaming-pubsub/index.html
@@ -255,7 +255,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/spark-streaming-twitter/index.html b/content/docs/spark/2.2.0/spark-streaming-twitter/index.html
index 1c1d70a..d72b0bf 100644
--- a/content/docs/spark/2.2.0/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.2.0/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.0/spark-streaming-zeromq/index.html b/content/docs/spark/2.2.0/spark-streaming-zeromq/index.html
index b50af15..c28de20 100644
--- a/content/docs/spark/2.2.0/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.2.0/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/documentation/index.html b/content/docs/spark/2.2.1/documentation/index.html
index e3cf87d..1090b56 100644
--- a/content/docs/spark/2.2.1/documentation/index.html
+++ b/content/docs/spark/2.2.1/documentation/index.html
@@ -234,7 +234,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/spark-sql-cloudant/index.html b/content/docs/spark/2.2.1/spark-sql-cloudant/index.html
index 31fcd1b..a0fde8c 100644
--- a/content/docs/spark/2.2.1/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.2.1/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/spark-sql-streaming-akka/index.html b/content/docs/spark/2.2.1/spark-sql-streaming-akka/index.html
index 55039ef..3b9c352 100644
--- a/content/docs/spark/2.2.1/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.2.1/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.2.1/spark-sql-streaming-mqtt/index.html
index 5c27e62..a4a9c7e 100644
--- a/content/docs/spark/2.2.1/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.2.1/spark-sql-streaming-mqtt/index.html
@@ -332,7 +332,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/spark-streaming-akka/index.html b/content/docs/spark/2.2.1/spark-streaming-akka/index.html
index 343518a..05b9318 100644
--- a/content/docs/spark/2.2.1/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.2.1/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/spark-streaming-mqtt/index.html b/content/docs/spark/2.2.1/spark-streaming-mqtt/index.html
index 08fbf4e..aee035d 100644
--- a/content/docs/spark/2.2.1/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.2.1/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/spark-streaming-pubsub/index.html b/content/docs/spark/2.2.1/spark-streaming-pubsub/index.html
index 7f48896..cad2edc 100644
--- a/content/docs/spark/2.2.1/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.2.1/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/spark-streaming-twitter/index.html b/content/docs/spark/2.2.1/spark-streaming-twitter/index.html
index cfb2dc5..5763a56 100644
--- a/content/docs/spark/2.2.1/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.2.1/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.1/spark-streaming-zeromq/index.html b/content/docs/spark/2.2.1/spark-streaming-zeromq/index.html
index eb784af..750c71b 100644
--- a/content/docs/spark/2.2.1/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.2.1/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/documentation/index.html b/content/docs/spark/2.2.2/documentation/index.html
index e3cf87d..1090b56 100644
--- a/content/docs/spark/2.2.2/documentation/index.html
+++ b/content/docs/spark/2.2.2/documentation/index.html
@@ -234,7 +234,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/spark-sql-cloudant/index.html b/content/docs/spark/2.2.2/spark-sql-cloudant/index.html
index cb38806..561da85 100644
--- a/content/docs/spark/2.2.2/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.2.2/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/spark-sql-streaming-akka/index.html b/content/docs/spark/2.2.2/spark-sql-streaming-akka/index.html
index 99a27aa..eb852a4 100644
--- a/content/docs/spark/2.2.2/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.2.2/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.2.2/spark-sql-streaming-mqtt/index.html
index 9c5fffb..263ae56 100644
--- a/content/docs/spark/2.2.2/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.2.2/spark-sql-streaming-mqtt/index.html
@@ -332,7 +332,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/spark-streaming-akka/index.html b/content/docs/spark/2.2.2/spark-streaming-akka/index.html
index 5fca75f..eebee36 100644
--- a/content/docs/spark/2.2.2/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.2.2/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/spark-streaming-mqtt/index.html b/content/docs/spark/2.2.2/spark-streaming-mqtt/index.html
index 432fdb0..42d2ce0 100644
--- a/content/docs/spark/2.2.2/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.2.2/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/spark-streaming-pubsub/index.html b/content/docs/spark/2.2.2/spark-streaming-pubsub/index.html
index 9fa85ad..d827274 100644
--- a/content/docs/spark/2.2.2/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.2.2/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/spark-streaming-twitter/index.html b/content/docs/spark/2.2.2/spark-streaming-twitter/index.html
index af2c8d2..fac225d 100644
--- a/content/docs/spark/2.2.2/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.2.2/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.2/spark-streaming-zeromq/index.html b/content/docs/spark/2.2.2/spark-streaming-zeromq/index.html
index ccb3290..d202083 100644
--- a/content/docs/spark/2.2.2/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.2.2/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/documentation/index.html b/content/docs/spark/2.2.3/documentation/index.html
index e3cf87d..1090b56 100644
--- a/content/docs/spark/2.2.3/documentation/index.html
+++ b/content/docs/spark/2.2.3/documentation/index.html
@@ -234,7 +234,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/spark-sql-cloudant/index.html b/content/docs/spark/2.2.3/spark-sql-cloudant/index.html
index 44fe394..ed0657a 100644
--- a/content/docs/spark/2.2.3/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.2.3/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/spark-sql-streaming-akka/index.html b/content/docs/spark/2.2.3/spark-sql-streaming-akka/index.html
index b1a050e..2eb238b 100644
--- a/content/docs/spark/2.2.3/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.2.3/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.2.3/spark-sql-streaming-mqtt/index.html
index f69c55a..89a96e2 100644
--- a/content/docs/spark/2.2.3/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.2.3/spark-sql-streaming-mqtt/index.html
@@ -332,7 +332,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/spark-streaming-akka/index.html b/content/docs/spark/2.2.3/spark-streaming-akka/index.html
index e077e0a..7d1da08 100644
--- a/content/docs/spark/2.2.3/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.2.3/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/spark-streaming-mqtt/index.html b/content/docs/spark/2.2.3/spark-streaming-mqtt/index.html
index d0d02ba..f9d2d22 100644
--- a/content/docs/spark/2.2.3/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.2.3/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/spark-streaming-pubsub/index.html b/content/docs/spark/2.2.3/spark-streaming-pubsub/index.html
index 86a8fe8..06cc686 100644
--- a/content/docs/spark/2.2.3/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.2.3/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/spark-streaming-twitter/index.html b/content/docs/spark/2.2.3/spark-streaming-twitter/index.html
index e4342b5..93388c9 100644
--- a/content/docs/spark/2.2.3/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.2.3/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.2.3/spark-streaming-zeromq/index.html b/content/docs/spark/2.2.3/spark-streaming-zeromq/index.html
index 819a1e2..893eb02 100644
--- a/content/docs/spark/2.2.3/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.2.3/spark-streaming-zeromq/index.html
@@ -245,7 +245,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/documentation/index.html b/content/docs/spark/2.3.0/documentation/index.html
index 30d62d2..6c7bc44 100644
--- a/content/docs/spark/2.3.0/documentation/index.html
+++ b/content/docs/spark/2.3.0/documentation/index.html
@@ -236,7 +236,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-sql-cloudant/index.html b/content/docs/spark/2.3.0/spark-sql-cloudant/index.html
index 684c17b..edb94ab 100644
--- a/content/docs/spark/2.3.0/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.3.0/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-sql-streaming-akka/index.html b/content/docs/spark/2.3.0/spark-sql-streaming-akka/index.html
index e15105e..1d78741 100644
--- a/content/docs/spark/2.3.0/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.3.0/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.3.0/spark-sql-streaming-mqtt/index.html
index 6e36694..5c999a1 100644
--- a/content/docs/spark/2.3.0/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.0/spark-sql-streaming-mqtt/index.html
@@ -418,7 +418,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-streaming-akka/index.html b/content/docs/spark/2.3.0/spark-streaming-akka/index.html
index 4c2f21a..8b0c582 100644
--- a/content/docs/spark/2.3.0/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.3.0/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-streaming-mqtt/index.html b/content/docs/spark/2.3.0/spark-streaming-mqtt/index.html
index 26bc21c..7803cfe 100644
--- a/content/docs/spark/2.3.0/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.0/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-streaming-pubnub/index.html b/content/docs/spark/2.3.0/spark-streaming-pubnub/index.html
index 0c5a717..67fa566 100644
--- a/content/docs/spark/2.3.0/spark-streaming-pubnub/index.html
+++ b/content/docs/spark/2.3.0/spark-streaming-pubnub/index.html
@@ -285,7 +285,7 @@ ReceiverInputDStream<SparkPubNubMessage> pubNubStream = PubNubUtils.create
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-streaming-pubsub/index.html b/content/docs/spark/2.3.0/spark-streaming-pubsub/index.html
index afabada..b5ee479 100644
--- a/content/docs/spark/2.3.0/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.3.0/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-streaming-twitter/index.html b/content/docs/spark/2.3.0/spark-streaming-twitter/index.html
index 532d33e..dc26017 100644
--- a/content/docs/spark/2.3.0/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.3.0/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.0/spark-streaming-zeromq/index.html b/content/docs/spark/2.3.0/spark-streaming-zeromq/index.html
index 5486546..5fed4c2 100644
--- a/content/docs/spark/2.3.0/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.3.0/spark-streaming-zeromq/index.html
@@ -258,7 +258,7 @@ JavaReceiverInputDStream<String> test1 = ZeroMQUtils.createJavaStream(
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/documentation/index.html b/content/docs/spark/2.3.1/documentation/index.html
index 30d62d2..6c7bc44 100644
--- a/content/docs/spark/2.3.1/documentation/index.html
+++ b/content/docs/spark/2.3.1/documentation/index.html
@@ -236,7 +236,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-sql-cloudant/index.html b/content/docs/spark/2.3.1/spark-sql-cloudant/index.html
index 8aae24f..11a6e3d 100644
--- a/content/docs/spark/2.3.1/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.3.1/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-sql-streaming-akka/index.html b/content/docs/spark/2.3.1/spark-sql-streaming-akka/index.html
index 82d5d76..40bf51b 100644
--- a/content/docs/spark/2.3.1/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.3.1/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.3.1/spark-sql-streaming-mqtt/index.html
index 4e2b0d4..c4e8aff 100644
--- a/content/docs/spark/2.3.1/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.1/spark-sql-streaming-mqtt/index.html
@@ -418,7 +418,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-streaming-akka/index.html b/content/docs/spark/2.3.1/spark-streaming-akka/index.html
index c591a59..492ee4f 100644
--- a/content/docs/spark/2.3.1/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.3.1/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-streaming-mqtt/index.html b/content/docs/spark/2.3.1/spark-streaming-mqtt/index.html
index 14d9eb3..203387c 100644
--- a/content/docs/spark/2.3.1/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.1/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-streaming-pubnub/index.html b/content/docs/spark/2.3.1/spark-streaming-pubnub/index.html
index 9f05825..2395bfa 100644
--- a/content/docs/spark/2.3.1/spark-streaming-pubnub/index.html
+++ b/content/docs/spark/2.3.1/spark-streaming-pubnub/index.html
@@ -285,7 +285,7 @@ ReceiverInputDStream<SparkPubNubMessage> pubNubStream = PubNubUtils.create
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-streaming-pubsub/index.html b/content/docs/spark/2.3.1/spark-streaming-pubsub/index.html
index 481f49a..c475ac2 100644
--- a/content/docs/spark/2.3.1/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.3.1/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-streaming-twitter/index.html b/content/docs/spark/2.3.1/spark-streaming-twitter/index.html
index afeacb7..a132d1d 100644
--- a/content/docs/spark/2.3.1/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.3.1/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.1/spark-streaming-zeromq/index.html b/content/docs/spark/2.3.1/spark-streaming-zeromq/index.html
index eb04aeb..5e376ec 100644
--- a/content/docs/spark/2.3.1/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.3.1/spark-streaming-zeromq/index.html
@@ -258,7 +258,7 @@ JavaReceiverInputDStream<String> test1 = ZeroMQUtils.createJavaStream(
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/documentation/index.html b/content/docs/spark/2.3.2/documentation/index.html
index 30d62d2..6c7bc44 100644
--- a/content/docs/spark/2.3.2/documentation/index.html
+++ b/content/docs/spark/2.3.2/documentation/index.html
@@ -236,7 +236,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-sql-cloudant/index.html b/content/docs/spark/2.3.2/spark-sql-cloudant/index.html
index 421cd7a..242f81a 100644
--- a/content/docs/spark/2.3.2/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.3.2/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-sql-streaming-akka/index.html b/content/docs/spark/2.3.2/spark-sql-streaming-akka/index.html
index d9ea960..2611e75 100644
--- a/content/docs/spark/2.3.2/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.3.2/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.3.2/spark-sql-streaming-mqtt/index.html
index bbbbfb9..69fef42 100644
--- a/content/docs/spark/2.3.2/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.2/spark-sql-streaming-mqtt/index.html
@@ -418,7 +418,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-streaming-akka/index.html b/content/docs/spark/2.3.2/spark-streaming-akka/index.html
index e7f6185..ac40eca 100644
--- a/content/docs/spark/2.3.2/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.3.2/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-streaming-mqtt/index.html b/content/docs/spark/2.3.2/spark-streaming-mqtt/index.html
index 9232daf..3648be9 100644
--- a/content/docs/spark/2.3.2/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.2/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-streaming-pubnub/index.html b/content/docs/spark/2.3.2/spark-streaming-pubnub/index.html
index 1c58bc3..6966dc0 100644
--- a/content/docs/spark/2.3.2/spark-streaming-pubnub/index.html
+++ b/content/docs/spark/2.3.2/spark-streaming-pubnub/index.html
@@ -285,7 +285,7 @@ ReceiverInputDStream<SparkPubNubMessage> pubNubStream = PubNubUtils.create
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-streaming-pubsub/index.html b/content/docs/spark/2.3.2/spark-streaming-pubsub/index.html
index 43d50c6..721d3e1 100644
--- a/content/docs/spark/2.3.2/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.3.2/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-streaming-twitter/index.html b/content/docs/spark/2.3.2/spark-streaming-twitter/index.html
index 033a24b..e684ac2 100644
--- a/content/docs/spark/2.3.2/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.3.2/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.2/spark-streaming-zeromq/index.html b/content/docs/spark/2.3.2/spark-streaming-zeromq/index.html
index 14b16d1..379172e 100644
--- a/content/docs/spark/2.3.2/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.3.2/spark-streaming-zeromq/index.html
@@ -258,7 +258,7 @@ JavaReceiverInputDStream<String> test1 = ZeroMQUtils.createJavaStream(
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/documentation/index.html b/content/docs/spark/2.3.3/documentation/index.html
index 30d62d2..6c7bc44 100644
--- a/content/docs/spark/2.3.3/documentation/index.html
+++ b/content/docs/spark/2.3.3/documentation/index.html
@@ -236,7 +236,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-sql-cloudant/index.html b/content/docs/spark/2.3.3/spark-sql-cloudant/index.html
index ca45834..6c730ec 100644
--- a/content/docs/spark/2.3.3/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.3.3/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-sql-streaming-akka/index.html b/content/docs/spark/2.3.3/spark-sql-streaming-akka/index.html
index 352130c..6fbdfbc 100644
--- a/content/docs/spark/2.3.3/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.3.3/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.3.3/spark-sql-streaming-mqtt/index.html
index 77f8d18..cfe7cc7 100644
--- a/content/docs/spark/2.3.3/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.3/spark-sql-streaming-mqtt/index.html
@@ -418,7 +418,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-streaming-akka/index.html b/content/docs/spark/2.3.3/spark-streaming-akka/index.html
index ff3988e..87dacca 100644
--- a/content/docs/spark/2.3.3/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.3.3/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-streaming-mqtt/index.html b/content/docs/spark/2.3.3/spark-streaming-mqtt/index.html
index 8116ebf..9c7be50 100644
--- a/content/docs/spark/2.3.3/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.3/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-streaming-pubnub/index.html b/content/docs/spark/2.3.3/spark-streaming-pubnub/index.html
index 307fee1..203ae23 100644
--- a/content/docs/spark/2.3.3/spark-streaming-pubnub/index.html
+++ b/content/docs/spark/2.3.3/spark-streaming-pubnub/index.html
@@ -285,7 +285,7 @@ ReceiverInputDStream<SparkPubNubMessage> pubNubStream = PubNubUtils.create
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-streaming-pubsub/index.html b/content/docs/spark/2.3.3/spark-streaming-pubsub/index.html
index 4c9a271..602471a 100644
--- a/content/docs/spark/2.3.3/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.3.3/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-streaming-twitter/index.html b/content/docs/spark/2.3.3/spark-streaming-twitter/index.html
index c8a40a6..feb857a 100644
--- a/content/docs/spark/2.3.3/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.3.3/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.3/spark-streaming-zeromq/index.html b/content/docs/spark/2.3.3/spark-streaming-zeromq/index.html
index e2c3f9b..87a8f3e 100644
--- a/content/docs/spark/2.3.3/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.3.3/spark-streaming-zeromq/index.html
@@ -258,7 +258,7 @@ JavaReceiverInputDStream<String> test1 = ZeroMQUtils.createJavaStream(
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/documentation/index.html b/content/docs/spark/2.3.4/documentation/index.html
index 30d62d2..6c7bc44 100644
--- a/content/docs/spark/2.3.4/documentation/index.html
+++ b/content/docs/spark/2.3.4/documentation/index.html
@@ -236,7 +236,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-sql-cloudant/index.html b/content/docs/spark/2.3.4/spark-sql-cloudant/index.html
index e806a16..d83e0bf 100644
--- a/content/docs/spark/2.3.4/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.3.4/spark-sql-cloudant/index.html
@@ -668,7 +668,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-sql-streaming-akka/index.html b/content/docs/spark/2.3.4/spark-sql-streaming-akka/index.html
index 9a3c5e5..527b78a 100644
--- a/content/docs/spark/2.3.4/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.3.4/spark-sql-streaming-akka/index.html
@@ -323,7 +323,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.3.4/spark-sql-streaming-mqtt/index.html
index 76c2851..d04b3bb 100644
--- a/content/docs/spark/2.3.4/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.4/spark-sql-streaming-mqtt/index.html
@@ -418,7 +418,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-streaming-akka/index.html b/content/docs/spark/2.3.4/spark-streaming-akka/index.html
index c21edda..14e1e02 100644
--- a/content/docs/spark/2.3.4/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.3.4/spark-streaming-akka/index.html
@@ -270,7 +270,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-streaming-mqtt/index.html b/content/docs/spark/2.3.4/spark-streaming-mqtt/index.html
index 27865d2..b790804 100644
--- a/content/docs/spark/2.3.4/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.3.4/spark-streaming-mqtt/index.html
@@ -293,7 +293,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-streaming-pubnub/index.html b/content/docs/spark/2.3.4/spark-streaming-pubnub/index.html
index 5a15afb..a5ed06e 100644
--- a/content/docs/spark/2.3.4/spark-streaming-pubnub/index.html
+++ b/content/docs/spark/2.3.4/spark-streaming-pubnub/index.html
@@ -285,7 +285,7 @@ ReceiverInputDStream<SparkPubNubMessage> pubNubStream = PubNubUtils.create
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-streaming-pubsub/index.html b/content/docs/spark/2.3.4/spark-streaming-pubsub/index.html
index 3270958..8f11992 100644
--- a/content/docs/spark/2.3.4/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.3.4/spark-streaming-pubsub/index.html
@@ -281,7 +281,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-streaming-twitter/index.html b/content/docs/spark/2.3.4/spark-streaming-twitter/index.html
index 63d7d55..1afbb8d 100644
--- a/content/docs/spark/2.3.4/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.3.4/spark-streaming-twitter/index.html
@@ -253,7 +253,7 @@ See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.3.4/spark-streaming-zeromq/index.html b/content/docs/spark/2.3.4/spark-streaming-zeromq/index.html
index 35bf3c9..96f9175 100644
--- a/content/docs/spark/2.3.4/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.3.4/spark-streaming-zeromq/index.html
@@ -258,7 +258,7 @@ JavaReceiverInputDStream<String> test1 = ZeroMQUtils.createJavaStream(
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/documentation/index.html b/content/docs/spark/2.4.0/documentation/index.html
index 30d62d2..6c7bc44 100644
--- a/content/docs/spark/2.4.0/documentation/index.html
+++ b/content/docs/spark/2.4.0/documentation/index.html
@@ -236,7 +236,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-sql-cloudant/index.html b/content/docs/spark/2.4.0/spark-sql-cloudant/index.html
index 9093336..7d7a4ed 100644
--- a/content/docs/spark/2.4.0/spark-sql-cloudant/index.html
+++ b/content/docs/spark/2.4.0/spark-sql-cloudant/index.html
@@ -673,7 +673,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-sql-streaming-akka/index.html b/content/docs/spark/2.4.0/spark-sql-streaming-akka/index.html
index 4e78a28..333af77 100644
--- a/content/docs/spark/2.4.0/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/2.4.0/spark-sql-streaming-akka/index.html
@@ -328,7 +328,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-sql-streaming-mqtt/index.html b/content/docs/spark/2.4.0/spark-sql-streaming-mqtt/index.html
index d472ab7..93670e6 100644
--- a/content/docs/spark/2.4.0/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/2.4.0/spark-sql-streaming-mqtt/index.html
@@ -533,7 +533,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-streaming-akka/index.html b/content/docs/spark/2.4.0/spark-streaming-akka/index.html
index db625ec..5b1c81f 100644
--- a/content/docs/spark/2.4.0/spark-streaming-akka/index.html
+++ b/content/docs/spark/2.4.0/spark-streaming-akka/index.html
@@ -275,7 +275,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-streaming-mqtt/index.html b/content/docs/spark/2.4.0/spark-streaming-mqtt/index.html
index 6c0a962..610a185 100644
--- a/content/docs/spark/2.4.0/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/2.4.0/spark-streaming-mqtt/index.html
@@ -298,7 +298,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-streaming-pubnub/index.html b/content/docs/spark/2.4.0/spark-streaming-pubnub/index.html
index a000920..98e630f 100644
--- a/content/docs/spark/2.4.0/spark-streaming-pubnub/index.html
+++ b/content/docs/spark/2.4.0/spark-streaming-pubnub/index.html
@@ -292,7 +292,7 @@ ENABLE_PUBNUB_TESTS=1 mvn clean test
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-streaming-pubsub/index.html b/content/docs/spark/2.4.0/spark-streaming-pubsub/index.html
index 46ce6de..4bf1b5f 100644
--- a/content/docs/spark/2.4.0/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/2.4.0/spark-streaming-pubsub/index.html
@@ -288,7 +288,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-streaming-twitter/index.html b/content/docs/spark/2.4.0/spark-streaming-twitter/index.html
index 02f5bc3..12aa853 100644
--- a/content/docs/spark/2.4.0/spark-streaming-twitter/index.html
+++ b/content/docs/spark/2.4.0/spark-streaming-twitter/index.html
@@ -273,7 +273,7 @@ env ENABLE_TWITTER_TESTS=1 \
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/2.4.0/spark-streaming-zeromq/index.html b/content/docs/spark/2.4.0/spark-streaming-zeromq/index.html
index a03ad53..509aeea 100644
--- a/content/docs/spark/2.4.0/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/2.4.0/spark-streaming-zeromq/index.html
@@ -261,7 +261,7 @@ JavaReceiverInputDStream<String> test1 = ZeroMQUtils.createJavaStream(
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/documentation/index.html b/content/docs/spark/current/documentation/index.html
index 30d62d2..6c7bc44 100644
--- a/content/docs/spark/current/documentation/index.html
+++ b/content/docs/spark/current/documentation/index.html
@@ -236,7 +236,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-sql-cloudant/index.html b/content/docs/spark/current/spark-sql-cloudant/index.html
index 3857723..201bb0f 100644
--- a/content/docs/spark/current/spark-sql-cloudant/index.html
+++ b/content/docs/spark/current/spark-sql-cloudant/index.html
@@ -673,7 +673,7 @@ example for more details):</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-sql-streaming-akka/index.html b/content/docs/spark/current/spark-sql-streaming-akka/index.html
index dfa1c7d..5c60131 100644
--- a/content/docs/spark/current/spark-sql-streaming-akka/index.html
+++ b/content/docs/spark/current/spark-sql-streaming-akka/index.html
@@ -328,7 +328,7 @@ The <code class="language-plaintext highlighter-rouge">--packages</code> argumen
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-sql-streaming-mqtt/index.html b/content/docs/spark/current/spark-sql-streaming-mqtt/index.html
index 1a002f5..697670a 100644
--- a/content/docs/spark/current/spark-sql-streaming-mqtt/index.html
+++ b/content/docs/spark/current/spark-sql-streaming-mqtt/index.html
@@ -533,7 +533,7 @@ query.awaitTermination();
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-streaming-akka/index.html b/content/docs/spark/current/spark-streaming-akka/index.html
index 2c274f1..ef67c1b 100644
--- a/content/docs/spark/current/spark-streaming-akka/index.html
+++ b/content/docs/spark/current/spark-streaming-akka/index.html
@@ -275,7 +275,7 @@ JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Pro
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-streaming-mqtt/index.html b/content/docs/spark/current/spark-streaming-mqtt/index.html
index aaa2a3a..6a944c9 100644
--- a/content/docs/spark/current/spark-streaming-mqtt/index.html
+++ b/content/docs/spark/current/spark-streaming-mqtt/index.html
@@ -298,7 +298,7 @@ JavaReceiverInputDStream<Tuple2<String, String>> lines = MQTTUtils.c
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-streaming-pubnub/index.html b/content/docs/spark/current/spark-streaming-pubnub/index.html
index d3295bf..6b59ed0 100644
--- a/content/docs/spark/current/spark-streaming-pubnub/index.html
+++ b/content/docs/spark/current/spark-streaming-pubnub/index.html
@@ -292,7 +292,7 @@ ENABLE_PUBNUB_TESTS=1 mvn clean test
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-streaming-pubsub/index.html b/content/docs/spark/current/spark-streaming-pubsub/index.html
index 46555fc..7cd3cc8 100644
--- a/content/docs/spark/current/spark-streaming-pubsub/index.html
+++ b/content/docs/spark/current/spark-streaming-pubsub/index.html
@@ -288,7 +288,7 @@ mvn test -pl streaming-pubsub
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-streaming-twitter/index.html b/content/docs/spark/current/spark-streaming-twitter/index.html
index 144aed6..6104c54 100644
--- a/content/docs/spark/current/spark-streaming-twitter/index.html
+++ b/content/docs/spark/current/spark-streaming-twitter/index.html
@@ -273,7 +273,7 @@ env ENABLE_TWITTER_TESTS=1 \
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/current/spark-streaming-zeromq/index.html b/content/docs/spark/current/spark-streaming-zeromq/index.html
index 6f3df6e..24e2a8e 100644
--- a/content/docs/spark/current/spark-streaming-zeromq/index.html
+++ b/content/docs/spark/current/spark-streaming-zeromq/index.html
@@ -261,7 +261,7 @@ JavaReceiverInputDStream<String> test1 = ZeroMQUtils.createJavaStream(
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/docs/spark/overview/index.html b/content/docs/spark/overview/index.html
index 500314c..0714cc4 100644
--- a/content/docs/spark/overview/index.html
+++ b/content/docs/spark/overview/index.html
@@ -225,7 +225,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/downloads/flink/index.html b/content/downloads/flink/index.html
index 679ccbf..c0d693f 100644
--- a/content/downloads/flink/index.html
+++ b/content/downloads/flink/index.html
@@ -270,7 +270,7 @@ succeed.</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/downloads/spark/index.html b/content/downloads/spark/index.html
index 7994a3a..4b93c12 100644
--- a/content/downloads/spark/index.html
+++ b/content/downloads/spark/index.html
@@ -266,7 +266,7 @@ succeed.</p>
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/feed.xml b/content/feed.xml
index e7bb9e4..fa4cf5b 100644
--- a/content/feed.xml
+++ b/content/feed.xml
@@ -6,8 +6,8 @@
</description>
<link>http://bahir.apache.org/</link>
<atom:link href="http://bahir.apache.org/feed.xml" rel="self" type="application/rss+xml"/>
- <pubDate>Mon, 14 Dec 2020 17:42:42 -0800</pubDate>
- <lastBuildDate>Mon, 14 Dec 2020 17:42:42 -0800</lastBuildDate>
+ <pubDate>Fri, 26 Nov 2021 20:10:48 +0100</pubDate>
+ <lastBuildDate>Fri, 26 Nov 2021 20:10:48 +0100</lastBuildDate>
<generator>Jekyll v3.9.0</generator>
</channel>
diff --git a/content/history/index.html b/content/history/index.html
index 85c9a20..ea7bd36 100644
--- a/content/history/index.html
+++ b/content/history/index.html
@@ -226,7 +226,7 @@ Derive <code class="language-plaintext highlighter-rouge">FOO</code> return type
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/index.html b/content/index.html
index 7ca99ec..5f7667b 100644
--- a/content/index.html
+++ b/content/index.html
@@ -255,7 +255,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/privacy-policy/index.html b/content/privacy-policy/index.html
index e1ae05c..e10bd2d 100644
--- a/content/privacy-policy/index.html
+++ b/content/privacy-policy/index.html
@@ -221,7 +221,7 @@ The addresses of pages from where you followed a link to our site.
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/releases/spark/2.0.0/release-notes/index.html b/content/releases/spark/2.0.0/release-notes/index.html
index 46d58c8..084064f 100644
--- a/content/releases/spark/2.0.0/release-notes/index.html
+++ b/content/releases/spark/2.0.0/release-notes/index.html
@@ -249,7 +249,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/releases/spark/2.0.1/release-notes/index.html b/content/releases/spark/2.0.1/release-notes/index.html
index aab5b03..0b359fe 100644
--- a/content/releases/spark/2.0.1/release-notes/index.html
+++ b/content/releases/spark/2.0.1/release-notes/index.html
@@ -222,7 +222,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/releases/spark/2.0.2/release-notes/index.html b/content/releases/spark/2.0.2/release-notes/index.html
index 2f69f53..8107bcb 100644
--- a/content/releases/spark/2.0.2/release-notes/index.html
+++ b/content/releases/spark/2.0.2/release-notes/index.html
@@ -221,7 +221,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/releases/spark/2.1.0/release-notes/index.html b/content/releases/spark/2.1.0/release-notes/index.html
index ffa0dfd..53041d7 100644
--- a/content/releases/spark/2.1.0/release-notes/index.html
+++ b/content/releases/spark/2.1.0/release-notes/index.html
@@ -212,7 +212,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/releases/spark/2.3.3/release-notes/index.html b/content/releases/spark/2.3.3/release-notes/index.html
index d56c261..bfa9737 100644
--- a/content/releases/spark/2.3.3/release-notes/index.html
+++ b/content/releases/spark/2.3.3/release-notes/index.html
@@ -229,7 +229,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">
diff --git a/content/releases/spark/2.3.4/release-notes/index.html b/content/releases/spark/2.3.4/release-notes/index.html
index d298167..c66c305 100644
--- a/content/releases/spark/2.3.4/release-notes/index.html
+++ b/content/releases/spark/2.3.4/release-notes/index.html
@@ -228,7 +228,7 @@
<hr>
- <!-- <p>© 2020 </p>-->
+ <!-- <p>© 2021 </p>-->
<footer class="site-footer">
<div class="wrapper">
<div class="footer-col-wrapper">