DeltaReadOptions¶
DeltaReadOptions is an extension of the DeltaOptionParser abstraction with the values of the read options of DeltaOptions.
excludeRegex¶
excludeRegex uses the options for the value of excludeRegex option and converts it to a scala.util.matching.Regex.
excludeRegex is used when:
DeltaSourceis requested for the excludeRegex
failOnDataLoss¶
failOnDataLoss uses the options for the value of failOnDataLoss option.
failOnDataLoss is true by default.
failOnDataLoss is used when:
DeltaSourceis requested to getFileChangesDeltaSourceCDCSupportis requested to getFileChangesForCDC
ignoreChanges¶
ignoreChanges...FIXME
ignoreChanges is used when:
- FIXME
ignoreDeletes¶
ignoreDeletes...FIXME
ignoreDeletes is used when:
- FIXME
ignoreFileDeletion¶
ignoreFileDeletion...FIXME
ignoreFileDeletion is used when:
- FIXME
maxBytesPerTrigger¶
maxBytesPerTrigger...FIXME
maxBytesPerTrigger is used when:
- FIXME
maxFilesPerTrigger¶
maxFilesPerTrigger...FIXME
maxFilesPerTrigger is used when:
- FIXME
readChangeFeed¶
readChangeFeed uses the options for the boolean value of readChangeFeed option (if available or falls back to the legacy readChangeData).
DeltaDataSource
Also known as CDC_ENABLED_KEY.
readChangeFeed is used when DeltaSourceBase is requested for the following:
- checkReadIncompatibleSchemaChanges
- getFileChangesAndCreateDataFrame (for the
DeltaSourceto get a streaming micro-batch dataframe) - getFileChangesWithRateLimit (for
DeltaSourceto determine the latest offset) - The read schema
startingTimestamp¶
startingTimestamp...FIXME
startingTimestamp is used when:
- FIXME
startingVersion¶
startingVersion...FIXME
startingVersion is used when:
- FIXME