diff --git a/Cargo.lock b/Cargo.lock
index ffeb915..9091434 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1131,8 +1131,8 @@ dependencies = [
 ]
 
 [[package]]
-name = "df-streams-core"
-version = "0.1.0"
+name = "denormalized"
+version = "0.0.1"
 dependencies = [
  "apache-avro",
  "arrow",
@@ -1159,13 +1159,13 @@ dependencies = [
 ]
 
 [[package]]
-name = "df-streams-examples"
-version = "0.1.0"
+name = "denormalized-examples"
+version = "0.0.1"
 dependencies = [
  "arrow",
  "arrow-schema",
  "datafusion",
- "df-streams-core",
+ "denormalized",
  "env_logger",
  "futures",
  "log",
diff --git a/Cargo.toml b/Cargo.toml
index 8df5af0..6d3cc8c 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -11,12 +11,12 @@ edition = "2021"
 homepage = "https://github.com/probably-nothing-labs/denormalized"
 license = "Apache-2.0"
 readme = "README.md"
-repository = "https://github.com/probably-nothing-labs/denormalized"
-version = "0.1.0"
+repository = "https://github.com/probably-nothing-labs/denormalized.git"
+version = "0.0.1"
 description = "Embeddable stream processing engine"
 
 [workspace.dependencies]
-df-streams-core = { path = "crates/core" }
+denormalized = { path = "crates/core" }
 datafusion = "41.0.0"
 
 arrow = { version = "52.0.0", features = ["prettyprint"] }
diff --git a/crates/core/Cargo.toml b/crates/core/Cargo.toml
index 44d23e9..330f5f0 100644
--- a/crates/core/Cargo.toml
+++ b/crates/core/Cargo.toml
@@ -1,5 +1,5 @@
 [package]
-name = "df-streams-core"
+name = "denormalized"
 version = { workspace = true }
 edition = { workspace = true }
 
diff --git a/examples/Cargo.toml b/examples/Cargo.toml
index 551a0c2..dfc991b 100644
--- a/examples/Cargo.toml
+++ b/examples/Cargo.toml
@@ -1,5 +1,5 @@
 [package]
-name = "df-streams-examples"
+name = "denormalized-examples"
 version = { workspace = true }
 edition = { workspace = true }
 publish = false
@@ -7,7 +7,7 @@ publish = false
 [dependencies]
 datafusion = { workspace = true }
 
-df-streams-core = { workspace = true }
+denormalized = { workspace = true }
 
 arrow = { workspace = true }
 arrow-schema = { workspace = true }
diff --git a/examples/examples/emit_measurements.rs b/examples/examples/emit_measurements.rs
index 736b81e..a0925b5 100644
--- a/examples/examples/emit_measurements.rs
+++ b/examples/examples/emit_measurements.rs
@@ -7,7 +7,7 @@ use rdkafka::config::ClientConfig;
 use rdkafka::producer::FutureRecord;
 use rdkafka::util::Timeout;
 
-use df_streams_examples::Measurment;
+use denormalized_examples::Measurment;
 
 /// This script emits test data to a kafka cluster
 ///
diff --git a/examples/examples/kafka_rideshare.rs b/examples/examples/kafka_rideshare.rs
index 694b8af..be9fa74 100644
--- a/examples/examples/kafka_rideshare.rs
+++ b/examples/examples/kafka_rideshare.rs
@@ -4,9 +4,9 @@ use datafusion::functions_aggregate::count::count;
 use datafusion::functions_aggregate::expr_fn::{max, min};
 use datafusion::logical_expr::col;
 
-use df_streams_core::context::Context;
-use df_streams_core::datasource::kafka::{ConnectionOpts, KafkaTopicBuilder};
-use df_streams_core::physical_plan::utils::time::TimestampUnit;
+use denormalized::context::Context;
+use denormalized::datasource::kafka::{ConnectionOpts, KafkaTopicBuilder};
+use denormalized::physical_plan::utils::time::TimestampUnit;
 
 use std::time::Duration;
 use tracing_subscriber::{fmt::format::FmtSpan, FmtSubscriber};
diff --git a/examples/examples/simple_aggregation.rs b/examples/examples/simple_aggregation.rs
index 4682819..c3cb337 100644
--- a/examples/examples/simple_aggregation.rs
+++ b/examples/examples/simple_aggregation.rs
@@ -6,11 +6,11 @@ use datafusion::functions_aggregate::count::count;
 use datafusion::functions_aggregate::expr_fn::{max, min};
 use datafusion::logical_expr::{col, lit};
 
-use df_streams_core::context::Context;
-use df_streams_core::datasource::kafka::{ConnectionOpts, KafkaTopicBuilder};
-use df_streams_core::physical_plan::utils::time::TimestampUnit;
+use denormalized::context::Context;
+use denormalized::datasource::kafka::{ConnectionOpts, KafkaTopicBuilder};
+use denormalized::physical_plan::utils::time::TimestampUnit;
 
-use df_streams_examples::get_sample_json;
+use denormalized_examples::get_sample_json;
 
 /// Demonstrates a simple stream aggregate job on data generated via the `emit_measurements.rs`
 /// example script.
diff --git a/examples/examples/stream_join.rs b/examples/examples/stream_join.rs
index a9184fa..9b84f70 100644
--- a/examples/examples/stream_join.rs
+++ b/examples/examples/stream_join.rs
@@ -5,11 +5,11 @@ use datafusion::error::Result;
 use datafusion::functions_aggregate::average::avg;
 use datafusion::logical_expr::col;
 
-use df_streams_core::context::Context;
-use df_streams_core::datasource::kafka::{ConnectionOpts, KafkaTopicBuilder};
-use df_streams_core::physical_plan::utils::time::TimestampUnit;
+use denormalized::context::Context;
+use denormalized::datasource::kafka::{ConnectionOpts, KafkaTopicBuilder};
+use denormalized::physical_plan::utils::time::TimestampUnit;
 
-use df_streams_examples::get_sample_json;
+use denormalized_examples::get_sample_json;
 
 /// Demonstrates a simple stream join on data generated via the `emit_measurements.rs`
 /// example script.