Interface UnmaskedResumable<Timestamp extends java.lang.Comparable<Timestamp>>

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

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

      • resumeAt

        java.util.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

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