@@ -32,6 +32,10 @@ impl Watermark {
|
|||||||
|
|
||||||
pub fn remove_reader(&mut self, ts: u64) {}
|
pub fn remove_reader(&mut self, ts: u64) {}
|
||||||
|
|
||||||
|
pub fn num_retained_snapshots(&self) -> usize {
|
||||||
|
0
|
||||||
|
}
|
||||||
|
|
||||||
pub fn watermark(&self) -> Option<u64> {
|
pub fn watermark(&self) -> Option<u64> {
|
||||||
Some(0)
|
Some(0)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user