BigPipe.Analytics
0.1.0
dotnet add package BigPipe.Analytics --version 0.1.0
NuGet\Install-Package BigPipe.Analytics -Version 0.1.0
<PackageReference Include="BigPipe.Analytics" Version="0.1.0" />
<PackageVersion Include="BigPipe.Analytics" Version="0.1.0" />
<PackageReference Include="BigPipe.Analytics" />
paket add BigPipe.Analytics --version 0.1.0
#r "nuget: BigPipe.Analytics, 0.1.0"
#:package BigPipe.Analytics@0.1.0
#addin nuget:?package=BigPipe.Analytics&version=0.1.0
#tool nuget:?package=BigPipe.Analytics&version=0.1.0
BigPipe for .NET
BigPipe is a high performance, Kafka-compatible realtime stream processing platform with per-topic storage: local disk, tiered, or diskless straight to object storage.
| Package | What it gives you |
|---|---|
BigPipe.Client |
Managed Kafka-protocol producer/consumer (idempotent, consumer groups), share groups, Schema Registry serializers, admin + HTTP clients, DI integration |
BigPipe.Streams |
Stream processing DSL: filter, map, group, tumbling/hopping/sliding/session windows, aggregations, stream-table joins, state stores with changelogs |
BigPipe.Analytics |
Realtime analytics: windows, streaming statistics, sketches (HyperLogLog, Count-Min, Top-K), anomaly detectors |
BigPipe.Analytics.Scripting |
Filter/query streams with C#, Python and JavaScript scripts |
BigPipe.Analytics.ML |
ML.NET: spike/change-point detection, SR-CNN, SSA forecasting, online classifiers |
BigPipe.Analytics.Torch |
TorchSharp: online autoencoder anomaly detection, TorchScript scoring |
BigPipe.Analytics.Gravicode |
GravicodeScience, HF.Net and MediaPipe.NET for stream analytics |
await using var producer = new ProducerBuilder<string, Order>().WithBootstrap("localhost:9092").Build();
await producer.SendAsync("orders", "order-1", new Order(1, 150_000m, "IDR"));
Docs: https://github.com/DotNetVibeCoderz/Vibe_Messaging/tree/main/BigPipe/docs
Dibuat oleh Gravicode Studios dipimpin oleh Kang Fadhil.
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
-
net10.0
- BigPipe.Client (>= 0.1.0)
- System.IO.Hashing (>= 10.0.12)
NuGet packages (4)
Showing the top 4 NuGet packages that depend on BigPipe.Analytics:
| Package | Downloads |
|---|---|
|
BigPipe.Analytics.ML
ML.NET for BigPipe realtime analytics: spike and change-point detection, SR-CNN window anomaly detection, SSA forecasting, streaming classifiers that retrain on the fly and scoring of saved ML.NET models. Dibuat oleh Gravicode Studios dipimpin oleh Kang Fadhil. |
|
|
BigPipe.Analytics.Scripting
Dynamic scripting for BigPipe realtime analytics: filter, project and query streams with C# (Roslyn), Python (IronPython) or JavaScript (Jint) expressions compiled at runtime. Dibuat oleh Gravicode Studios dipimpin oleh Kang Fadhil. |
|
|
BigPipe.Analytics.Torch
TorchSharp deep learning for BigPipe realtime analytics: online autoencoder anomaly detection for multivariate streams, sliding-window detectors and TorchScript model scoring. Uses the TorchSharp API; add TorchSharp-cpu or TorchSharp-cuda-* for the native runtime. Dibuat oleh Gravicode Studios dipimpin oleh Kang Fadhil. |
|
|
BigPipe.Analytics.Gravicode
Gravicode AI ecosystem for BigPipe realtime analytics: GravicodeScience (GraviNum, GraviFrame DataFrames, GraviLearn clustering and one-class SVM, GraviText sentiment), HF.Net transformers (classification, embeddings, semantic filters) and MediaPipe.NET text tasks (sentiment, language detection). Dibuat oleh Gravicode Studios dipimpin oleh Kang Fadhil. |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 0.1.0 | 45 | 9/29/2026 |