pyspark.streaming.kinesis.InitialPositionInStream.TRIM_HORIZON# InitialPositionInStream.TRIM_HORIZON = 1#