Skip to content

Instantly share code, notes, and snippets.

use std::time::{Duration, Instant, SystemTime};
use std::hint::black_box;
use clap::Parser;
#[derive(Parser, Debug)]
#[command(author, version, about, long_about = None)]
struct Args {
/// Number of outer iterations for each timing method
#[arg(long, default_value_t = 15_000)]
iterations: u64,
use std::time::Instant;
// Define a trait with a simple operation
trait Operation {
fn execute(&self, input: i32) -> i32;
}
// Implement the trait for a specific type
struct AddOperation;
impl Operation for AddOperation {
[package]
name = "dagger"
version = "0.1.0"
edition = "2021"
# Add dependencies as needed
[dependencies]
petgraph = "0.6" # for DAG structure and traversal
tokio = { version = "1", features = ["full"] } # for async orchestration
serde = { version = "1.0", features = ["derive"] }
[package]
name = "gen_conc"
version = "0.1.0"
edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies]
tokio = { version = "1", features = ["full"] }
sha2 = "0.10" # For hashing document content (SHA-256)
[package]
name = "cete_node"
version = "0.1.0"
edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies]
actix-web = "4"
aws-config = "*"
aws-sdk-codecommit = "*"
[package]
name = "delta_fake"
version = "0.1.0"
edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies]
anyhow = "1.0.86"
dashmap = "5.5.3"
@mooreniemi
mooreniemi / Cargo.toml
Created May 19, 2024 19:31
`SharedFile` using `unsafe`
[package]
name = "delta_fake"
version = "0.1.0"
edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies]
anyhow = "1.0.86"
fd-lock = "4.0.2"
[package]
name = "poodah"
version = "0.1.0"
edition = "2021"
[[bench]]
name = "ray_in_tok"
harness = false
[dependencies]
@mooreniemi
mooreniemi / Cargo.toml
Created May 7, 2024 14:18
This is a minimal example of reading a delta table from S3 with Rust. From [this discussion](https://delta-users.slack.com/archives/C013LCAEB98/p1714949120391979).
[package]
name = "read-table-example"
version = "0.1.0"
edition = "2021"
# note: I did not double-check this and your dependencies might slightly vary (I cut some of mine off)
[dependencies]
deltalake = { version = "*", features = ["s3"] }
tokio = { version = "1", features = ["full"] }
quick-xml = { version = "0.23.0-alpha3" }
@mooreniemi
mooreniemi / Cargo.toml
Last active May 6, 2024 04:46
streaming parquet read from s3
[package]
name = "stream-pq"
version = "0.1.0"
edition = "2021"
[dependencies]
deltalake = { version = "*", features = ["s3"] }
tokio = { version = "1", features = ["full"] }
quick-xml = { version = "0.23.0-alpha3" }
aws-config = { version = "*", features = ["rustls"] }