diff --git a/src/indexing/dense.rs b/src/indexing/dense.rs index 001998c..37cb3f9 100644 --- a/src/indexing/dense.rs +++ b/src/indexing/dense.rs @@ -27,20 +27,16 @@ impl DenseIndexBuilder { } } - -#[doc=""] -pub fn build_dense_index( - log_path: &str, - index_path: &str, -) -> std::io::Result<()> { +#[doc = ""] +pub fn build_dense_index(log_path: &str, index_path: &str) -> std::io::Result<()> { let mut log = File::open(log_path)?; let mut builder = DenseIndexBuilder::create(index_path)?; let mut offset = 0u64; let mut record = [0u8; RECORD_SIZE]; - while log.read_exact(&mut record).is_ok(){ - let (timestamp, _, _ , _, _ ) = decode_record(&record); + while log.read_exact(&mut record).is_ok() { + let (timestamp, _, _, _, _) = decode_record(&record); builder.add_entry(timestamp, offset)?; offset += RECORD_SIZE as u64; } diff --git a/src/indexing/dictionary.rs b/src/indexing/dictionary.rs index d34a7ac..e5605b2 100644 --- a/src/indexing/dictionary.rs +++ b/src/indexing/dictionary.rs @@ -61,7 +61,7 @@ impl Dictionary { file.read_exact(&mut count_bytes)?; let count = u64::from_be_bytes(count_bytes); - // Reading each IRI Entry + // Reading each URI Entry for id in 0..count { let mut len_bytes = [0u8; 4]; diff --git a/src/indexing/mod.rs b/src/indexing/mod.rs index 6f0579a..69d25b6 100644 --- a/src/indexing/mod.rs +++ b/src/indexing/mod.rs @@ -1,8 +1,8 @@ -#[doc=""] -pub mod shared; -#[doc=""] +#[doc = ""] pub mod dense; -#[doc=""] -pub mod sparse; -#[doc=""] +#[doc = ""] pub mod dictionary; +#[doc = ""] +pub mod shared; +#[doc = ""] +pub mod sparse; diff --git a/src/indexing/shared.rs b/src/indexing/shared.rs index 97a1155..dd344bc 100644 --- a/src/indexing/shared.rs +++ b/src/indexing/shared.rs @@ -1,6 +1,6 @@ +use crate::indexing::dictionary::Dictionary; use std::fs::File; use std::io::Write; -use crate::indexing::dictionary::Dictionary; #[doc = ""] pub const RECORD_SIZE: usize = 40; @@ -93,7 +93,7 @@ pub struct Event { } #[derive(Debug, Clone)] -pub struct ResolvedEvent{ +pub struct ResolvedEvent { pub timestamp: u64, pub subject: String, pub predicate: String, @@ -108,7 +108,7 @@ impl Event { subject: dict.fetch_uri(self.subject).unwrap_or("UNKNOWN").to_string(), predicate: dict.fetch_uri(self.predicate).unwrap_or("UNKNOWN").to_string(), object: dict.fetch_uri(self.object).unwrap_or("UNKNOWN").to_string(), - graph: dict.fetch_uri(self.graph).unwrap_or("UNKNOWN").to_string() - } + graph: dict.fetch_uri(self.graph).unwrap_or("UNKNOWN").to_string(), + } } } diff --git a/src/indexing/sparse.rs b/src/indexing/sparse.rs index 36f3a99..70a8ad1 100644 --- a/src/indexing/sparse.rs +++ b/src/indexing/sparse.rs @@ -1,4 +1,4 @@ -use crate::indexing::dictionary::{self, Dictionary}; +use crate::indexing::dictionary::Dictionary; use crate::indexing::shared::{decode_record, Event, ResolvedEvent, RECORD_SIZE}; use std::fs::File; use std::io::{Read, Seek, SeekFrom, Write}; diff --git a/src/parsing/janusql_parser.rs b/src/parsing/janusql_parser.rs index da8dafa..c023058 100644 --- a/src/parsing/janusql_parser.rs +++ b/src/parsing/janusql_parser.rs @@ -356,7 +356,7 @@ mod tests { } #[test] - fn test_mixed_windows(){ + fn test_mixed_windows() { let parser = JanusQLParser::new().unwrap(); let query = r#" PREFIX sensor: