Interface UnmaskedResumable<Timestamp extends Comparable<Timestamp>>

All Superinterfaces:
Resumable<Timestamp>
All Known Implementing Classes:
TimelyMemory

public interface UnmaskedResumable<Timestamp extends Comparable<Timestamp>> extends Resumable<Timestamp>
A unmasked Resumable implementation, which maintains lazy folding without caring about tuple signatures.
Since:
2.4
  • Method Details

    • resumeAt

      Map<Tuple,Diff<Timestamp>> resumeAt(Timestamp timestamp)
      When called, the folding of the state shall be resumed at the given timestamp. The resumable is expected to do a folding step at the given timestamp only. Afterwards, folding shall be interrupted, even if there is more folding to do towards higher timestamps.
    • getResumableTuples

      Iterable<Tuple> getResumableTuples()
      Returns the set of tuples for which lazy folding shall be resumed at the next timestamp.