ran cargo fmt
This commit is contained in:
parent
7b8943976f
commit
212e595a7e
@ -1,14 +1,18 @@
|
|||||||
use std::thread::available_parallelism;
|
|
||||||
use clap::Parser;
|
use clap::Parser;
|
||||||
use colored::Colorize;
|
use colored::Colorize;
|
||||||
use memmap2::Mmap;
|
use memmap2::Mmap;
|
||||||
use onebrc::implementations::rgk::{find_city_names, format, run_parallel, to_str, Args, Record, S};
|
use onebrc::implementations::rgk::{
|
||||||
|
find_city_names, format, run_parallel, to_str, Args, Record, S,
|
||||||
|
};
|
||||||
|
use std::thread::available_parallelism;
|
||||||
|
|
||||||
fn main() {
|
fn main() {
|
||||||
let args = Args::parse();
|
let args = Args::parse();
|
||||||
|
|
||||||
let start = std::time::Instant::now();
|
let start = std::time::Instant::now();
|
||||||
let filename = args.input.unwrap_or("../../../measurements.txt".to_string());
|
let filename = args
|
||||||
|
.input
|
||||||
|
.unwrap_or("../../../measurements.txt".to_string());
|
||||||
let mmap: Mmap;
|
let mmap: Mmap;
|
||||||
let data;
|
let data;
|
||||||
{
|
{
|
||||||
@ -84,4 +88,4 @@ fn main() {
|
|||||||
"total: {}",
|
"total: {}",
|
||||||
format!("{:>5.2?}", start.elapsed()).bold().green()
|
format!("{:>5.2?}", start.elapsed()).bold().green()
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
@ -5,6 +5,6 @@ pub mod multi_threaded_smol;
|
|||||||
pub mod multi_threaded_structured;
|
pub mod multi_threaded_structured;
|
||||||
pub mod phcs;
|
pub mod phcs;
|
||||||
pub mod reference_impl;
|
pub mod reference_impl;
|
||||||
|
pub mod rgk;
|
||||||
pub mod single_thread;
|
pub mod single_thread;
|
||||||
pub mod smol;
|
pub mod smol;
|
||||||
pub mod rgk;
|
|
||||||
|
@ -1,10 +1,10 @@
|
|||||||
use crate::models::station_measurements::StationMeasurements;
|
use crate::models::station_measurements::StationMeasurements;
|
||||||
use crate::utils::{hash, parse};
|
use crate::utils::{hash, parse};
|
||||||
use memmap2::MmapOptions;
|
use memmap2::MmapOptions;
|
||||||
|
use rustc_hash::{FxBuildHasher, FxHashMap as HashMap};
|
||||||
use std::sync::mpsc;
|
use std::sync::mpsc;
|
||||||
use std::time::Instant;
|
use std::time::Instant;
|
||||||
use std::{fs::File, thread};
|
use std::{fs::File, thread};
|
||||||
use rustc_hash::{FxHashMap as HashMap, FxBuildHasher};
|
|
||||||
|
|
||||||
const DEFAULT_HASHMAP_LENGTH: usize = 10000;
|
const DEFAULT_HASHMAP_LENGTH: usize = 10000;
|
||||||
|
|
||||||
|
@ -1,9 +1,9 @@
|
|||||||
use ptr_hash::PtrHashParams;
|
use ptr_hash::PtrHashParams;
|
||||||
|
use rustc_hash::FxHashSet;
|
||||||
use std::{
|
use std::{
|
||||||
simd::{cmp::SimdPartialEq, Simd},
|
simd::{cmp::SimdPartialEq, Simd},
|
||||||
vec::Vec,
|
vec::Vec,
|
||||||
};
|
};
|
||||||
use rustc_hash::FxHashSet;
|
|
||||||
|
|
||||||
type V = i32;
|
type V = i32;
|
||||||
|
|
||||||
|
@ -37,4 +37,4 @@ mod tests {
|
|||||||
assert_ne!(hash_1, hash_2);
|
assert_ne!(hash_1, hash_2);
|
||||||
assert_ne!(hash_3, hash_4);
|
assert_ne!(hash_3, hash_4);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user