Struct InMemorySegmentStore 

pub struct InMemorySegmentStore { /* private fields */ }

インメモリにカラムナーセグメントを保持する。

Implementations

impl InMemorySegmentStore

pub fn new(memory_limit: Option<u64>) -> Self

memory_limit バイト上限付きで生成する。None は無制限。

pub fn write_segment( &self, table_id: u32, segment: ColumnSegmentV2, ) -> Result<u64>

セグメントを書き込み、割り当てたセグメントIDを返す。

pub fn read_segment( &self, table_id: u32, segment_id: u64, columns: &[usize], ) -> Result<Vec<RecordBatch>>

セグメントを読み取り、指定カラムを返す。

pub fn memory_usage(&self) -> u64

現在のメモリ使用量（バイト）を返す。

pub fn flush_to_segment_file<P: AsRef<Path>>( &self, table_id: u32, segment_id: u64, path: P, ) -> Result<()>

セグメントをファイルへフラッシュする（fsync + rename）。

pub fn flush_to_kvs( &self, table_id: u32, segment_id: u64, bridge: &ColumnarKvsBridge, ) -> Result<u64>

KVS へフラッシュする（ColumnarKvsBridge 経由）。

pub fn flush_to_alopex( &self, table_id: u32, segment_id: u64, writer: &mut AlopexFileWriter, ) -> Result<u32>

.alopex ファイルへフラッシュする。

pub fn column_count(&self, table_id: u32, segment_id: u64) -> Result<usize>

カラム数を返す（メタデータから取得）。

pub fn schema(&self, table_id: u32, segment_id: u64) -> Result<Schema>

スキーマを返す（メタデータから取得）。

pub fn list_segments(&self) -> Vec<(u32, u64)>

すべてのセグメント (table_id, segment_id) を返す。