svn commit: r18125 - in /dev/bahir/2.1.0-rc1: ./ apache-bahir-2.1.0-src.tar.gz apache-bahir-2.1.0-src.tar.gz.asc apache-bahir-2.1.0-src.tar.gz.md5 apache-bahir-2.1.0-src.zip apache-bahir-2.1.0-src.zip

2017-02-03 Thread ckadner 
Author: ckadner
Date: Sat Feb  4 05:18:40 2017
New Revision: 18125

Log:
Apache Bahir 2.1.0-rc1

Added:
dev/bahir/2.1.0-rc1/
dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz   (with props)
dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz.asc
dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz.md5
dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip   (with props)
dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip.asc
dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip.md5

Added: dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz
==
Binary file - no diff available.

Propchange: dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz
--
svn:mime-type = application/octet-stream

Added: dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz.asc
==
--- dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz.asc (added)
+++ dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz.asc Sat Feb  4 05:18:40 
2017
@@ -0,0 +1,17 @@
+-BEGIN PGP SIGNATURE-
+Version: GnuPG v2
+
+iQIcBAABCAAGBQJYlWQuAAoJEHVK7wAfQD+gCsoP/1NY314ML85rmB4rOyj3OF8X
+p6VfHE3C/pIU3wzcsB/3xUqicfWBfspqPRUc9bZeJu8X3PZEM7/dOo/e+mnUwNvN
+h/eMbQm5y5SIiv/1kIJQPYf8qHYBiTU50XR3TJ9Ou/tpEqTOZ+pPUces84BMkkg1
+PoUxz41Jq1RBPboZudT1pAaOKtcjCupWBhck7Hb/7aylsmpwN5SM0qi9S5ztJ+JI
+cOBFFYNXYO6zzbNBa7rdyDiERTPRRALj1f08CHdwds7NZ8oqq6yRtiuFPrdPMvBe
+lHLPY/b/druge8PU0rHkSCYFyfCdUmJx2HRHwEbH8KTISnALCasIr7If9f4PToJj
+7tllKCx3FcChwc7WqeZ2Pl8LJj6m9kisOpEEUm2decTVhub8xkU/OCILOAsj3a8b
+hANZlT7qxJ6Fuu8SpfsfQUVszlveKuKL5CJkV1oGPW+zPUk4aS06ol4hO1kfhBup
+7j5Oi/Dln6otfs9Uuy3eJZqkShHkY+MBPh4Rm7KFILRJ3ixwSpCQcZF5nezJcLJL
+p7jdbOOmHLYAr+kVOcuu9js7My4HBL0nNjx/8X07wICmxT0UWyaQ/fw+ogGttj1p
+t/R2qhIuc22M64gp3F0/EFvD0X4Ev8sX4U6Ipl1g5pAXfGWsZhWw1H3bpYOjJva6
+W6a11UnbawSeNsye2b6P
+=aFx1
+-END PGP SIGNATURE-

Added: dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz.md5
==
--- dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz.md5 (added)
+++ dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.tar.gz.md5 Sat Feb  4 05:18:40 
2017
@@ -0,0 +1 @@
+4d6a3379577d466477fccd223328e5a4 *apache-bahir-2.1.0-src.tar.gz

Added: dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip
==
Binary file - no diff available.

Propchange: dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip
--
svn:mime-type = application/octet-stream

Added: dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip.asc
==
--- dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip.asc (added)
+++ dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip.asc Sat Feb  4 05:18:40 2017
@@ -0,0 +1,17 @@
+-BEGIN PGP SIGNATURE-
+Version: GnuPG v2
+
+iQIcBAABCAAGBQJYlWQuAAoJEHVK7wAfQD+gh8sP/jgi41dyxCxYREgOnG/wXkle
+hWvYYfneHSTYhWTyPbODtC94+M7Cyo9zlLxMuc5+ZSwC4T49CeBUY+1EkyzfO+CH
+KJHV9DKpKAMnrAaMWXZFxb/dGIIxO49Wm7tUoBc4pu7KvkrcFk8wyYODHcJcLUL0
+SsNO+k8sblZgQzkzHY557s7bl5DVlutBKChScZ5xVROQCc4Mp3AfJuv4E7loUmVB
+5lJ6ntFFuH9ZZeZTmrpldBT1dPVYQ00DCOveMSELKuT0zkGntP2YzR5epOtIQJK9
+SJuLL8e+IhurzG8MqLQmHM/NQPkTplb5CXQrlNfKZKaLPBGlCQyPNYzZcpGyLQXW
+n+wEkAWizHlF1XseuKUL0kYsbEtX2mFneufQOj4WXbjM9xkjYpU0Uu0XCzwUNGGe
+6xUOvgdBNxof5keGRyErOffF1TtfMyjvFGDSZ5Nu/2iPt8zkil+lzMi4k+caJEpZ
+tIV5UBgxHOID6mll9ye+KT37W4jCSqRml5Dvm17HRiOx12pYknO1KnmB3Pl5Wtwz
+lpp+lqPim8rhKkAboNIgKSDocfa8Tbf295uIBVqV35cF7cb5dJKMs/1An3Z7fUrI
+GElCexQ5h6S0sitebbofOsHALF3vv8rvrYD4wFkqLsxkZ66C1R7BWY23skCPgCE5
+PWlCE0cDnZ5c9IjRy22H
+=pa3R
+-END PGP SIGNATURE-

Added: dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip.md5
==
--- dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip.md5 (added)
+++ dev/bahir/2.1.0-rc1/apache-bahir-2.1.0-src.zip.md5 Sat Feb  4 05:18:40 2017
@@ -0,0 +1 @@
+6ca5b82e97aaf8746cbe4d4669a4f3c5 *apache-bahir-2.1.0-src.zip

bahir git commit: [maven-release-plugin] prepare for next development iteration

2017-02-03 Thread ckadner 
Repository: bahir
Updated Branches:
  refs/heads/master e61cc3ddc -> daf001fd6


[maven-release-plugin] prepare for next development iteration


Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/daf001fd
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/daf001fd
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/daf001fd

Branch: refs/heads/master
Commit: daf001fd6c8db14362da8a6a51961859768ca081
Parents: e61cc3d
Author: Christian Kadner 
Authored: Fri Feb 3 20:21:59 2017 -0800
Committer: Christian Kadner 
Committed: Fri Feb 3 20:21:59 2017 -0800

--
 distribution/pom.xml   | 2 +-
 pom.xml| 4 ++--
 sql-streaming-mqtt/pom.xml | 2 +-
 streaming-akka/pom.xml | 2 +-
 streaming-mqtt/pom.xml | 2 +-
 streaming-twitter/pom.xml  | 2 +-
 streaming-zeromq/pom.xml   | 2 +-
 7 files changed, 8 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/bahir/blob/daf001fd/distribution/pom.xml
--
diff --git a/distribution/pom.xml b/distribution/pom.xml
index c7fbff0..4ff93fc 100644
--- a/distribution/pom.xml
+++ b/distribution/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.bahir
 bahir-parent_2.11
-2.1.0
+2.2.0-SNAPSHOT
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/daf001fd/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 210c608..f9ee4a0 100644
--- a/pom.xml
+++ b/pom.xml
@@ -25,7 +25,7 @@
   
   org.apache.bahir
   bahir-parent_2.11
-  2.1.0
+  2.2.0-SNAPSHOT
   pom
   Apache Bahir - Parent POM
   http://bahir.apache.org/
@@ -40,7 +40,7 @@
 scm:git:g...@github.com:apache/bahir.git
 
scm:git:https://git-wip-us.apache.org/repos/asf/bahir.git
 scm:git:g...@github.com:apache/bahir.git
-v2.1.0-rc1
+HEAD
   
   
 JIRA

http://git-wip-us.apache.org/repos/asf/bahir/blob/daf001fd/sql-streaming-mqtt/pom.xml
--
diff --git a/sql-streaming-mqtt/pom.xml b/sql-streaming-mqtt/pom.xml
index 28840e6..4a01ef5 100644
--- a/sql-streaming-mqtt/pom.xml
+++ b/sql-streaming-mqtt/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0
+2.2.0-SNAPSHOT
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/daf001fd/streaming-akka/pom.xml
--
diff --git a/streaming-akka/pom.xml b/streaming-akka/pom.xml
index 4510801..36ce385 100644
--- a/streaming-akka/pom.xml
+++ b/streaming-akka/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0
+2.2.0-SNAPSHOT
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/daf001fd/streaming-mqtt/pom.xml
--
diff --git a/streaming-mqtt/pom.xml b/streaming-mqtt/pom.xml
index e5fef2a..2935f51 100644
--- a/streaming-mqtt/pom.xml
+++ b/streaming-mqtt/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0
+2.2.0-SNAPSHOT
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/daf001fd/streaming-twitter/pom.xml
--
diff --git a/streaming-twitter/pom.xml b/streaming-twitter/pom.xml
index a33842d..949e4b3 100644
--- a/streaming-twitter/pom.xml
+++ b/streaming-twitter/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0
+2.2.0-SNAPSHOT
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/daf001fd/streaming-zeromq/pom.xml
--
diff --git a/streaming-zeromq/pom.xml b/streaming-zeromq/pom.xml
index bba10f0..db6616d 100644
--- a/streaming-zeromq/pom.xml
+++ b/streaming-zeromq/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0
+2.2.0-SNAPSHOT
 ../pom.xml

[bahir] Git Push Summary

2017-02-03 Thread ckadner 
Repository: bahir
Updated Tags:  refs/tags/v2.1.0-rc1 [created] bc34dda31

bahir git commit: [maven-release-plugin] prepare release v2.1.0-rc1

2017-02-03 Thread ckadner 
Repository: bahir
Updated Branches:
  refs/heads/master f97f2dfa2 -> e61cc3ddc


[maven-release-plugin] prepare release v2.1.0-rc1


Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/e61cc3dd
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/e61cc3dd
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/e61cc3dd

Branch: refs/heads/master
Commit: e61cc3ddc7994361d85fe22aeb1fd973e106959e
Parents: f97f2df
Author: Christian Kadner 
Authored: Fri Feb 3 20:21:39 2017 -0800
Committer: Christian Kadner 
Committed: Fri Feb 3 20:21:39 2017 -0800

--
 distribution/pom.xml   | 2 +-
 pom.xml| 4 ++--
 sql-streaming-mqtt/pom.xml | 2 +-
 streaming-akka/pom.xml | 2 +-
 streaming-mqtt/pom.xml | 2 +-
 streaming-twitter/pom.xml  | 2 +-
 streaming-zeromq/pom.xml   | 2 +-
 7 files changed, 8 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/bahir/blob/e61cc3dd/distribution/pom.xml
--
diff --git a/distribution/pom.xml b/distribution/pom.xml
index 186dafd..c7fbff0 100644
--- a/distribution/pom.xml
+++ b/distribution/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.bahir
 bahir-parent_2.11
-2.1.0-SNAPSHOT
+2.1.0
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/e61cc3dd/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 0903858..210c608 100644
--- a/pom.xml
+++ b/pom.xml
@@ -25,7 +25,7 @@
   
   org.apache.bahir
   bahir-parent_2.11
-  2.1.0-SNAPSHOT
+  2.1.0
   pom
   Apache Bahir - Parent POM
   http://bahir.apache.org/
@@ -40,7 +40,7 @@
 scm:git:g...@github.com:apache/bahir.git
 
scm:git:https://git-wip-us.apache.org/repos/asf/bahir.git
 scm:git:g...@github.com:apache/bahir.git
-HEAD
+v2.1.0-rc1
   
   
 JIRA

http://git-wip-us.apache.org/repos/asf/bahir/blob/e61cc3dd/sql-streaming-mqtt/pom.xml
--
diff --git a/sql-streaming-mqtt/pom.xml b/sql-streaming-mqtt/pom.xml
index 678aeee..28840e6 100644
--- a/sql-streaming-mqtt/pom.xml
+++ b/sql-streaming-mqtt/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0-SNAPSHOT
+2.1.0
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/e61cc3dd/streaming-akka/pom.xml
--
diff --git a/streaming-akka/pom.xml b/streaming-akka/pom.xml
index b108502..4510801 100644
--- a/streaming-akka/pom.xml
+++ b/streaming-akka/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0-SNAPSHOT
+2.1.0
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/e61cc3dd/streaming-mqtt/pom.xml
--
diff --git a/streaming-mqtt/pom.xml b/streaming-mqtt/pom.xml
index 8cdba98..e5fef2a 100644
--- a/streaming-mqtt/pom.xml
+++ b/streaming-mqtt/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0-SNAPSHOT
+2.1.0
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/e61cc3dd/streaming-twitter/pom.xml
--
diff --git a/streaming-twitter/pom.xml b/streaming-twitter/pom.xml
index 7647ba8..a33842d 100644
--- a/streaming-twitter/pom.xml
+++ b/streaming-twitter/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0-SNAPSHOT
+2.1.0
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/bahir/blob/e61cc3dd/streaming-zeromq/pom.xml
--
diff --git a/streaming-zeromq/pom.xml b/streaming-zeromq/pom.xml
index f9ae3bc..bba10f0 100644
--- a/streaming-zeromq/pom.xml
+++ b/streaming-zeromq/pom.xml
@@ -21,7 +21,7 @@
   
 org.apache.bahir
 bahir-parent_2.11
-2.1.0-SNAPSHOT
+2.1.0
 ../pom.xml

bahir git commit: [BAHIR-87] Prepare release based on Apache Spark 2.1.0

2017-02-03 Thread ckadner 
Repository: bahir
Updated Branches:
  refs/heads/master 695ca982d -> f97f2dfa2


[BAHIR-87] Prepare release based on Apache Spark 2.1.0


Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/f97f2dfa
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/f97f2dfa
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/f97f2dfa

Branch: refs/heads/master
Commit: f97f2dfa2fc51a8dcdec82d45aa68b2cddc22b3a
Parents: 695ca98
Author: Christian Kadner 
Authored: Fri Feb 3 19:02:31 2017 -0800
Committer: Christian Kadner 
Committed: Fri Feb 3 19:02:31 2017 -0800

--
 pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/bahir/blob/f97f2dfa/pom.xml
--
diff --git a/pom.xml b/pom.xml
index e7cb338..0903858 100644
--- a/pom.xml
+++ b/pom.xml
@@ -96,7 +96,7 @@
 1.2.17
 
 
-2.0.2
+2.1.0
 
 
 com.typesafe.akka

svn commit: r18103 - /dev/bahir/KEYS /release/bahir/KEYS

2017-02-03 Thread lresende 
Author: lresende
Date: Fri Feb  3 15:55:25 2017
New Revision: 18103

Log:
Add KYES file

Added:
release/bahir/KEYS
  - copied unchanged from r18102, dev/bahir/KEYS
Removed:
dev/bahir/KEYS

svn commit: r18102 - /dev/bahir/KEYS

2017-02-03 Thread lresende 
Author: lresende
Date: Fri Feb  3 15:54:30 2017
New Revision: 18102

Log:
KEYS += lresende

Modified:
dev/bahir/KEYS

Modified: dev/bahir/KEYS
==
--- dev/bahir/KEYS (original)
+++ dev/bahir/KEYS Fri Feb  3 15:54:30 2017
@@ -89,3 +89,229 @@ YeDPOdZD/CrNaZ//Vfk4X/gEtYlNzLfn7FbB0x3N
 nBNI7h5BqlGGviOFhgR/tvkLf18dCmbF
 =h//X
 -END PGP PUBLIC KEY BLOCK-
+pub   1024D/EFB55DF1 2007-06-30
+  Key fingerprint = 50D7 C82A C193 34EA 3C75  699A F39F 187D EFB5 5DF1
+uid   [ unknown] Luciano Resende (Code Signing Key) 
+sub   2048g/463476A5 2007-06-30
+
+-BEGIN PGP PUBLIC KEY BLOCK-
+
+mQGiBEaFzM0RBACZtZH7GdUqfY2lSz2Scgh/Wki/NpNkVr+VXMx/1O1epn4+mSza
+fvXg7WHzg6G6T6neji7agbuOt9DCnZEC+W1PsLv/bZm7b5dZbe/7/L94ARhz9+27
+mSSHNwDaE3xSrBEFTcr85Z67Xsdz46hlUQaH0ZXP/ktgk+tnDi/DXa8hBwCgwPRK
+YOtBQ1ojNMc1XmvX8gBCDJUD/iKHkOe5xXHkMgw9BQNevTumiNeQZ6Sdwo5LEGv6
+iRwit1XD11sgM7e03umYrVvtK/DmpUN3ReSvPYQk6M7cMSBbUCM/9xSAkhmLK/6m
+/0DhsnXRewalmNaXXl+cZwfF+myza+ym8HXjQpSHumKFKTTRLEhXMVeFyJdxE2Pz
+CMhCA/97t6iv3+2oIT9859DRoAkjKA+tMiB2S2988MyWs+94n4wZ1jxQ1wiSzZLN
+WkqOpKlvCLzRgHvTkhwHpg2RFqcKdIx1lxGp+kgMk6wuRBLvE/Kw/vh02VW8FXOy
+lv5ne9i1EqSY2rW1o5N+0lntipBzP3MGjH2Js0jFQ2o7tfKzXLQ4THVjaWFubyBS
+ZXNlbmRlIChDb2RlIFNpZ25pbmcgS2V5KSA8bHJlc2VuZGVAYXBhY2hlLm9yZz6I
+YAQTEQIAIAUCRoXMzQIbAwYLCQgHAwIEFQIIAwQWAgMBAh4BAheAAAoJEPOfGH3v
+tV3xP1MAn1+Ozw4Kjm9JDQiucgbghH8H1JDCAKCjIwjTkpudi89ltvRNyq48zHN5
+I4hGBBIRAgAGBQJM1CTFAAoJEPQmjufy79DwvEMAn3G8oNCrsu2qRrhx665JcH4o
+sKF8AKCWq/lP3EA33WuaMTRwspAP6P3sqYh1BBARAgA1BQJM4lKiLhxKZWFuLVNl
+YmFzdGllbiBEZWxmaW5vIDxqc2RlbGZpbm9AYXBhY2hlLm9yZz4ACgkQpH0eLdAe
+DhiqHQCfeAwgQy1jMzSHneyw3inNdK945NUAoIVjfkmkIvdbs3c7daFEc0ksUSI1
+iMoEEBECAIoFAkzStEMfHEppbSBKYWdpZWxza2kgPGppbUBhcGFjaGUub3JnPiAc
+SmltIEphZ2llbHNraSA8amltQGphZ3VORVQuY29tPh8cSmltIEphZ2llbHNraSA8
+amltQGppbWphZy5jb20+IhxKaW0gSmFnaWVsc2tpIDxqaW1qQGNvdmFsZW50Lm5l
+dD4ACgkQizpgHwjJdeUYQwCffbmouN6c6lHylNkCxdLhjsOBwtoAnRuaK9u4ahsC
+Rw8BhTCdc6I0g+RwiQIcBBABCgAGBQJM0p96AAoJEJrilv0C6fZbGTIQAK2QrxQ3
+iiMPqYzGvrV2MwWnjpzfEb7z4KMvcy8DYiiPY3pVPgIw6MRMdetYfDggWgtfn8de
+yPJug48hg1gSBjJWIt6THVJzCO88jN+Z0JuA6u50EtrtAzV+1SWBOA7HJD6Hd+Ll
+QW9vAj3S1hkKUvoBKnolTAy211hNZs6329FnFOcb+Kq4oSbSazPBSbFxOIKwmX2X
+syaOgao7Hd+oAiapxyaKHz3nRE6oGvNe/eiA3xGih8HgsaDrZbDXqz46BB0eDkEj
+v8GelPqUEpJiYzOlzvkRU1WunoZCsUdhw1A2fF25jnOFPrCdA9P+SUKIQu1mm0+3
+bbUJ9aMed/aVzCbdxyPKaA+HZRYg+JHYAp6bVVZxzbtPzvbrvlck+CM0/4FwskEv
+uxlI5VpylrwcpDKFbe57iSATWB/7JBxrEjtQDeYrBlqw+1eCsw/xSQxeNd7PRDJ2
+L82sgxb32B9Fw6/fMt5o9dxkNU+cT/Gb8BuqtIwAwOvwPIBVzElQloo4VKuG3Q/x
+LeYsRXJhijo+ZHt4R2r+zkqk/MUBpr+uefby4/gfqv0SCGzBNiUIcrm0GqIDHgtS
+E9jZKfZ7+C+0WLtJM5VEAwFPE8QbBhV3TtMF0LVCkLSPGjDgPQ7umm34qk0XRQQQ
+BQSdoTVpqXef28dNzjRK45ee2LweVSHvUzkciQIcBBABCgAGBQJM0rYmAAoJEIJ4
+HeRtWVT6Dv4P/i2nS7py3wyvOi5mWN7dGfiCYiVgkrW1kaHgEBV5Z3n1cVOEYtMH
+aE/feJYVfEfmpBoS8S62XInayeBaHRpORS7gTP4KXRF+HpenRjWaSfVsUF9QpRWi
+fMM2L1ETFY9fPNs90Jeq43rXGnh4l6jgOG0zqQBEq7ZDXBZnnwMetGWj1kW7aXIL
+dBECJV4XZc1P+AW35oXQ4uz8vNbxKDSbgONzLsCkWUnHxivNtcg6Ajgz5csV/i4k
+uKg6pWVkCOrfzKIr8uoUoXBi6dG6hONzPYkOlN1+JA5PYxIA6P+vXFKICFbCDlMx
+Slsa3FhNM/Kzyg+kfrd/NA1pydqYu2b2rOEv8ygpg90kgASMWz6kaYbel4Tin/O5
+DNuxEux+BZ1k/LUAO2ngHTwaisZP4uFiVj59HTc4ANXzAMQvcg8iHsGSYW9wen35
+4JIM1QKfHMnXppc0+q7Uh2X2X6MEusSgIOEvRzQdC7/T/+EwoAjG2etdrTp1yleS
+sizy5DfKF3eSrsnuabhnlCLp/6qKSlDUzUqOxprLbN56D2w+67vYK6dAJSLCKi9N
+4Dz+ZK885+fFVMZ8GrGgvIv6NCcftIW640bJIXNccI2i3/6VeivXV4apeP5AZw8q
+9ann59z2p3HGqzz6cQDtIYflY7UV6xdxN3zURIlf73DVsYqU/KmOTEtkiQIcBBAB
+CgAGBQJNHE4+AAoJED/PUp/y8noG2TUP/i0y3jTLpEv6KY8bEtWhjx/lqFUz1NpT
+5TCzod8Z138KJ8vZufmpO/Tkt1+ckckZSSgnf7d7n9P8abbDneY31fqwc47+o4P1
+M47dgEkd2nKhQA4S2sx8ox0Qxs+NL4wuvH5MbdcTdytxr6g89jm58428s8GUsIEc
+jTbSRkN6NrXPZhpzgRKTCap7HzfScod5vlHdyBktIbRAZba1yanid+k7jWd/bqf7
+k94bKqoec8GzO5vhM4PvFOskVbf1C/uTH0GkKZ/xOCSCPcoivWG1ZBLtvnpFzUGv
+NpdGHuVPOPQ6dCeL2wQfUfmQGbuZW5uMQrYeFo9rPv4jiAS8ptF+upRvyQrknoud
+N7ap5xcEYQTGZSgrIdcBZ+ot8xIoCxDBQG0moi39UZewPf59t1RQEmOw0gtxfHI6
+W5k/3LKEScGv3xvnz4PUhvfVVNdqyD6Vvl602A4dAEEkDjAoNmRcCyyxZKzow+EG
+yi+cSyq3eMwFVVctesueSUwjgHcM0oE7LLloW6jjDMT/as34fnk39gcGOhMQmfEy
+uhjFzo0p4jPDCoY5b10yJA9aljpxD/vs+Xhf4OWHl7FD/cc8ZNAZEfzSKTXu0Uqf
+C3wi7RWd0YjhLLF52X2fcHyt+tBjsg+Gvx7wdS9Vmj9Hb6W75NXSGrE9K+wGixkH
+6xw8rMMcKwcpiQIiBBMBCgAMBQJXc4XuBYMHhh+AAAoJEKkkVPkXR4a0eWcP/2vo
+9W+f09Z2i3czTg0sXU7Q9fKF88iDqRgvJXO743vWoXL49Fdc8splv8opeWZ/yw59
+gOzrmcmaaUJyxW9O/ItNotERKE8nRCAIOu3Uq5uQ2hz8v8+HYLcTMjL1ZOCi9cvL
+O+0gF5WWPFIsqdr7Tu8aU2ACUTwO7Wcbb3ZoAEcFmYqqbu9t9QPi4ecEArlhhDH/
+mXWHmhrk1+EnDhghUbJKJd3zrdIbfMubCgUkZwQWlmxV/06jlWpe2QS+VlQ+SdCz
+gVywAvnUbKGzRALL2Ve4ZapNNa6+rkCr+3pnrv36MwVh9OpQ9E33CDfz1BxEAU9z
+D7tw+5Fd8kwu4ZBxmpPsCCBUaNeB0/2NmWXFAci1+UszZ4CCgBCMh8VMUaHGfJvG
+ywfKt94TEzsIT2GJZP/WpwnnK5Ea3qwa52rU8OgmCGiT0JVPCyF1KTjSJgcYtMy+
+AWlb9+VLd7DgtSJAlwC5oyCo+EwomJ3b3wTLHf0Nwxkdjy3+krAtn5N4aapZFb8O
+59CamFGlKMBTQmjlWZdm/gv1VAT0PRhcLjj+ieMDyROZx6IgePzPfhEl4++b+so1
+Wgh3wItTyH6S3gaExRGIdfUb7lKWtIeZsa6RHgk+KQhJhyhojidV1pHSU4co838Q
+0NQKwwOkf3gXMYDevrFQYvsR0/zn

bahir git commit: [MINOR] Update Scaladoc in MQTTWordCount example

2017-02-03 Thread ckadner 
Repository: bahir
Updated Branches:
  refs/heads/master cf0d74081 -> 695ca982d


[MINOR] Update Scaladoc in MQTTWordCount example

to match the more descriptive text from the Python example

Closes #35


Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/695ca982
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/695ca982
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/695ca982

Branch: refs/heads/master
Commit: 695ca982d2bb8606d7b40bbba11f3fe94ab5899e
Parents: cf0d740
Author: Prabeesh 
Authored: Fri Feb 3 02:21:32 2017 -0800
Committer: Christian Kadner 
Committed: Fri Feb 3 02:21:32 2017 -0800

--
 .../examples/streaming/mqtt/MQTTWordCount.scala | 31 +---
 1 file changed, 21 insertions(+), 10 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/bahir/blob/695ca982/streaming-mqtt/examples/src/main/scala/org/apache/spark/examples/streaming/mqtt/MQTTWordCount.scala
--
diff --git 
a/streaming-mqtt/examples/src/main/scala/org/apache/spark/examples/streaming/mqtt/MQTTWordCount.scala
 
b/streaming-mqtt/examples/src/main/scala/org/apache/spark/examples/streaming/mqtt/MQTTWordCount.scala
index e09e75e..bc41ffa 100644
--- 
a/streaming-mqtt/examples/src/main/scala/org/apache/spark/examples/streaming/mqtt/MQTTWordCount.scala
+++ 
b/streaming-mqtt/examples/src/main/scala/org/apache/spark/examples/streaming/mqtt/MQTTWordCount.scala
@@ -79,24 +79,35 @@ object MQTTPublisher {
 }
 
 /**
- * A sample wordcount with MqttStream stream
+ * A sample wordcount with MQTTInputDStream
  *
- * To work with Mqtt, Mqtt Message broker/server required.
- * Mosquitto (http://mosquitto.org/) is an open source Mqtt Broker
- * In ubuntu mosquitto can be installed using the command  `$ sudo apt-get 
install mosquitto`
- * Eclipse paho project provides Java library for Mqtt Client 
http://www.eclipse.org/paho/
- * Example Java code for Mqtt Publisher and Subscriber can be found here
- * https://bitbucket.org/mkjinesh/mqttclient
  * Usage: MQTTWordCount  
- *and  describe where Mqtt publisher is running.
  *
- * To run this example locally, you may run publisher as
+ * To run this example on your local machine, you first need to setup a MQTT 
broker and publisher,
+ * like Mosquitto (http://mosquitto.org/) an easy to use and install open 
source MQTT Broker.
+ * On Mac OS, Mosquitto can be installed with Homebrew `$ brew install 
mosquitto`.
+ * On Ubuntu, Mosquitto can be installed with the command `$ sudo apt-get 
install mosquitto`.
+ *
+ * Alternatively, checkout the Eclipse paho project which provides a number of 
clients and utilities
+ * for working with MQTT (http://www.eclipse.org/paho/#getting-started).
+ *
+ * How to run this example locally:
+ *
+ * (1) Start a MQTT message broker/server, i.e. Mosquitto:
+ *
+ *`$ mosquitto -p 1883`
+ *
+ * (2) Run the publisher:
+ *
  *`$ bin/run-example \
  *  org.apache.spark.examples.streaming.mqtt.MQTTPublisher 
tcp://localhost:1883 foo`
- * and run the example as
+ *
+ * (3) Run the example:
+ *
  *`$ bin/run-example \
  *  org.apache.spark.examples.streaming.mqtt.MQTTWordCount 
tcp://localhost:1883 foo`
  */
+
 object MQTTWordCount {
 
   def main(args: Array[String]) {