public interface UnmaskedResumable<Timestamp extends java.lang.Comparable<Timestamp>> extends Resumable<Timestamp>
Resumable
implementation, which maintains lazy folding without caring about tuple signatures.Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<Tuple> |
getResumableTuples()
Returns the set of tuples for which lazy folding shall be resumed at the next timestamp.
|
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,Diff<Timestamp>> resumeAt(Timestamp timestamp)
java.lang.Iterable<Tuple> getResumableTuples()