mod buckets;
mod manifest;
pub mod merge;
mod options;
mod streaming;
pub const FORMAT_VERSION: u32 = 1;
pub const FORMAT_MAGIC: &str = "RYPE_PARQUET_V1";
pub mod files {
pub const MANIFEST: &str = "manifest.toml";
pub const BUCKETS: &str = "buckets.parquet";
pub const INVERTED_DIR: &str = "inverted";
pub fn inverted_shard(shard_id: u32) -> String {
format!("shard.{}.parquet", shard_id)
}
}
pub use buckets::{read_buckets_parquet, write_buckets_parquet};
pub use manifest::{
create_index_directory, is_parquet_index, BucketData, BucketMetadata, InvertedManifest,
InvertedShardInfo, ParquetManifest, ParquetShardFormat,
};
pub use options::{hex_u64, ParquetCompression, ParquetReadOptions, ParquetWriteOptions};
pub use streaming::{
compute_source_hash, create_parquet_inverted_index, ShardAccumulator, MIN_SHARD_BYTES,
};