Interface MaskedResumable<Timestamp extends Comparable<Timestamp>>

All Superinterfaces:
Resumable<Timestamp>
All Known Implementing Classes:
DefaultMaskedTupleMemory, IdentityMaskedTupleMemory, MaskedTupleMemory, NullaryMaskedTupleMemory, TimelyDefaultMaskedTupleMemory, TimelyIdentityMaskedTupleMemory, TimelyNullaryMaskedTupleMemory, TimelyUnaryMaskedTupleMemory, UnaryMaskedTupleMemory

public interface MaskedResumable<Timestamp extends Comparable<Timestamp>> extends Resumable<Timestamp>
A masked Resumable implementation, which maintains lazy folding per tuple signature.
Since:
2.4
  • Method Details

    • resumeAt

      Map<Tuple,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.
    • getResumableSignatures

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