DataFlow.Spark
1.0.2
This package has been renamed to DataLinq.Spark. All development, bug fixes, and new features continue under the new name. The rename aligns with the parent framework rebrand from DataFlow.NET to DataLinq.NET, resolving naming conflicts with Google Cloud Dataflow and System.Threading.Tasks.Dataflow (TPL).
To migrate: Install DataLinq.Spark, then update your using statements from using DataFlow; to using DataLinq; and using DataFlow.Spark; to using DataLinq.Spark;
dotnet add package DataFlow.Spark --version 1.0.2
NuGet\Install-Package DataFlow.Spark -Version 1.0.2
<PackageReference Include="DataFlow.Spark" Version="1.0.2" />
<PackageVersion Include="DataFlow.Spark" Version="1.0.2" />
<PackageReference Include="DataFlow.Spark" />
paket add DataFlow.Spark --version 1.0.2
#r "nuget: DataFlow.Spark, 1.0.2"
#:package DataFlow.Spark@1.0.2
#addin nuget:?package=DataFlow.Spark&version=1.0.2
#tool nuget:?package=DataFlow.Spark&version=1.0.2
DataFlow.Spark
LINQ-native Apache Spark integration for DataFlow.NET.
Features
- Native LINQ Translation - Write C# LINQ, execute distributed Spark
- Streaming Results - Efficient processing with DataFrames
- Type Safety - Strong typing with automatic column mapping
- Distributed Processing - Scale to petabytes with Apache Spark
Quick Start
using DataFlow.Spark;
using Microsoft.Spark.Sql;
var spark = SparkSession.Builder()
.AppName("DataFlowApp")
.GetOrCreate();
var orders = Spark.Table<Order>(spark, "sales.orders")
.Where(o => o.Amount > 1000)
.GroupBy(o => o.Region)
.Select(g => new { Region = g.Key, Total = g.Sum(o => o.Amount) })
.ToList();
Requirements
- .NET 8.0+
- DataFlow.Net 1.1.0+
- Apache Spark 3.5.0+
- DataFlow.Spark license for production
License
Free development tier (DEBUG builds, 1,000 row limit). Production use requires a license: https://dataflow.net/pricing
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net8.0 is compatible. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. net9.0 was computed. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 was computed. 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. |
-
net8.0
- DataFlow.Net (>= 1.1.0)
- Microsoft.Spark (>= 2.3.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|
v1.0.0: Initial release - LINQ to Spark with native translations, distributed processing, and product-specific licensing.