Mobius: C# API for Spark

Mobius adds C# language binding to Apache Spark, enabling the implementation of Spark driver code and data processing operations in C#.

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 KeyValuePair<string, int>(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:

var reqDataFrame = sqlContext.TextFile(@"hdfs://path/to/requests.csv");
var metricDataFrame = sqlContext.TextFile(@"hdfs://path/to/metrics.csv");
reqDataFrame.RegisterTempTable("requests");
metricDataFrame.RegisterTempTable("metrics");
// C0 - guid in requests DataFrame, C3 - guid in metrics DataFrame  
var joinDataFrame = GetSqlContext().Sql(  
    "SELECT joinedtable.datacenter" +
         ", MAX(joinedtable.latency) maxlatency" +
         ", AVG(joinedtable.latency) avglatency " + 
    "FROM (" +
       "SELECT a.C1 as datacenter, b.C6 as latency " +  
       "FROM requests a JOIN metrics b ON a.C0  = b.C3) joinedtable " +   
    "GROUP BY datacenter");
joinDataFrame.ShowSchema();
joinDataFrame.Show();

A simple DataFrame application using DataFrame DSL may look like the following:

// C0 - guid, C1 - datacenter
var reqDataFrame = sqlContext.TextFile(@"hdfs://path/to/requests.csv")  
                             .Select("C0", "C1");    
// C3 - guid, C6 - latency   
var metricDataFrame = sqlContext.TextFile(@"hdfs://path/to/metrics.csv", ",", false, true)
                                .Select("C3", "C6"); //override delimiter, hasHeader & inferSchema
var joinDataFrame = reqDataFrame.Join(metricDataFrame, reqDataFrame["C0"] == metricDataFrame["C3"])
                                .GroupBy("C1");
var maxLatencyByDcDataFrame = joinDataFrame.Agg(new Dictionary<string, string> { { "C6", "max" } });
maxLatencyByDcDataFrame.ShowSchema();
maxLatencyByDcDataFrame.Show();

Refer to SparkCLR\csharp\Samples directory and sample usage for complete samples.

API Documentation

Refer to Mobius C# API documentation for the list of Spark's data processing operations supported in SparkCLR.

API Usage

Mobius API usage samples are available at:

• Samples project which uses a comprehensive set of Mobius APIs to implement samples that are also used for functional validation of APIs

• Examples folder which contains standalone C# projects that can be used as templates to start developing Mobius applications

• Performance test scenarios implemented in C# and Scala for side by side comparison of Spark driver code

Documents

Refer to the docs folder for design overview and other info on Mobius

Build Status

Ubuntu 14.04.3 LTS	Windows	Unit test coverage

Getting Started

	Windows	Linux
Build & run unit tests	windows-instructions.md	linux-instructions.md
Run samples (functional tests) in local mode	windows-instructions.md	linux-instructions.md
Run examples in local mode	running-sparkclr-app.md	running-sparkclr-app.md
Run Mobius app in standalone cluster	running-sparkclr-app.md	running-sparkclr-app.md
Run Mobius app in YARN cluster	running-sparkclr-app.md	running-sparkclr-app.md

Note: Refer to linux-compatibility.md for using Mobius with Spark on Linux

Supported Spark Versions

Mobius is built and tested with Spark 1.4.1, Spark 1.5.2 and Spark 1.6.0.

License

Mobius is licensed under the MIT license. See LICENSE file for full license information.

Community

• Mobius project welcomes contributions. To contribute, follow the instructions in CONTRIBUTING.md

• Options to ask your question to the Mobius community

  • create issue on GitHub
  • create post with "sparkclr" tag in Stack Overflow
  • send email to sparkclr-user@googlegroups.com
  • join chat at Mobius room in Gitter