Interface IncrementalScan<ThisT,​T extends ScanTask,​G extends ScanTaskGroup<T>>

    • Method Detail

      • fromSnapshotInclusive

        ThisT fromSnapshotInclusive​(long fromSnapshotId)
        Instructs this scan to look for changes starting from a particular snapshot (inclusive).

        If the start snapshot is not configured, it is defaulted to the oldest ancestor of the end snapshot (inclusive).

        Parameters:
        fromSnapshotId - the start snapshot ID (inclusive)
        Returns:
        this for method chaining
        Throws:
        java.lang.IllegalArgumentException - if the start snapshot is not an ancestor of the end snapshot
      • fromSnapshotExclusive

        ThisT fromSnapshotExclusive​(long fromSnapshotId)
        Instructs this scan to look for changes starting from a particular snapshot (exclusive).

        If the start snapshot is not configured, it is defaulted to the oldest ancestor of the end snapshot (inclusive).

        Parameters:
        fromSnapshotId - the start snapshot ID (exclusive)
        Returns:
        this for method chaining
        Throws:
        java.lang.IllegalArgumentException - if the start snapshot is not an ancestor of the end snapshot
      • toSnapshot

        ThisT toSnapshot​(long toSnapshotId)
        Instructs this scan to look for changes up to a particular snapshot (inclusive).

        If the end snapshot is not configured, it is defaulted to the current table snapshot (inclusive).

        Parameters:
        toSnapshotId - the end snapshot ID (inclusive)
        Returns:
        this for method chaining