THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
package org.apache.kafka.streams.state;
public final class VersionedRecord<V> {
/**
* Create a new {@link VersionedRecord} instance. {@code value} cannot be {@code null}.
*
* @param value the value
* @param timestamp the timestamp
*/
public VersionedRecord(final V value, final long timestamp) {
this.value = Objects.requireNonNull(value);
this.timestamp = timestamp;
this.validTo = Long.MAX_VALUE;
}
/**
* Create a new {@link VersionedRecord} instance. {@code value} cannot be {@code null}.
*
* @param value the value
* @param timestamp the timestamp
* @param validTo the latest exclusive timestamp that value is valid
*/
public VersionedRecord(final V value, final long timestamp, final long validTo);
/**
* Returns the {@code validTo}
*/
public long validTo();
} |
...