pyspark.streaming.kinesis.InitialPositionInStream.TRIM_HORIZON

InitialPositionInStream.TRIM_HORIZON = 1