GitHub user budde opened a pull request:
https://github.com/apache/spark/pull/17250
[SPARK-19911][STREAMING] Add builder interface for Kinesis DStreams
## What changes were proposed in this pull request?
- Add new KinesisDStream.scala containing KinesisDStream.Builder class
- Add KinesisDStreamBuilderSuite test suite
- Make KinesisInputDStream ctor args package private for testing
## How was this patch tested?
Added ```KinesisDStreamBuilderSuite``` to verify builder class works as
expected
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/budde/spark KinesisStreamBuilder
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/17250.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #17250
----
commit 8552caf84dbd5b43a5a8446b10e4ccf9b295f924
Author: Budde <[email protected]>
Date: 2017-02-23T22:53:50Z
[SPARK-19911][STREAMING] Add builder interface for Kinesis DStreams
- Add new KinesisDStream.scala containing KinesisDStream.Builder class
- Add KinesisDStreamBuilderSuite test suite
- Make KinesisInputDStream ctor args package private for testing
----
---
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 enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
