THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
To be able to list the tombstones, the validTo filed is added to the VersionedRecord class. The default value of validTo is positive infinity.
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 validTo timestamp */ public VersionedRecord(final V value, final long timestamp, final long validTo); /** * Returns the {@code validTo} */ public long validTo(); } |
...