pyspark.streaming.kinesis.InitialPositionInStream.TRIM_HORIZON

InitialPositionInStream.TRIM_HORIZON = 1

previous

pyspark.streaming.kinesis.InitialPositionInStream.LATEST

next

MLlib (RDD-based)