public interface MaskedResumable<Timestamp extends java.lang.Comparable<Timestamp>> extends Resumable<Timestamp>
Resumable
implementation, which maintains lazy folding per tuple signature.Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<Tuple> |
getResumableSignatures()
Returns the set of signatures for which lazy folding shall be resumed at the next timestamp.
|
java.util.Map<Tuple,java.util.Map<Tuple,Diff<Timestamp>>> |
resumeAt(Timestamp timestamp)
When called, the folding of the state shall be resumed at the given timestamp.
|
getResumableTimestamp
java.util.Map<Tuple,java.util.Map<Tuple,Diff<Timestamp>>> resumeAt(Timestamp timestamp)
java.lang.Iterable<Tuple> getResumableSignatures()