InitialPositionInStream。
TRIM_HORIZON
以前的
pyspark.streaming.kinesis.InitialPositionInStream.LATEST
下一個
MLlib (RDD-based)