InitialPositionInStream。
最新的
以前的
pyspark.streaming.kinesis.KinesisUtils.createStream
下一個
pyspark.streaming.kinesis.InitialPositionInStream.TRIM_HORIZON