TahoeChangeFileIndex¶

TahoeChangeFileIndex is a TahoeFileIndexWithSnapshotDescriptor of AddCDCFiles for changesToDF in Change Data Feed.

Creating Instance¶

TahoeChangeFileIndex takes the following to be created:

• SparkSession (Spark SQL)
• CDCDataSpecs of AddCDCFile
• DeltaLog
• Path
• SnapshotDescriptor

TahoeChangeFileIndex is created when:

• CDCReaderImpl is requested to changesToDF

matchingFiles¶

matchingFiles(
  partitionFilters: Seq[Expression],
  dataFilters: Seq[Expression]): Seq[AddFile]

matchingFiles...FIXME

inputFiles¶

inputFiles: Array[String]

inputFiles is the absolute paths of all the AddCDCFiles of the CDCDataSpecs.