Details
-
Improvement
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
3.1.0
-
None
-
None
Description
Implement the following options while performing structured streaming from a file data source:
startingOffsetsByTimestamp endingOffsetsByTimestamp startingOffsets endingOffsets
These options currently exist when using structured streaming from a Kafka data source.
Please see comments from the below PR for details.
https://github.com/apache/spark/pull/28841
Example from usage with Kafka data source
http://spark.apache.org/docs/latest/structured-streaming-kafka-integration.html#creating-a-kafka-source-for-batch-queries