Hi,

I am saving the output of my streaming process to s3.

I want to able to change the directory of the stream as an hour passes by.

Will this work:

parsed_kf_frame.saveAsTextFiles((s3_location).format(
        datetime.datetime.today().strftime("%Y%m%d"),
datetime.datetime.today().strftime("%H"), "prefix_key"), "csv")

Thank You!

Sid.

Reply via email to