[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407158#comment-15407158 ] ASF GitHub Bot commented on BAHIR-39: - Github user ScrapCodes commented on a diff in the

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user ScrapCodes commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73461705 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/utils/Logging.scala --- @@ -0,0 +1,25 @@ +/* + * Licensed to the Apache Software Foundat

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407153#comment-15407153 ] ASF GitHub Bot commented on BAHIR-39: - Github user ScrapCodes commented on a diff in the

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user ScrapCodes commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73461457 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSource.scala --- @@ -0,0 +1,191 @@ +/* + * Licensed to the

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407151#comment-15407151 ] ASF GitHub Bot commented on BAHIR-39: - Github user ScrapCodes commented on a diff in the

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user ScrapCodes commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73461326 --- Diff: sql-streaming-mqtt/README.md --- @@ -0,0 +1,121 @@ +A library for reading data from MQTT Servers using Spark SQL Streaming ( or Structured stre

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407144#comment-15407144 ] ASF GitHub Bot commented on BAHIR-39: - Github user ScrapCodes commented on a diff in the

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user ScrapCodes commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73461106 --- Diff: sql-streaming-mqtt/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister --- @@ -0,0 +1 @@ +org.apache.bahir.sq

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406636#comment-15406636 ] ASF GitHub Bot commented on BAHIR-39: - Github user frreiss commented on a diff in the pu

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user frreiss commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73423700 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSource.scala --- @@ -0,0 +1,191 @@ +/* + * Licensed to the Ap

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406625#comment-15406625 ] ASF GitHub Bot commented on BAHIR-39: - Github user frreiss commented on a diff in the pu

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user frreiss commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73422375 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSource.scala --- @@ -0,0 +1,191 @@ +/* + * Licensed to the Ap

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406621#comment-15406621 ] ASF GitHub Bot commented on BAHIR-39: - Github user frreiss commented on a diff in the pu

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user frreiss commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73422074 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSource.scala --- @@ -0,0 +1,191 @@ +/* + * Licensed to the Ap

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406522#comment-15406522 ] ASF GitHub Bot commented on BAHIR-39: - Github user lresende commented on the issue:

[GitHub] bahir issue #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user lresende commented on the issue: https://github.com/apache/bahir/pull/13 @ScrapCodes I added some comments, they should be easy to address. Also, I am ok if not all issues you mentioned above are finished before we commit this code, but I would appreciate if you could rais

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406507#comment-15406507 ] ASF GitHub Bot commented on BAHIR-39: - Github user lresende commented on a diff in the p

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user lresende commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73407125 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/utils/Logging.scala --- @@ -0,0 +1,25 @@ +/* + * Licensed to the Apache Software Foundatio

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406496#comment-15406496 ] ASF GitHub Bot commented on BAHIR-39: - Github user lresende commented on a diff in the p

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user lresende commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73406691 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/utils/BahirUtils.scala --- @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user lresende commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73406376 --- Diff: sql-streaming-mqtt/README.md --- @@ -0,0 +1,121 @@ +A library for reading data from MQTT Servers using Spark SQL Streaming ( or Structured stream

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406494#comment-15406494 ] ASF GitHub Bot commented on BAHIR-39: - Github user lresende commented on a diff in the p

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406490#comment-15406490 ] ASF GitHub Bot commented on BAHIR-39: - Github user lresende commented on a diff in the p

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user lresende commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73405744 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSource.scala --- @@ -0,0 +1,191 @@ +/* + * Licensed to the A

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406487#comment-15406487 ] ASF GitHub Bot commented on BAHIR-39: - Github user lresende commented on a diff in the p

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user lresende commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73405558 --- Diff: sql-streaming-mqtt/src/main/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSource.scala --- @@ -0,0 +1,191 @@ +/* + * Licensed to the A

[jira] [Commented] (BAHIR-39) MQTT as a streaming source for SQL Streaming.

[ https://issues.apache.org/jira/browse/BAHIR-39?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406478#comment-15406478 ] ASF GitHub Bot commented on BAHIR-39: - Github user lresende commented on a diff in the p

[GitHub] bahir pull request #13: [BAHIR-39] Add SQL Streaming MQTT support.

Github user lresende commented on a diff in the pull request: https://github.com/apache/bahir/pull/13#discussion_r73404347 --- Diff: sql-streaming-mqtt/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister --- @@ -0,0 +1 @@ +org.apache.bahir.sql.

[jira] [Commented] (BAHIR-31) Add documentation for streaming-zeromq connector

[ https://issues.apache.org/jira/browse/BAHIR-31?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406464#comment-15406464 ] ASF GitHub Bot commented on BAHIR-31: - Github user lresende closed the pull request at:

[jira] [Commented] (BAHIR-29) Add documentation for streaming-mqtt connector

[ https://issues.apache.org/jira/browse/BAHIR-29?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406466#comment-15406466 ] ASF GitHub Bot commented on BAHIR-29: - Github user lresende closed the pull request at:

[jira] [Commented] (BAHIR-30) Add documentation for streaming-twitter connector

[ https://issues.apache.org/jira/browse/BAHIR-30?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406465#comment-15406465 ] ASF GitHub Bot commented on BAHIR-30: - Github user lresende closed the pull request at:

[jira] [Commented] (BAHIR-28) Add documentation for streaming-akka connector

[ https://issues.apache.org/jira/browse/BAHIR-28?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406463#comment-15406463 ] ASF GitHub Bot commented on BAHIR-28: - Github user lresende closed the pull request at:

[GitHub] bahir pull request #16: [BAHIR-30] Add basic documentation for Twitter conne...

Github user lresende closed the pull request at: https://github.com/apache/bahir/pull/16 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] bahir pull request #18: [BAHIR-28] Add basic documentation for Akka connecto...

Github user lresende closed the pull request at: https://github.com/apache/bahir/pull/18 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] bahir pull request #17: [BAHIR-29] Add basic documentation for MQTT Connecto...

Github user lresende closed the pull request at: https://github.com/apache/bahir/pull/17 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] bahir pull request #15: [BAHIR-31] Add basic documentation for ZeroMQ connec...

Github user lresende closed the pull request at: https://github.com/apache/bahir/pull/15 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Closed] (BAHIR-29) Add documentation for streaming-mqtt connector

[ https://issues.apache.org/jira/browse/BAHIR-29?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende closed BAHIR-29. Resolution: Fixed Assignee: Luciano Resende Fix Version/s: 2.0.0 > Add documentation f

[jira] [Closed] (BAHIR-27) Add documentation for existing streaming connectors

[ https://issues.apache.org/jira/browse/BAHIR-27?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende closed BAHIR-27. Resolution: Fixed Assignee: Luciano Resende Fix Version/s: 2.0.0 > Add documentation f

[jira] [Closed] (BAHIR-28) Add documentation for streaming-akka connector

[ https://issues.apache.org/jira/browse/BAHIR-28?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende closed BAHIR-28. Resolution: Fixed Assignee: Luciano Resende Fix Version/s: 2.0.0 > Add documentation f

[jira] [Closed] (BAHIR-31) Add documentation for streaming-zeromq connector

[ https://issues.apache.org/jira/browse/BAHIR-31?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende closed BAHIR-31. Resolution: Fixed Assignee: Luciano Resende Fix Version/s: 2.0.0 > Add documentation f

[jira] [Closed] (BAHIR-30) Add documentation for streaming-twitter connector

[ https://issues.apache.org/jira/browse/BAHIR-30?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende closed BAHIR-30. Resolution: Fixed Assignee: Luciano Resende Fix Version/s: 2.0.0 > Add documentation f

[jira] [Commented] (BAHIR-29) Add documentation for streaming-mqtt connector

[ https://issues.apache.org/jira/browse/BAHIR-29?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406449#comment-15406449 ] ASF subversion and git services commented on BAHIR-29: -- Commit 619936d3

[jira] [Commented] (BAHIR-30) Add documentation for streaming-twitter connector

[ https://issues.apache.org/jira/browse/BAHIR-30?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406450#comment-15406450 ] ASF subversion and git services commented on BAHIR-30: -- Commit c78af705

[jira] [Commented] (BAHIR-31) Add documentation for streaming-zeromq connector

[ https://issues.apache.org/jira/browse/BAHIR-31?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406451#comment-15406451 ] ASF subversion and git services commented on BAHIR-31: -- Commit 29d8c762

[jira] [Commented] (BAHIR-28) Add documentation for streaming-akka connector

[ https://issues.apache.org/jira/browse/BAHIR-28?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406448#comment-15406448 ] ASF subversion and git services commented on BAHIR-28: -- Commit 858ad27a