IndexedChangeFileSeq¶

Creating Instance¶

IndexedChangeFileSeq takes the following to be created:

• IndexedFiles (Iterator[IndexedFile])
• isInitialSnapshot flag

IndexedChangeFileSeq is created when:

• DeltaSourceCDCSupport is requested to getFileChangesForCDC

isInitialSnapshot Flag¶

IndexedChangeFileSeq is given isInitialSnapshot flag when created:

• true for DeltaSourceCDCSupport when getFileChangesForCDC with isStartingVersion flag on
• false for DeltaSourceCDCSupport when filterAndIndexDeltaLogs (while getFileChangesForCDC)

filterFiles¶

filterFiles(
  fromVersion: Long,
  fromIndex: Long,
  limits: Option[AdmissionLimits],
  endOffset: Option[DeltaSourceOffset] = None): Iterator[IndexedFile]

filterFiles...FIXME

filterFiles is used when:

• DeltaSourceCDCSupport is requested to getFileChangesForCDC

isValidIndexedFile¶

isValidIndexedFile(
  indexedFile: IndexedFile,
  fromVersion: Long,
  fromIndex: Long,
  endOffset: Option[DeltaSourceOffset]): Boolean

isValidIndexedFile...FIXME

isValidIndexedFile is used when:

• IndexedChangeFileSeq is requested to filterFiles

moreThanFrom¶

moreThanFrom(
  indexedFile: IndexedFile,
  fromVersion: Long,
  fromIndex: Long): Boolean

moreThanFrom...FIXME