4747- ** Cortex.Streams:** Core streaming capabilities for building data pipelines.
4848[ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.Streams?label=Cortex.Streams )] ( https://www.nuget.org/packages/Cortex.Streams )
4949
50+ - ** Cortex.Streams.Mediator:** Integration of Cortex Streaming with Cortex Mediator
51+ [ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.Streams.Mediator?label=Cortex.Streams.Mediator )] ( https://www.nuget.org/packages/Cortex.Streams.Mediator )
52+
5053- ** Cortex.Streams.Kafka:** Integration with Apache Kafka for robust data streaming.
5154[ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.Streams.Kafka?label=Cortex.Streams.Kafka )] ( https://www.nuget.org/packages/Cortex.Streams.Kafka )
5255
111114- ** Cortex.States.SQLite:** Persistent state storage using SQLite.
112115[ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.States.SQLite?label=Cortex.States.SQLite )] ( https://www.nuget.org/packages/Cortex.States.SQLite )
113116
117+ - ** Cortex.States.DuckDb:** Persistent state storage using DuckDb.
118+ [ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.States.DuckDb?label=Cortex.States.DuckDb )] ( https://www.nuget.org/packages/Cortex.States.DuckDb )
119+
114120- ** Cortex.Telemetry:** Core library to add support for Tracing and Matrics.
115121[ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.Telemetry?label=Cortex.Telemetry )] ( https://www.nuget.org/packages/Cortex.Telemetry )
116122
126132- ** Cortex.Mediator.Behaviors.FluentValidation:** implementation of the FluentValidation validation for Commands and Queries
127133[ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.Mediator.Behaviors.FluentValidation?label=Cortex.Mediator.Behaviors.FluentValidation )] ( https://www.nuget.org/packages/Cortex.Mediator.Behaviors.FluentValidation )
128134
135+ - ** Cortex.Mediator.Behaviors.Transactional:** implementation of the Transactional Behaviors for Commands
136+ [ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.Mediator.Behaviors.Transactional?label=Cortex.Mediator.Behaviors.Transactional )] ( https://www.nuget.org/packages/Cortex.Mediator.Behaviors.Transactional )
137+
129138- ** Cortex.Vectors:** is a High‑performance vector types—Dense, Sparse, and Bit—for AI.
130139[ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.Vectors?label=Cortex.Vectors )] ( https://www.nuget.org/packages/Cortex.Vectors )
131140
141+ - ** Cortex.Serialization.Yaml:** is a High‑performance data serializer for Yaml
142+ [ ![ NuGet Version] ( https://img.shields.io/nuget/v/Cortex.Vectors?label=Cortex.Serialization.Yaml )] ( https://www.nuget.org/packages/Cortex.Serialization.Yaml )
143+
132144
133145## Getting Started
134146
@@ -175,7 +187,8 @@ Cortex Data Framework makes it easy to set up and run real-time data processing
175187### 1. Creating a Stream
176188
177189``` csharp
178- var stream = StreamBuilder <int , int >.CreateNewStream (" ExampleStream"
190+ var stream = StreamBuilder <int >.CreateNewStream (" ExampleStream"
191+ .Stream ()
179192 .Map (x => x * 2 )
180193 .Filter (x => x > 10 )
181194 .Sink (Console .WriteLine )
@@ -197,9 +210,10 @@ Console.WriteLine(stateStore.Get("key1"));
197210
198211``` csharp
199212var telemetryProvider = new OpenTelemetryProvider ();
200- var stream = StreamBuilder < int , int >
213+ var stream = StreamBuilder < int >
201214 .CreateNewStream (" TelemetryStream"
202215 .WithTelemetry (telemetryProvider )
216+ .Stream ()
203217 .Map (x => x * 2 )
204218 .Sink (Console .WriteLine )
205219 .Build ();
@@ -233,7 +247,7 @@ public class ClickEvent
233247 static void Main (string [] args )
234248 {
235249 // Build the stream
236- var stream = StreamBuilder <ClickEvent , ClickEvent >.CreateNewStream (" ClickStream"
250+ var stream = StreamBuilder <ClickEvent >.CreateNewStream (" ClickStream"
237251 .Stream ()
238252 .Filter (e => ! string .IsNullOrEmpty (e .PageUrl ))
239253 .GroupBySilently (
0 commit comments