hermes-core 1.8.120

Core async search engine library with WASM support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

//! End-to-end coverage for posting-codec selection and compatibility stamps.

use crate::directories::RamDirectory;
use crate::dsl::{Document, SchemaBuilder};
use crate::index::{Index, IndexConfig, IndexMetadata, IndexWriter};
use crate::structures::{IndexOptimization, PostingCodec};

#[tokio::test]
async fn size_optimization_survives_reencoding_merge() {
    let mut schema = SchemaBuilder::default();
    let body = schema.add_text_field("body", true, false);
    let schema = schema.build();
    let dir = RamDirectory::new();
    let config = IndexConfig {
        optimization: IndexOptimization::SizeOptimized,
        merge_policy: Box::new(crate::merge::NoMergePolicy),
        ..IndexConfig::default()
    };
    let mut writer = IndexWriter::create(dir.clone(), schema, config.clone())
        .await
        .unwrap();

    // One inline source plus one external source forces the merger's
    // decode/remap/re-encode path for "needle".
    let mut first = Document::new();
    first.add_text(body, "needle");
    writer.add_document(first).unwrap();
    writer.commit().await.unwrap();
    for i in 0..8 {
        let mut doc = Document::new();
        doc.add_text(body, format!("needle value{i}"));
        writer.add_document(doc).unwrap();
    }
    writer.commit().await.unwrap();

    let metadata = IndexMetadata::load(&dir).await.unwrap();
    assert_eq!(
        metadata.version,
        crate::index::metadata::INDEX_META_FORMAT_VERSION,
        "new text layouts use the current index format"
    );

    writer.force_merge().await.unwrap();
    drop(writer);
    let index = Index::open(dir.clone(), config).await.unwrap();
    let segments = index.segment_readers().await.unwrap();
    assert_eq!(segments.len(), 1);
    let postings = segments[0]
        .get_postings(body, b"needle")
        .await
        .unwrap()
        .unwrap();
    assert!(postings.num_blocks() > 0);
    assert!(
        (0..postings.num_blocks())
            .all(|block| { postings.block_codec(block) == Some(PostingCodec::Pfor) }),
        "merge re-encoding must retain the configured size codec"
    );
}