C# and F# language binding and extensions to Apache Spark
C# and F# language binding and extensions to Apache Spark
Mobius provides C# language binding to Apache Spark enabling the implementation of Spark driver program and data processing operations in the languages supported in the .NET framework like C# or F#.
For example, the word count sample in Apache Spark can be implemented in C# as follows :
var lines = sparkContext.TextFile(@"hdfs://path/to/input.txt");
var words = lines.FlatMap(s => s.Split(' '));
var wordCounts = words.Map(w => new Tuple(w.Trim(), 1))
.ReduceByKey((x, y) => x + y);
var wordCountCollection = wordCounts.Collect();
wordCounts.SaveAsTextFile(@"hdfs://path/to/wordcount.txt"); A simple DataFrame application using TempTable may look like the following:
…A simple DataFrame application using DataFrame DSL may look like the following:
…A simple Spark Streaming application that processes messages from Kafka using C# may be implemented using the following code:
…For more code samples, refer to Mobius\examples directory or Mobius\csharp\Samples directory.
Refer to Mobius C# API documentation for the list of Spark's data processing operations supported in Mobius.
Mobius API usage samples are available at:
Examples folder which contains standalone C# and F# projects that can be used as templates to start developing Mobius applications
Samples project which uses a comprehensive set of Mobius APIs to implement samples that are also used for functional validation of APIs
Mobius performance test scenarios implemented in C# and Scala for side by side comparison of Spark driver code
Refer to the docs folder for design overview and other info on Mobius
| Ubuntu 14.04.3 LTS | Windows | Unit test coverage |
|---|---|---|
| Windows | Linux | |
|---|---|---|
| Build & run unit tests | Build in Windows | Build in Linux |
| Run samples (functional tests) in local mode | Samples in Windows | Samples in Linux |
| Run examples in local mode | Examples in Windows | Examples in Linux |
| Run Mobius app |
|
AWS EMR Spark Cluster | |Run Mobius Shell |
| Not supported yet |
Mobius is built and tested with Apache Spark 1.4.1, 1.5.2, 1.6.* and 2.0.
Mobius releases are available at https://github.com/Microsoft/Mobius/releases. References needed to build C# Spark driver applicaiton using Mobius are also available in NuGet Refer to mobius-release-info.md for the details on versioning policy and the contents of the release.
Mobius is licensed under the MIT license. See LICENSE file for full license information.
Mobius project welcomes contributions. To contribute, follow the instructions in CONTRIBUTING.md
Options to ask your question to the Mobius community
This project has adopted the Microsoft Open Source Code of Conduct. For more information see the Code of Conduct FAQ or contact [email protected] with any additional questions or comments.
No open issues yet, or sync has not completed.