Github user budde commented on the issue:
https://github.com/apache/spark/pull/18029
My understanding of @brkyvz's suggestion is that you remove the two
```initialPositionInStream``` and ```initialPositionInStreamTimestamp```
arguments in favor of the single ```InitialPosition``` interface that can
represent all possible combinations of Kinesis initial positions. The builder
could construct the appropriate ```InitialPosition``` argument to pass to the
stream depending on the parameters provided to the builder.
I don't have strong opinions on where the interface and case
classes/objects should be defined but I think creating a new source file à la
SparkAWSCredentials.scala would be fine. I think making ```InitialPosition``` a
sealed trait would also make sense logically but that probably isn't super
important.
---
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]
