DeltaReadOptions¶
DeltaReadOptions is an extension of the DeltaOptionParser abstraction with the values of the read options of DeltaOptions.
excludeRegex¶
excludeRegex: Option[Regex]
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: Boolean
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: Boolean
ignoreChanges...FIXME
ignoreChanges is used when:
- FIXME
ignoreDeletes¶
ignoreDeletes: Boolean
ignoreDeletes...FIXME
ignoreDeletes is used when:
- FIXME
ignoreFileDeletion¶
ignoreFileDeletion: Boolean
ignoreFileDeletion...FIXME
ignoreFileDeletion is used when:
- FIXME
maxBytesPerTrigger¶
maxBytesPerTrigger: Option[Long]
maxBytesPerTrigger...FIXME
maxBytesPerTrigger is used when:
- FIXME
maxFilesPerTrigger¶
maxFilesPerTrigger: Option[Int]
maxFilesPerTrigger...FIXME
maxFilesPerTrigger is used when:
- FIXME
readChangeFeed¶
readChangeFeed: Boolean
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: Option[String]
startingTimestamp...FIXME
startingTimestamp is used when:
- FIXME
startingVersion¶
startingVersion: Option[DeltaStartingVersion]
startingVersion...FIXME
startingVersion is used when:
- FIXME