summaryrefslogtreecommitdiffstats
path: root/src/termdict/merger.rs
diff options
context:
space:
mode:
authorPaul Masurel <paul.masurel@gmail.com>2017-08-13 17:57:11 +0900
committerPaul Masurel <paul.masurel@gmail.com>2017-08-13 17:57:11 +0900
commit413d0e17197cf56275af04ee8a15e908bdfbcf6f (patch)
tree10b83b126d5432209863e374f90e87ad33a21561 /src/termdict/merger.rs
parent0eb3c872fd4abf5f811ab13e2c13aeca873cab3d (diff)
NOBUG test passing
Diffstat (limited to 'src/termdict/merger.rs')
-rw-r--r--src/termdict/merger.rs14
1 files changed, 1 insertions, 13 deletions
diff --git a/src/termdict/merger.rs b/src/termdict/merger.rs
index 4689e06..e7b4b39 100644
--- a/src/termdict/merger.rs
+++ b/src/termdict/merger.rs
@@ -1,11 +1,8 @@
use std::collections::BinaryHeap;
-use core::SegmentReader;
use termdict::TermStreamerImpl;
use common::BinarySerializable;
-use postings::TermInfo;
use std::cmp::Ordering;
use termdict::TermStreamer;
-use termdict::TermDictionary;
use schema::Term;
pub struct HeapItem<'a, V>
@@ -58,7 +55,7 @@ pub struct TermMerger<'a, V>
impl<'a, V> TermMerger<'a, V>
where V: 'a + BinarySerializable + Default
{
- fn new(streams: Vec<TermStreamerImpl<'a, V>>) -> TermMerger<'a, V> {
+ pub fn new(streams: Vec<TermStreamerImpl<'a, V>>) -> TermMerger<'a, V> {
TermMerger {
heap: BinaryHeap::new(),
current_streamers: streams
@@ -141,12 +138,3 @@ impl<'a, V> TermMerger<'a, V>
}
-
-impl<'a> From<&'a [SegmentReader]> for TermMerger<'a, TermInfo> {
- fn from(segment_readers: &'a [SegmentReader]) -> TermMerger<'a, TermInfo> {
- TermMerger::new(segment_readers
- .iter()
- .map(|reader| reader.terms().stream())
- .collect())
- }
-}