bahir.git
2 years agoDisable OpenJDK builds on TravisCI branch-2.3
Luciano Resende [Wed, 11 Sep 2019 21:36:11 +0000 (14:36 -0700)] 
Disable OpenJDK builds on TravisCI

Temporarily disable openjdk8 due to platform issue
see https://github.com/michaelklishin/jdk_switcher/issues/20

2 years ago[BAHIR-217] Installation of Oracle JDK8 is Failing in Travis CI (#93)
abhishekd0907 [Wed, 11 Sep 2019 21:06:25 +0000 (14:06 -0700)] 
[BAHIR-217] Installation of Oracle JDK8 is Failing in Travis CI (#93)

Install of Oracle JDK 8 Failing in Travis CI and as a result,
build is failing for new pull requests.

We just need to add `dist: trusty` in the .travis.yml file
as mentioned in the issue below:
https://travis-ci.community/t/install-of-oracle-jdk-8-failing/3038

2 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Wed, 11 Sep 2019 17:01:25 +0000 (10:01 -0700)] 
[maven-release-plugin] prepare for next development iteration

2 years ago[maven-release-plugin] prepare release v2.3.4-rc1 v2.3.4 v2.3.4-rc1
Luciano Resende [Wed, 11 Sep 2019 17:01:05 +0000 (10:01 -0700)] 
[maven-release-plugin] prepare release v2.3.4-rc1

2 years agoSet Spark version to 2.3.4 preparing for release
Luciano Resende [Wed, 11 Sep 2019 16:48:08 +0000 (09:48 -0700)] 
Set Spark version to 2.3.4 preparing for release

3 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Sun, 19 May 2019 15:40:00 +0000 (17:40 +0200)] 
[maven-release-plugin] prepare for next development iteration

3 years ago[maven-release-plugin] prepare release v2.3.3-rc1 v2.3.3 v2.3.3-rc1
Luciano Resende [Sun, 19 May 2019 15:39:40 +0000 (17:39 +0200)] 
[maven-release-plugin] prepare release v2.3.3-rc1

3 years agoUpdate release script to support branches
Luciano Resende [Sun, 19 May 2019 15:26:06 +0000 (17:26 +0200)] 
Update release script to support branches

3 years agoPrepare for next development iteration
Luciano Resende [Sun, 19 May 2019 15:13:38 +0000 (17:13 +0200)] 
Prepare for next development iteration

3 years agoSet Spark version to 2.3.3 preparing for release
Luciano Resende [Sun, 19 May 2019 15:05:44 +0000 (17:05 +0200)] 
Set Spark version to 2.3.3 preparing for release

3 years ago[maven-release-plugin] prepare release v2.3.2-rc1 v2.3.2 v2.3.2-rc1
Luciano Resende [Fri, 30 Nov 2018 19:36:52 +0000 (20:36 +0100)] 
[maven-release-plugin] prepare release v2.3.2-rc1

3 years agoSet Spark version to 2.3.2 preparing for release
Luciano Resende [Fri, 30 Nov 2018 19:29:15 +0000 (20:29 +0100)] 
Set Spark version to 2.3.2 preparing for release

3 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Fri, 30 Nov 2018 15:30:31 +0000 (16:30 +0100)] 
[maven-release-plugin] prepare for next development iteration

3 years ago[maven-release-plugin] prepare release v2.3.1-rc1 v2.3.1 v2.3.1-rc1
Luciano Resende [Fri, 30 Nov 2018 15:30:13 +0000 (16:30 +0100)] 
[maven-release-plugin] prepare release v2.3.1-rc1

3 years agoSet Spark version to 2.3.1 preparing for release
Luciano Resende [Fri, 30 Nov 2018 14:56:22 +0000 (15:56 +0100)] 
Set Spark version to 2.3.1 preparing for release

3 years ago[MINOR] Update release script usage documentation
Luciano Resende [Fri, 30 Nov 2018 14:54:26 +0000 (15:54 +0100)] 
[MINOR] Update release script usage documentation

3 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Fri, 30 Nov 2018 13:34:43 +0000 (14:34 +0100)] 
[maven-release-plugin] prepare for next development iteration

3 years ago[maven-release-plugin] prepare release v2.3.0-rc1 v2.3.0 v2.3.0-rc1
Luciano Resende [Fri, 30 Nov 2018 13:34:25 +0000 (14:34 +0100)] 
[maven-release-plugin] prepare release v2.3.0-rc1

3 years ago[MINOR] Fix compilation/build warnings
Luciano Resende [Fri, 30 Nov 2018 12:26:57 +0000 (13:26 +0100)] 
[MINOR] Fix compilation/build warnings

Disable zinc to avoid build
Replace deprecated Timeouts with TimeLimits
Add imports for scala postfix function support

3 years ago[BAHIR-182] Spark Streaming PubNub connector
Lukasz Antoniak [Thu, 22 Nov 2018 22:28:44 +0000 (14:28 -0800)] 
[BAHIR-182] Spark Streaming PubNub connector

Implement new connector for PubNub (https://www.pubnub.com/)
which is increasing in popularity as a cloud messaging infrastructure.

Closes #70

3 years ago[BAHIR-66] Switch to Java binding for ZeroMQ
Lukasz Antoniak [Tue, 27 Nov 2018 14:58:42 +0000 (06:58 -0800)] 
[BAHIR-66] Switch to Java binding for ZeroMQ

Initially, I just wanted to implement integration test for BAHIR-66.
Google pointed me to JeroMQ, which provides official ZeroMQ binding
for Java and does not require native libraries. I have decided to give
it a try, but quickly realized that akka-zeromq module (transient
dependency from current Bahir master) is not compatible with JeroMQ.
Actually Akka team also wanted to move to JeroMQ (akka/akka#13856),
but in the end decided to remove akka-zeromq project completely
(akka/akka#15864, https://www.lightbend.com/blog/akka-roadmap-update-2014).

Having in mind that akka-zeromq does not support latest version of ZeroMQ
protocol and further development may come delayed, I have decided to refactor
streaming-zeromq implementation and leverage JeroMQ. With the change we receive
various benefits, such as support for PUB-SUB and PUSH-PULL messaging patterns
and the ability to bind the socket on whatever end of communication channel
(see test cases), subscription to multiple channels, etc. JeroMQ seems pretty
reliable and reconnection is handled out-of-the-box. Actually, we could even
start the ZeroMQ subscriber trying to connect to remote socket before other
end created and bound the socket. While I tried to preserve backward compatibility
of method signatures, there was no easy way to support Akka API and business
logic that users could put there (e.g. akka.actor.ActorSystem).

Closes #71

3 years ago[BAHIR-49] Sink for SQL Streaming MQTT module
Lukasz Antoniak [Mon, 9 Jul 2018 05:42:09 +0000 (07:42 +0200)] 
[BAHIR-49] Sink for SQL Streaming MQTT module

Closes #68

3 years ago[BAHIR-181] Add username and password in MQTTUtils for pyspark
zhankeyu [Thu, 1 Nov 2018 09:26:19 +0000 (17:26 +0800)] 
[BAHIR-181] Add username and password in MQTTUtils for pyspark

Closes #69

3 years ago[BAHIR-166] Migrate akka sql streaming source to DataSource v2 API
shimamoto [Thu, 31 May 2018 08:15:04 +0000 (17:15 +0900)] 
[BAHIR-166] Migrate akka sql streaming source to DataSource v2 API

Migrate akka sql streaming source to DataSource v2 API.

Closes #67

3 years ago[BAHIR-164][BAHIR-165] Port Mqtt sql source to datasource v2 API
Prashant Sharma [Fri, 27 Apr 2018 07:09:35 +0000 (12:39 +0530)] 
[BAHIR-164][BAHIR-165] Port Mqtt sql source to datasource v2 API

Migrating Mqtt spark structured streaming connector to DatasourceV2 API.

Closes #65

3 years ago[maven-release-plugin] prepare for next development iteration 2.x-before-datasource-v2
Luciano Resende [Thu, 8 Nov 2018 02:09:34 +0000 (18:09 -0800)] 
[maven-release-plugin] prepare for next development iteration

3 years ago[maven-release-plugin] prepare release v2.2.2-rc1 v2.2.2 v2.2.2-rc1
Luciano Resende [Thu, 8 Nov 2018 02:09:19 +0000 (18:09 -0800)] 
[maven-release-plugin] prepare release v2.2.2-rc1

3 years agoSet Spark version to 2.2.2 preparing for release
Luciano Resende [Thu, 8 Nov 2018 01:41:55 +0000 (17:41 -0800)] 
Set Spark version to 2.2.2 preparing for release

3 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Thu, 8 Nov 2018 01:09:52 +0000 (17:09 -0800)] 
[maven-release-plugin] prepare for next development iteration

3 years ago[maven-release-plugin] prepare release v2.1.3-rc1 v2.1.3 v2.1.3-rc1
Luciano Resende [Thu, 8 Nov 2018 01:09:37 +0000 (17:09 -0800)] 
[maven-release-plugin] prepare release v2.1.3-rc1

3 years agoSet Spark version to 2.1.3 preparing for release
Luciano Resende [Thu, 8 Nov 2018 01:02:41 +0000 (17:02 -0800)] 
Set Spark version to 2.1.3 preparing for release

3 years agoUpdate to Scala 2.11.12
Luciano Resende [Fri, 14 Sep 2018 01:58:14 +0000 (18:58 -0700)] 
Update to Scala 2.11.12

4 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Wed, 6 Jun 2018 15:23:06 +0000 (17:23 +0200)] 
[maven-release-plugin] prepare for next development iteration

4 years ago[maven-release-plugin] prepare release v2.2.1-rc1 v2.2.1 v2.2.1-rc1
Luciano Resende [Wed, 6 Jun 2018 15:22:49 +0000 (17:22 +0200)] 
[maven-release-plugin] prepare release v2.2.1-rc1

4 years agoSet Spark version to 2.2.1 preparing for release
Luciano Resende [Wed, 6 Jun 2018 13:05:37 +0000 (15:05 +0200)] 
Set Spark version to 2.2.1 preparing for release

4 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Fri, 1 Jun 2018 04:53:24 +0000 (21:53 -0700)] 
[maven-release-plugin] prepare for next development iteration

4 years ago[maven-release-plugin] prepare release v2.1.2-rc1 v2.1.2 v2.1.2-rc1
Luciano Resende [Fri, 1 Jun 2018 04:53:09 +0000 (21:53 -0700)] 
[maven-release-plugin] prepare release v2.1.2-rc1

4 years agoSet Spark version to 2.1.2 preparing for release
Luciano Resende [Wed, 30 May 2018 18:25:02 +0000 (11:25 -0700)] 
Set Spark version to 2.1.2 preparing for release

Update the Spark version to Spark 2.1.2 and update
necessary code to properly compile with the cited
spark version.

4 years agoUpdate twitter4j-streaming to latest version 4.0.5
Milad [Sat, 19 May 2018 08:10:09 +0000 (12:40 +0430)] 
Update twitter4j-streaming to latest version 4.0.5

Closes #66

4 years ago[BAHIR-162] Stop publishing MD5 hash with releases
Luciano Resende [Wed, 25 Apr 2018 19:22:03 +0000 (12:22 -0700)] 
[BAHIR-162] Stop publishing MD5 hash with releases

4 years ago[BAHIR-163] Enable builds using Travis CI
Luciano Resende [Wed, 25 Apr 2018 18:49:20 +0000 (11:49 -0700)] 
[BAHIR-163] Enable builds using Travis CI

4 years ago[BAHIR-154] Refactor sql-cloudant to use cloudant-client library
Esteban Laver [Sun, 17 Dec 2017 18:30:04 +0000 (13:30 -0500)] 
[BAHIR-154] Refactor sql-cloudant to use cloudant-client library

- Use java-cloudant’s executeRequest for HTTP requests against
  _all_docs endpoint
- Added HTTP 429 backoff with default settings
- Simplified caught exception and message for schema size
- Replaced scala http library with okhttp library for changes receiver
- Updated streaming CloudantReceiver class to use improved
  ChangesRowScanner method
- Replaced Play JSON with GSON library
- Updated save operation to use java-cloudant bulk API
- Use _changes feed filter option for Cloudant/CouchDB 2.x and greater

Closes #61

4 years ago[BAHIR-138] Fix deprecation warning messages
Esteban Laver [Fri, 12 Jan 2018 05:26:29 +0000 (00:26 -0500)] 
[BAHIR-138] Fix deprecation warning messages

- Imported ‘spark.implicits._’ to convert Spark RDD to Dataset
- Replaced deprecated `json(RDD[String])` with `json(Dataset[String])`

Closes #63

4 years ago[BAHIR-137] CouchDB/Cloudant _changes feed receiver improvements
Esteban Laver [Mon, 2 Oct 2017 15:09:28 +0000 (11:09 -0400)] 
[BAHIR-137] CouchDB/Cloudant _changes feed receiver improvements

Adds batchInterval option for tuning _changes receiver’s streaming batch interval
Throw a CloudantException if the final schema for the _changes receiver is empty
Call stop method in streaming receiver when there’s an error

Closes #60

4 years ago[BAHIR-104] Multi-topic MQTT DStream in Python is now a PairRDD.
Zubair Nabi [Wed, 29 Nov 2017 05:45:28 +0000 (10:45 +0500)] 
[BAHIR-104] Multi-topic MQTT DStream in Python is now a PairRDD.

Closes #55

4 years ago[BAHIR-138] fix deprecated warnings in sql-cloudant
Esteban Laver [Mon, 2 Oct 2017 20:18:40 +0000 (16:18 -0400)] 
[BAHIR-138] fix deprecated warnings in sql-cloudant

Fix warnings in DefaultSource class, and in CloudantStreaming
and CloudantStreamingSelector examples.

How

Imported spark.implicits._ to convert Spark RDD to Dataset
Replaced deprecated json(RDD[String]) with json(Dataset[String])
Improved streaming examples:

Replaced registerTempTable with preferred createOrReplaceTempView
Replaced !isEmpty with nonEmpty
Use an accessible sales database so users can run the example without any setup
Fixed error message when stopping tests by adding logic to streaming
receiver to not store documents in Spark memory when stream has stopped

Closes #59

4 years ago[BAHIR-128] Improve sql-cloudant _changes receiver
Esteban Laver [Fri, 8 Sep 2017 14:33:26 +0000 (10:33 -0400)] 
[BAHIR-128] Improve sql-cloudant _changes receiver

This change improves the stability of _changes receiver and
fix the intermitent failing test in sql-cloudant's
CloudantChangesDFSuite.

How

Improve performance and decrease testing time by setting batch size
to 8 seconds and using seq_interval _changes feed option.
Use getResource to load json files path
Added Mike Rhodes's ChangesRowScanner for reading each _changes line
and transforming to GSON's JSON object
Added Mike Rhodes's ChangesRow representing a row in the changes feed

Closes #57

4 years agoEnforce License Header in Java Sources
Christian Kadner [Sun, 10 Dec 2017 11:15:04 +0000 (03:15 -0800)] 
Enforce License Header in Java Sources

Add a "Header" rule to the checkstyle configuration
to enforce proper Apache license headers in Java
source files.

A similar rule ("HeaderMatchesChecker") already exists
in the scalastyle configuration.

Closes #58

4 years ago[BAHIR-149] Update Cloudant dependency to release 2.11.0
Luciano Resende [Tue, 5 Dec 2017 22:08:52 +0000 (23:08 +0100)] 
[BAHIR-149] Update Cloudant dependency to release 2.11.0

4 years ago[BAHIR-148] Use consistent MQTT client dependency version
Luciano Resende [Tue, 5 Dec 2017 21:55:42 +0000 (22:55 +0100)] 
[BAHIR-148] Use consistent MQTT client dependency version

Create a property to use a consistent version of the MQTT
client across all extensions based on MQTT.

For now, use org.eclipse.paho.client.mqttv3:1.1.0

4 years ago[BAHIR-139] Force scala-maven-plugin to use java.version
Christian Kadner [Sat, 14 Oct 2017 02:16:23 +0000 (19:16 -0700)] 
[BAHIR-139] Force scala-maven-plugin to use java.version

Make sure the scala-maven-plugin uses java.version 1.8 instead of the
default source and target version which is Java 1.6.

Upgrade the scala-maven-plugin version from 3.2.2 to 3.3.1

Closes #51

4 years ago[BAHIR-123] Upgrade to play-json 2.6.6
Esteban Laver [Wed, 4 Oct 2017 19:58:50 +0000 (15:58 -0400)] 
[BAHIR-123] Upgrade to play-json 2.6.6

Fixed breaking API changes between play-json 2.5.x and 2.6.x
in sql-cloudant by replacing deprecated methods.

Closes #50

4 years ago[MINOR] Clean any sha signature files during release process
Luciano Resende [Thu, 17 Aug 2017 04:50:16 +0000 (22:50 -0600)] 
[MINOR] Clean any sha signature files during release process

4 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Thu, 17 Aug 2017 04:36:35 +0000 (22:36 -0600)] 
[maven-release-plugin] prepare for next development iteration

4 years ago[maven-release-plugin] prepare release v2.2.0-rc1 v2.2.0 v2.2.0-rc1
Luciano Resende [Thu, 17 Aug 2017 04:36:17 +0000 (22:36 -0600)] 
[maven-release-plugin] prepare release v2.2.0-rc1

4 years ago[MINOR] Fix javadoc issues when performing release:prepare
Luciano Resende [Thu, 17 Aug 2017 04:28:14 +0000 (22:28 -0600)] 
[MINOR] Fix javadoc issues when performing release:prepare

The maven-javadoc-plugin was complaining with 'javadoc: error -
No public or protected classes found to document.' when running
maven release:prepare.

4 years ago[MINOR] Skip Scala 2.10 when publishing release artifacts
Luciano Resende [Thu, 17 Aug 2017 04:19:35 +0000 (22:19 -0600)] 
[MINOR] Skip Scala 2.10 when publishing release artifacts

Skip Scala 2.10 as a few of the extension dependencies are
not published in Scala 2.10 binaries.

4 years ago[MINOR] Update signature algorithm in release script
Luciano Resende [Thu, 17 Aug 2017 04:18:40 +0000 (22:18 -0600)] 
[MINOR] Update signature algorithm in release script

4 years ago[BAHIR-126] Update Akka to version 2.4.20
Luciano Resende [Wed, 16 Aug 2017 16:22:13 +0000 (10:22 -0600)] 
[BAHIR-126] Update Akka to version 2.4.20

Address akka vulnerability: CVE-2017-5643

4 years ago[MINOR] Use jekyll template to describe Spark and Scala version
Luciano Resende [Tue, 15 Aug 2017 19:27:19 +0000 (13:27 -0600)] 
[MINOR] Use jekyll template to describe Spark and Scala version

4 years ago[BAHIR-122][PubSub] Make "ServiceAccountCredentials" really broadcastable
Ire Sun [Tue, 1 Aug 2017 09:00:58 +0000 (02:00 -0700)] 
[BAHIR-122][PubSub] Make "ServiceAccountCredentials" really broadcastable

Instead of requiring key files on each instance of the cluster, we read
the key file content on the driver node and store the binary in the
ServiceAccountCredentials. When the provider is called, it retrieves the
credential with the in-memory key file.

Closes #48

4 years ago[BAHIR-125] Update Bahir parent pom
Luciano Resende [Wed, 26 Jul 2017 17:33:04 +0000 (10:33 -0700)] 
[BAHIR-125] Update Bahir parent pom

- Default build using JAVA 8
- Update dependencies to align with Spark 2.2.0

4 years ago[BAHIR-124] Update Spark depedency to version 2.2.0
Luciano Resende [Wed, 26 Jul 2017 17:34:27 +0000 (10:34 -0700)] 
[BAHIR-124] Update Spark depedency to version 2.2.0

4 years ago[BAHIR-110] Implement _changes API for sql-cloudant
Esteban Laver [Wed, 26 Jul 2017 05:53:58 +0000 (22:53 -0700)] 
[BAHIR-110] Implement _changes API for sql-cloudant

 - support loading Cloudant data into Spark DataFrames and SQL tables
   using '_changes' endpoint
 - update README to explain the new config options and differences
   between '_all_docs' and '_changes' endpoints when loading data
 - Add test suite to test Spark DataFrames using the '_all_docs' and
   '_changes' endpoint, assert Cloudant config options, and test Spark
   SQL temporary views

Closes #45

4 years ago[MINOR] Fix copy+paste typo
Luciano Resende [Thu, 20 Jul 2017 01:24:04 +0000 (18:24 -0700)] 
[MINOR] Fix copy+paste typo

4 years ago[BAHIR-100] Enhance MQTT connector to support byte arrays
drosenst [Wed, 5 Jul 2017 20:41:02 +0000 (23:41 +0300)] 
[BAHIR-100] Enhance MQTT connector to support byte arrays

Closes #47

5 years ago[MINOR] Fix data file path in the streaming-twitter sample app
Dheeraj Dwivedi [Sat, 24 Jun 2017 07:49:40 +0000 (13:19 +0530)] 
[MINOR] Fix data file path in the streaming-twitter sample app

Closes #46

5 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Thu, 8 Jun 2017 04:36:50 +0000 (21:36 -0700)] 
[maven-release-plugin] prepare for next development iteration

5 years ago[maven-release-plugin] prepare release v2.1.1-rc2 v2.1.1 v2.1.1-rc2
Luciano Resende [Thu, 8 Jun 2017 04:36:35 +0000 (21:36 -0700)] 
[maven-release-plugin] prepare release v2.1.1-rc2

5 years ago[BAHIR-88] Add release:prepare statement back to script
Luciano Resende [Thu, 8 Jun 2017 04:32:39 +0000 (21:32 -0700)] 
[BAHIR-88] Add release:prepare statement back to script

5 years ago[BAHIR-88] Additional fixes to produce proper rc distribution
Luciano Resende [Thu, 8 Jun 2017 04:28:58 +0000 (21:28 -0700)] 
[BAHIR-88] Additional fixes to produce proper rc distribution

5 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Thu, 8 Jun 2017 03:18:58 +0000 (20:18 -0700)] 
[maven-release-plugin] prepare for next development iteration

5 years ago[maven-release-plugin] prepare release v2.1.1-rc1 v2.1.1-rc1
Luciano Resende [Thu, 8 Jun 2017 03:18:43 +0000 (20:18 -0700)] 
[maven-release-plugin] prepare release v2.1.1-rc1

5 years ago[BAHIR-88] Produce distributions without release temp files
Luciano Resende [Thu, 8 Jun 2017 03:13:45 +0000 (20:13 -0700)] 
[BAHIR-88] Produce distributions without release temp files

5 years ago[MINOR] Add checkpoint directory to git ignore configuration
Luciano Resende [Wed, 7 Jun 2017 04:10:27 +0000 (21:10 -0700)] 
[MINOR] Add checkpoint directory to git ignore configuration

5 years ago[BAHIR-116] Add spark streaming connector to Google Cloud Pub/Sub
Chen Bin [Thu, 27 Apr 2017 09:18:32 +0000 (17:18 +0800)] 
[BAHIR-116] Add spark streaming connector to Google Cloud Pub/Sub

Cloases #42.

5 years ago[BAHIR-120] Akka SQL Streaming build fails with Apache Spark 2.1.1
Subhobrata Dey [Wed, 31 May 2017 06:43:39 +0000 (23:43 -0700)] 
[BAHIR-120] Akka SQL Streaming build fails with Apache Spark 2.1.1

Closes #44.

5 years ago[BAHIR-117] Expand filtering options for TwitterInputDStream
Clemens Wolff [Thu, 4 May 2017 19:52:54 +0000 (12:52 -0700)] 
[BAHIR-117] Expand filtering options for TwitterInputDStream

Adds a new method to TwitterUtils that enables users to pass
an arbitrary FilterQuery down to the TwitterReceiver.

This enables use-cases like receiving Tweets based on location,
based on handle, etc. Previously users were only able to receive
Tweets based on disjunctive keyword queries.

Closes #43.

5 years ago[MINOR] Update Spark dependency to release 2.1.1
Luciano Resende [Thu, 18 May 2017 04:42:17 +0000 (00:42 -0400)] 
[MINOR] Update Spark dependency to release 2.1.1

5 years ago[BAHIR-102] Initial support of Cloudant Query and examples
Yang Lei [Fri, 7 Apr 2017 23:23:43 +0000 (19:23 -0400)] 
[BAHIR-102] Initial support of Cloudant Query and examples

Add optimization to use query in particular scenarios.

Closes #41.

5 years ago[MINOR] Tweaking assembly naming
Luciano Resende [Thu, 13 Apr 2017 19:05:23 +0000 (12:05 -0700)] 
[MINOR] Tweaking assembly naming

5 years ago[MINOR] Update supported signatures
Luciano Resende [Thu, 13 Apr 2017 18:49:36 +0000 (11:49 -0700)] 
[MINOR] Update supported signatures

5 years ago[BAHIR-101] Update sql-cloudant readme and python examples
Esteban Laver [Mon, 3 Apr 2017 22:05:44 +0000 (18:05 -0400)] 
[BAHIR-101] Update sql-cloudant readme and python examples

Closes #40.

5 years ago[BAHIR-97] Akka as SQL Streaming datasource.
Subhobrata Dey [Mon, 27 Mar 2017 04:30:30 +0000 (21:30 -0700)] 
[BAHIR-97] Akka as SQL Streaming datasource.

Closes #38.

5 years ago[BAHIR-101] Spark SQL datasource for CounchDB/Cloudant
Yang Lei [Wed, 29 Mar 2017 21:32:51 +0000 (17:32 -0400)] 
[BAHIR-101] Spark SQL datasource for CounchDB/Cloudant

Initial code supporting CounchDB/Cloudant as an Spark SQL
data source. The initial source contains the core connector,
examples, and basic documentation on the README.

Closes #39.

5 years ago[MINOR] Re-add .gitignore and .gitattributes
Christian Kadner [Tue, 28 Mar 2017 06:23:35 +0000 (23:23 -0700)] 
[MINOR] Re-add .gitignore and .gitattributes

The two files accidentally got removed in commit 826545c

5 years ago[BAHIR-89] Multi topic API support for streaming MQTT
Anntinu [Mon, 27 Feb 2017 02:07:07 +0000 (07:37 +0530)] 
[BAHIR-89] Multi topic API support for streaming MQTT

New API which accept array of MQTT topics as input
and return Tuple2<TopicName, Message> as output.

It helps consume from multiple MQTT topics with
efficient user of resources.

Closes #37.

5 years ago[MINOR] Code Style Fixes for Akka Example
Scott Walker [Thu, 23 Feb 2017 14:13:12 +0000 (14:13 +0000)] 
[MINOR] Code Style Fixes for Akka Example

* mutable LinkedHashSet must be prefixed
* use interpolated string formatting

Closes #36

5 years ago[maven-release-plugin] prepare for next development iteration
Christian Kadner [Sat, 4 Feb 2017 04:21:59 +0000 (20:21 -0800)] 
[maven-release-plugin] prepare for next development iteration

5 years ago[maven-release-plugin] prepare release v2.1.0-rc1 v2.1.0 v2.1.0-rc1
Christian Kadner [Sat, 4 Feb 2017 04:21:39 +0000 (20:21 -0800)] 
[maven-release-plugin] prepare release v2.1.0-rc1

5 years ago[BAHIR-87] Prepare release based on Apache Spark 2.1.0
Christian Kadner [Sat, 4 Feb 2017 03:02:31 +0000 (19:02 -0800)] 
[BAHIR-87] Prepare release based on Apache Spark 2.1.0

5 years ago[MINOR] Update Scaladoc in MQTTWordCount example
Prabeesh [Fri, 3 Feb 2017 10:21:32 +0000 (02:21 -0800)] 
[MINOR] Update Scaladoc in MQTTWordCount example

to match the more descriptive text from the Python example

Closes #35

5 years ago[MINOR] Fix Maven artifact IDs in README.md files
Christian Kadner [Sat, 28 Jan 2017 13:37:36 +0000 (05:37 -0800)] 
[MINOR] Fix Maven artifact IDs in README.md files

The spark-shell usage examples show an underscore instead of a dash in
the Maven artifact ID ("spark-streaming_xxx" vs "spark-streaming-xxx").
Consequently Spark can not resolve these broken Maven coordinates.

  $ bin/spark-shell \
      --packages org.apache.bahir:spark-streaming_akka_2.11:2.0.2

  $ bin/spark-shell \
      --packages org.apache.bahir:spark-streaming-akka_2.11:2.0.2

5 years ago[maven-release-plugin] prepare for next development iteration
Christian Kadner [Sat, 21 Jan 2017 00:43:56 +0000 (16:43 -0800)] 
[maven-release-plugin] prepare for next development iteration

5 years ago[maven-release-plugin] prepare release v2.0.2-rc3 v2.0.2 v2.0.2-rc3
Christian Kadner [Sat, 21 Jan 2017 00:43:42 +0000 (16:43 -0800)] 
[maven-release-plugin] prepare release v2.0.2-rc3

5 years ago[MINOR] Prompt for PGP passphrase when not exported
Christian Kadner [Tue, 17 Jan 2017 20:26:52 +0000 (12:26 -0800)] 
[MINOR] Prompt for PGP passphrase when not exported

The Release plugin forks the current Maven session but does not
propagated the system properties to the forked Maven session.
Therefore we need to pass the "-Dgpg.passphrase" wrapped inside
the "-Darguments" parameter.

http://maven.apache.org/plugins/maven-gpg-plugin/usage.html

Prompt for the GPG passphrase if the GPG_PASSPHRASE environment
variable was not exported.

Closes #34

5 years ago[BAHIR-84] Suppress Parquet-MR build log messages
Christian Kadner [Thu, 12 Jan 2017 08:07:02 +0000 (00:07 -0800)] 
[BAHIR-84] Suppress Parquet-MR build log messages

Since Parquet-MR (1.7.0) uses Java Simple Logging (not Log4j) we
need to add a logging.properties file and add it to the configuration
of the maven-surefire-plugin and scalatest-maven-plugin.
Since Parquet-MR is logging everything to System.out despite log file
handler settings we raise the threshold to ERROR.

https://github.com/Parquet/parquet-mr/issues/390
https://github.com/Parquet/parquet-mr/issues/425

Closes #33

5 years ago[MINOR] update ImportOrderChecker
Christian Kadner [Mon, 9 Jan 2017 22:46:17 +0000 (14:46 -0800)] 
[MINOR] update ImportOrderChecker

Update Scalastyle configuration to group org.apache.bahir.* import statements below org.apache.spark.* imports

Closes #30

5 years ago[BAHIR-83] ignore test case "Send and receive 100 messages."
Christian Kadner [Wed, 18 Jan 2017 08:00:28 +0000 (00:00 -0800)] 
[BAHIR-83] ignore test case "Send and receive 100 messages."

5 years ago[maven-release-plugin] prepare for next development iteration
Luciano Resende [Wed, 11 Jan 2017 02:22:07 +0000 (18:22 -0800)] 
[maven-release-plugin] prepare for next development iteration