InitialPositionInStream.
TRIM_HORIZON
previous
pyspark.streaming.kinesis.InitialPositionInStream.LATEST
next
MLlib (RDD-based)