Noam Tamim created SPARK-36520: ---------------------------------- Summary: KinesisInitialPosition interface should be public Key: SPARK-36520 URL: https://issues.apache.org/jira/browse/SPARK-36520 Project: Spark Issue Type: Improvement Components: DStreams Affects Versions: 3.1.2 Reporter: Noam Tamim
In `org.apache.spark.streaming.kinesis` there's a Java interface `KinesisInitialPosition` - for some reason it's not public, so can't be used. The reason it needs to be used is simple: it is the parent of `KinesisInitialPositions.Latest` and `KinesisInitialPositions.TrimHorizon`. Without using it, it's impossible to pass instances of `Latest` and `TrimHorizon` around without calling them by name. The workaround is to use the enum `InitialPositionInStream` instead, and a factory method `fromKinesisInitialPosition(..)` - but it doesn't seem like the correct pattern. -- This message was sent by Atlassian Jira (v8.3.4#803005) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org