Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r158627640
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala
---
@@ -56,12 +57,13 @@ import org.apache.spark.util.Utils
* @param endpointUrl Url of Kinesis service (e.g.,
https://kinesis.us-east-1.amazonaws.com)
* @param regionName Region name used by the Kinesis Client Library for
* DynamoDB (lease coordination and checkpointing) and
CloudWatch (metrics)
- * @param initialPositionInStream In the absence of Kinesis checkpoint
info, this is the
+ * @param initialPosition Instance of [[KinesisInitialPosition]]
+ * In the absence of Kinesis checkpoint
info, this is the
--- End diff --
nit: indentation
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
