Struct SortIndexCreator

pub struct SortIndexCreator {
    sorter_factory: SorterFactory,
    sorters: HashMap<String, Box<dyn Sorter>>,
    segment_row_count: NonZeroUsize,
}

SortIndexCreator orchestrates indexing by sorting input data for each named index and writing to an inverted index writer

Fields

sorter_factory: SorterFactory

Factory for producing Sorter instances

sorters: HashMap<String, Box<dyn Sorter>>

Map of index names to sorters

segment_row_count: NonZeroUsize

Number of rows in each segment, used to produce sorters

Implementations

impl SortIndexCreator

pub fn new( sorter_factory: SorterFactory, segment_row_count: NonZeroUsize, ) -> Self

Creates a new SortIndexCreator with the given sorter factory and index writer

Trait Implementations

impl InvertedIndexCreator for SortIndexCreator

fn push_with_name_n<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, index_name: &'life1 str, value: Option<BytesRef<'life2>>, n: usize, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Inserts n values or nulls into the sorter for the specified index.

If the index does not exist, a new index is created even if n is 0. Caller may leverage this behavior to create indexes with no data.

fn finish<'life0, 'life1, 'async_trait>( &'life0 mut self, writer: &'life1 mut dyn InvertedIndexWriter, bitmap_type: BitmapType, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Finalizes the sorting for all indexes and writes them using the inverted index writer

fn push_with_name<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, index_name: &'life1 str, value: Option<BytesRef<'life2>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Adds a value to the named index. A None value represents an absence of data (null)