diff options
author | Adam Budde <budde@amazon.com> | 2017-02-22 11:32:36 -0500 |
---|---|---|
committer | Burak Yavuz <brkyvz@gmail.com> | 2017-02-22 11:32:36 -0500 |
commit | e4065376d2b4eec178a119476fa95b26f440c076 (patch) | |
tree | 83d86c58abbd1c004daad6f30df5e544064491c8 /R | |
parent | 10c566cc3b5f93ddd823b1c987d9de8286cdea60 (diff) | |
download | spark-e4065376d2b4eec178a119476fa95b26f440c076.tar.gz spark-e4065376d2b4eec178a119476fa95b26f440c076.tar.bz2 spark-e4065376d2b4eec178a119476fa95b26f440c076.zip |
[SPARK-19405][STREAMING] Support for cross-account Kinesis reads via STS
- Add dependency on aws-java-sdk-sts
- Replace SerializableAWSCredentials with new SerializableCredentialsProvider interface
- Make KinesisReceiver take SerializableCredentialsProvider as argument and
pass credential provider to KCL
- Add new implementations of KinesisUtils.createStream() that take STS
arguments
- Make JavaKinesisStreamSuite test the entire KinesisUtils Java API
- Update KCL/AWS SDK dependencies to 1.7.x/1.11.x
## What changes were proposed in this pull request?
[JIRA link with detailed description.](https://issues.apache.org/jira/browse/SPARK-19405)
* Replace SerializableAWSCredentials with new SerializableKCLAuthProvider class that takes 5 optional config params for configuring AWS auth and returns the appropriate credential provider object
* Add new public createStream() APIs for specifying these parameters in KinesisUtils
## How was this patch tested?
* Manually tested using explicit keypair and instance profile to read data from Kinesis stream in separate account (difficult to write a test orchestrating creation and assumption of IAM roles across separate accounts)
* Expanded JavaKinesisStreamSuite to test the entire Java API in KinesisUtils
## License acknowledgement
This contribution is my original work and that I license the work to the project under the project’s open source license.
Author: Budde <budde@amazon.com>
Closes #16744 from budde/master.
Diffstat (limited to 'R')
0 files changed, 0 insertions, 0 deletions