From e774b20d48fed406db8375cd00237720998b890d Mon Sep 17 00:00:00 2001 From: Matt Green Date: Wed, 14 Aug 2024 16:59:32 -0700 Subject: [PATCH] change package version and update name --- Cargo.lock | 10 +++++----- Cargo.toml | 6 +++--- crates/core/Cargo.toml | 2 +- examples/Cargo.toml | 4 ++-- examples/examples/emit_measurements.rs | 2 +- examples/examples/kafka_rideshare.rs | 6 +++--- examples/examples/simple_aggregation.rs | 8 ++++---- examples/examples/stream_join.rs | 8 ++++---- 8 files changed, 23 insertions(+), 23 deletions(-) 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.