shuflr 0.1.1

Streaming shuffled JSONL: chunk pool, shuffle algorithms, I/O, sinks
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//! shuflr — streaming shuffled JSONL.
//!
//! See `docs/design/002-revised-plan.md` for the authoritative v1 specification,
//! plus amendments `003-compression-formats.md`, `004-convert-subcommand.md`,
//! and `005-serve-multi-transport.md`.

#![cfg_attr(test, allow(clippy::unwrap_used, clippy::expect_used))]

pub mod analyze;
pub mod error;
pub mod framing;
pub mod index;
pub mod io;
pub mod json_validate;
#[cfg(feature = "parquet")]
pub mod parquet_input;
pub mod pipeline;
pub mod sampling;
pub mod seed;
#[cfg(feature = "serve")]
pub mod serve;

pub use error::{Error, Result};
pub use framing::{OnError, Stats};
pub use index::{Fingerprint, IndexFile};
pub use sampling::SamplingReader;
pub use seed::Seed;

/// Physical CPU core count (not logical/SMT). Defaults to 1 on systems
/// where detection fails. Preferred over `std::thread::available_parallelism`
/// for compute-heavy workloads like zstd compression; see
/// `docs/bench/001-edgar-31gb-gzip.md` §thread-scaling.
pub fn physical_cores() -> usize {
    num_cpus::get_physical().max(1)
}