スパークAWS s3のフォルダからのストリーミング - PySpark

Question

awsに「input」というフォルダがあります。3.そのフォルダで作成された新しいファイルをストリーミングしたいです。私はこのコードを使用しています：

ssc = StreamingContext(sc, 10) 
rdd = ssc.textFileStream("s3n://dynamodbstream607/input/*") 

しかし、入力/ *が存在しないというエラーが表示されます。 S3のフォルダからストリームにスパークを取得するには

Answer 1

このPRによれば、2.0で利用可能になります。