Avro as optional feature

Cargo.toml

@@ -14,10 +14,11 @@ homepage = "https://github.com/deib-polimi/renoir"
 readme = "README.md"
 
 [features]
-default = ["clap", "ssh", "timestamp",]
+default = ["clap", "ssh", "timestamp", "avro"]
 timestamp = []
 ssh = ["ssh2", "whoami", "shell-escape", "sha2", "base64"]
 tokio = ["dep:tokio", "futures", "tokio/net", "tokio/io-util", "tokio/time", "tokio/rt-multi-thread", "tokio/macros"]
+avro = ["dep:apache-avro"]
 profiler = []
 
 [dependencies]
@@ -78,7 +79,7 @@ indexmap = "2.2.6"
 tracing = { version = "0.1.40", features = ["log"] }
 quick_cache = "0.5.1"
 dashmap = "5.5.3"
-apache-avro = { version = "0.16.0", features = ["derive"] }
+apache-avro = { version = "0.16.0", features = ["derive"], optional = true }
 dyn-clone = "1.0.17"
 
 [dev-dependencies]
@@ -104,6 +105,10 @@ nexmark = { version = "0.2.0", features = ["serde"] }
 name = "nexmark"
 required-features = ["timestamp"]
 
+[[example]]
+name = "avro_rw"
+required-features = ["avro"]
+
 [[example]]
 name = "rolling_top_words"
 required-features = ["timestamp"]

src/operator/sink/mod.rs

@@ -5,6 +5,7 @@
 
 use std::sync::{Arc, Mutex};
 
+#[cfg(feature = "avro")]
 pub(super) mod avro;
 pub(super) mod collect;
 pub(super) mod collect_channel;

src/operator/source/mod.rs

@@ -3,6 +3,7 @@
 pub use self::csv::*;
 #[cfg(feature = "tokio")]
 pub use async_stream::*;
+#[cfg(feature = "avro")]
 pub use avro::*;
 pub use channel::*;
 pub use file::*;
@@ -13,6 +14,7 @@ use crate::{block::Replication, operator::Operator};
 
 #[cfg(feature = "tokio")]
 mod async_stream;
+#[cfg(feature = "avro")]
 mod avro;
 mod channel;
 mod csv;