Mobius
Mobius copied to clipboard
microsoft
C# and F# language binding and extensions to Apache Spark
I have a simple java producer which is pushing message to kafka. I can read message using simple java consumer but not using spark streaming. Using spark streaming all messages...
### Please help me. What's wrong? I cant call Reduce in "Pi Example" I did everything as a guide - https://www.ics.uci.edu/~shantas/Install_Spark_on_Windows10.pdf ---------------------------- ##List of my components - Windows10 - JDK:8u60...
I am trying to run WORDCOUNT example and it works if u run the CLI such as **sparkclr-submit.cmd --exe SparkClrWordCount.exe C:\Users\Downloads\Mobius-master\examples\Batch\WordCount\bin\Debug file:///C:/Users/eyadmin/Desktop/TEST/words.txt** - it works! ----------------------------------------------------------- HOWEVER, if i run...
Downloaded the master yesterday and tried to run build.cmd in the VS2015 command prompt running JDK 8.0.600.27 64bit. After having to manually download winutils and tartools (both failed in the...
The documentation file appears to have been generated with no space between the hashes and the header text. This is causing the headers to not display correctly, and is difficult...
I'm new to Mobius and new to Spark as well. I am trying to set up the Build using the instructions but when I run Build.cmd I get a failure...
I get a serialization error any time I'm passing data at runtime. This happens with any calls using a lambda expression with data originating outside of the lambda expression. Using...
I'm trying to use newAPIHadoopFile to implement custom InputFormat and RecordReader classes instead of using the default ones provided by Spark. I can do the same in Java but am...
### Context: I'm trying to write the RDD as text file on Azure Blob (wasb). My code looks similar to this: ```C# var stream = EventHubsUtils.CreateUnionStream( ssc, eventhubsParams.Select( v =>...
