fix: Allow dead code temporarily while partition is being refactored
parent
48954424e1
commit
fed0a5e8b0
|
@ -1,3 +1,5 @@
|
|||
#![allow(dead_code)]
|
||||
|
||||
use crate::delorean::{Node, Predicate, TimestampRange};
|
||||
use crate::line_parser::{ParseError, Point, PointType};
|
||||
use crate::storage::partitioned_store::{ReadBatch, ReadValues};
|
||||
|
|
|
@ -80,6 +80,7 @@ struct StreamState<'a, T> {
|
|||
}
|
||||
|
||||
impl StringMergeStream<'_> {
|
||||
#[allow(dead_code)]
|
||||
fn new(streams: Vec<BoxStream<'_, String>>) -> StringMergeStream<'_> {
|
||||
let states = streams
|
||||
.into_iter()
|
||||
|
@ -165,6 +166,7 @@ pub struct ReadMergeStream<'a> {
|
|||
}
|
||||
|
||||
impl ReadMergeStream<'_> {
|
||||
#[allow(dead_code)]
|
||||
fn new(streams: Vec<BoxStream<'_, ReadBatch>>) -> ReadMergeStream<'_> {
|
||||
let states = streams
|
||||
.into_iter()
|
||||
|
|
Loading…
Reference in New Issue