aboutsummaryrefslogtreecommitdiff
path: root/R
diff options
context:
space:
mode:
authorAdam Budde <budde@amazon.com>2017-02-22 11:32:36 -0500
committerBurak Yavuz <brkyvz@gmail.com>2017-02-22 11:32:36 -0500
commite4065376d2b4eec178a119476fa95b26f440c076 (patch)
tree83d86c58abbd1c004daad6f30df5e544064491c8 /R
parent10c566cc3b5f93ddd823b1c987d9de8286cdea60 (diff)
downloadspark-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