|Modifier and Type||Method and Description|
ContinuousReader createContinuousReader(java.util.Optional<StructType> schema, String checkpointLocation, DataSourceOptions options)
ContinuousReaderto scan the data from this data source.
schema- the user provided schema, or empty() if none was provided
checkpointLocation- a path to Hadoop FS scratch space that can be used for failure recovery. Readers for the same logical source in the same query will be given the same checkpointLocation.
options- the options for the returned data source reader, which is an immutable case-insensitive string-to-string map.