Added the mySparkStreamingApp.

Author: daisukenishino2

Azure/DotNet4ApacheSpark/mySparkStreamingApp/mySparkStreamingApp.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 16
+VisualStudioVersion = 16.0.30717.126
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "mySparkStreamingApp", "mySparkStreamingApp\mySparkStreamingApp.csproj", "{774336F5-C408-40E3-9E45-BE2266E5AA31}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{774336F5-C408-40E3-9E45-BE2266E5AA31}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{774336F5-C408-40E3-9E45-BE2266E5AA31}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{774336F5-C408-40E3-9E45-BE2266E5AA31}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{774336F5-C408-40E3-9E45-BE2266E5AA31}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {13246FAA-A546-4B4B-8E52-F6D65C265691}
+	EndGlobalSection
+EndGlobal

Azure/DotNet4ApacheSpark/mySparkStreamingApp/mySparkStreamingApp/Program.cs

@@ -0,0 +1,57 @@
+using System;
+using Microsoft.Spark.Sql;
+using Microsoft.Spark.Sql.Streaming;
+using static Microsoft.Spark.Sql.Functions;
+
+namespace mySparkStreamingApp
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            //Console.WriteLine("Hello World!");
+            // Default to running on localhost:9999
+            string hostname = "localhost";
+            int port = 9999;
+
+            // User designated their own host and port
+            if (args.Length == 2)
+            {
+                hostname = args[0];
+                port = int.Parse(args[1]);
+            }
+
+            // Create Spark session
+            SparkSession spark = SparkSession
+                .Builder()
+                .AppName("Streaming example with a UDF")
+                .GetOrCreate();
+
+            // Create initial DataFrame
+            DataFrame lines = spark
+                .ReadStream()
+                .Format("socket")
+                .Option("host", hostname)
+                .Option("port", port)
+                .Load();
+
+            // UDF to produce an array
+            // Array includes:
+            // 1) original string
+            // 2) original string + length of original string
+            Func<Column, Column> udfArray =
+                Udf<string, string[]>((str) => new string[] { str, $"{str} {str.Length}" });
+
+            // Explode array to rows
+            DataFrame arrayDF = lines.Select(Explode(udfArray(lines["value"])));
+
+            // Process and display each incoming line
+            StreamingQuery query = arrayDF
+                .WriteStream()
+                .Format("console")
+                .Start();
+
+            query.AwaitTermination();
+        }
+    }
+}

Azure/DotNet4ApacheSpark/mySparkStreamingApp/mySparkStreamingApp/mySparkStreamingApp.csproj

@@ -0,0 +1,12 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp3.1</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Spark" Version="1.0.0" />
+  </ItemGroup>
+
+</Project>