Github user budde commented on the issue:
https://github.com/apache/spark/pull/17250
Open questions I'd like feedback on:
* Should the ```KinesisUtils.createStream()``` methods be marked as
deprecated?
* Should the ```KinesisUtils.createStream()``` methods be refactored to use
the builder?
* Should I add full docs for each method (e.g. including ```@param```
lists)?
* Does the file name and class name I've added seem reasonable?
* Is making the ctor args to ```KinesisInputDStream``` package private for
testing reasonable?
I'd like to also extend this to allow configuring CloudWatch and
DynamoDB-specific authorization which I imagine will be quite helpful to users.
I'm trying to decide if I should do this as a separate PR or just roll it in
here.
Pinging @brkyvz and @srown from #16744
---
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]
