Drop Spark 2.3 Support

azure-pipelines.yml

@@ -16,11 +16,6 @@ variables:
   backwardCompatibleRelease: '1.0.0'
   forwardCompatibleRelease: '1.0.0'
 
-  backwardCompatibleTestOptions_Windows_2_3: ""
-  forwardCompatibleTestOptions_Windows_2_3: ""
-  backwardCompatibleTestOptions_Linux_2_3: ""
-  forwardCompatibleTestOptions_Linux_2_3: ""
-
   backwardCompatibleTestOptions_Windows_2_4: ""
   forwardCompatibleTestOptions_Windows_2_4: ""
   backwardCompatibleTestOptions_Linux_2_4: ""
@@ -206,53 +201,6 @@ stages:
     backwardCompatibleRelease: $(backwardCompatibleRelease)
     forwardCompatibleRelease: $(forwardCompatibleRelease)
     tests:
-    - version: '2.3.0'
-      jobOptions:
-      # 'Hosted Ubuntu 1604' test is disabled due to https://github.com/dotnet/spark/issues/753
-      - pool: 'Hosted VS2017'
-        testOptions: ''
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Windows_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Windows_2_3)
-    - version: '2.3.1'
-      jobOptions:
-      - pool: 'Hosted VS2017'
-        testOptions: ""
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Windows_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Windows_2_3)
-      - pool: 'Hosted Ubuntu 1604'
-        testOptions: ""
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Linux_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Linux_2_3)
-    - version: '2.3.2'
-      jobOptions:
-      - pool: 'Hosted VS2017'
-        testOptions: ""
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Windows_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Windows_2_3)
-      - pool: 'Hosted Ubuntu 1604'
-        testOptions: ""
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Linux_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Linux_2_3)
-    - version: '2.3.3'
-      jobOptions:
-      - pool: 'Hosted VS2017'
-        testOptions: ""
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Windows_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Windows_2_3)
-      - pool: 'Hosted Ubuntu 1604'
-        testOptions: ""
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Linux_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Linux_2_3)
-    - version: '2.3.4'
-      jobOptions:
-      - pool: 'Hosted VS2017'
-        testOptions: ""
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Windows_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Windows_2_3)
-      - pool: 'Hosted Ubuntu 1604'
-        testOptions: ""
-        backwardCompatibleTestOptions: $(backwardCompatibleTestOptions_Linux_2_3)
-        forwardCompatibleTestOptions: $(forwardCompatibleTestOptions_Linux_2_3)
     - version: '2.4.0'
       jobOptions:
       - pool: 'Hosted VS2017'

src/csharp/Extensions/Microsoft.Spark.Extensions.DotNet.Interactive/AssemblyKernelExtension.cs

@@ -145,10 +145,10 @@ private bool IsPathValid(string path)
             }
 
             Version version = SparkEnvironment.SparkVersion;
-            return (version.Major, version.Minor, version.Build) switch
+            return version.Major switch
             {
-                (2, _, _) => false,
-                (3, 0, _) => true,
+                2 => false,
+                3 => true,
                 _ => throw new NotSupportedException($"Spark {version} not supported.")
             };
         }

src/csharp/Microsoft.Spark.E2ETest/IpcTests/ML/Feature/StopWordsRemoverTests.cs

@@ -3,7 +3,6 @@
 // See the LICENSE file in the project root for more information.
 
 using System.IO;
-using Microsoft.Spark.E2ETest.Utils;
 using Microsoft.Spark.ML.Feature;
 using Microsoft.Spark.Sql;
 using Microsoft.Spark.Sql.Types;
@@ -23,10 +22,10 @@ public StopWordsRemoverTests(SparkFixture fixture) : base(fixture)
         }
 
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             string expectedUid = "theUidWithOutLocale";
             string expectedInputCol = "input_col";
@@ -62,16 +61,9 @@ public void TestSignaturesV2_3_X()
             Assert.IsType<DataFrame>(stopWordsRemover.Transform(input));
 
             TestFeatureBase(stopWordsRemover, "inputCol", "input_col");
-        }
 
-        /// <summary>
-        /// Test signatures for APIs introduced in Spark 2.4.*.
-        /// </summary>
-        [SkipIfSparkVersionIsLessThan(Versions.V2_4_0)]
-        public void TestSignaturesV2_4_X()
-        {
             string expectedLocale = "en_GB";
-            StopWordsRemover stopWordsRemover = new StopWordsRemover().SetLocale(expectedLocale);
+            stopWordsRemover.SetLocale(expectedLocale);
             Assert.Equal(expectedLocale, stopWordsRemover.GetLocale());
         }
     }

src/csharp/Microsoft.Spark.E2ETest/IpcTests/SparkContextTests.cs

@@ -17,13 +17,13 @@ namespace Microsoft.Spark.E2ETest.IpcTests
     public class SparkContextTests
     {
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         /// <remarks>
         /// For the RDD related tests, refer to <see cref="RDDTests"/>.
         /// </remarks>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             SparkContext sc = SparkContext.GetOrCreate(new SparkConf());
 

src/csharp/Microsoft.Spark.E2ETest/IpcTests/Sql/CatalogTests.cs

@@ -24,10 +24,10 @@ public CatalogTests(SparkFixture fixture)
         }
 
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             WithTable(_spark, new string[] { "users", "users2", "users3", "users4", "usersp" }, () =>
             {

src/csharp/Microsoft.Spark.E2ETest/IpcTests/Sql/ColumnTests.cs

@@ -14,10 +14,10 @@ namespace Microsoft.Spark.E2ETest.IpcTests
     public class ColumnTests
     {
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             Column col1 = Column("col1");
             Column col2 = Column("col2");
@@ -28,22 +28,22 @@ public void TestSignaturesV2_3_X()
 
             Assert.IsType<Column>(col1 == col2);
             Assert.IsType<Column>(col1.EqualTo(col2));
-            
+
             Assert.IsType<Column>(col1 != col2);
             Assert.IsType<Column>(col1.NotEqual(col2));
-            
-            Assert.IsType<Column>(col1 > col2);            
-            Assert.IsType<Column>(col1 > "hello");            
-            Assert.IsType<Column>(col1.Gt(col2));            
+
+            Assert.IsType<Column>(col1 > col2);
+            Assert.IsType<Column>(col1 > "hello");
+            Assert.IsType<Column>(col1.Gt(col2));
             Assert.IsType<Column>(col1.Gt("hello"));
-            
-            Assert.IsType<Column>(col1 < col2);            
-            Assert.IsType<Column>(col1 < "hello");            
-            Assert.IsType<Column>(col1.Lt(col2));            
+
+            Assert.IsType<Column>(col1 < col2);
+            Assert.IsType<Column>(col1 < "hello");
+            Assert.IsType<Column>(col1.Lt(col2));
             Assert.IsType<Column>(col1.Lt("hello"));
 
             Assert.IsType<Column>(col1 <= col2);
-            Assert.IsType<Column>(col1 <= "hello");            
+            Assert.IsType<Column>(col1 <= "hello");
             Assert.IsType<Column>(col1.Leq(col2));
             Assert.IsType<Column>(col1.Leq("hello"));
 
@@ -59,7 +59,7 @@ public void TestSignaturesV2_3_X()
 
             Assert.IsType<Column>(When(col1 == col2, 0).Otherwise(col2));
             Assert.IsType<Column>(When(col1 == col2, 0).Otherwise("hello"));
-            
+
             Assert.IsType<Column>(col1.Between(col1, col2));
             Assert.IsType<Column>(col1.Between(1, 3));
 
@@ -69,7 +69,7 @@ public void TestSignaturesV2_3_X()
 
             Assert.IsType<Column>(col1 | col2);
             Assert.IsType<Column>(col1.Or(col2));
-            
+
             Assert.IsType<Column>(col1 & col2);
             Assert.IsType<Column>(col1.And(col2));
 
@@ -139,7 +139,7 @@ public void TestSignaturesV2_3_X()
 
             Assert.IsType<Column>(col1.Over(PartitionBy(col1)));
             Assert.IsType<Column>(col1.Over());
-            
+
             Assert.Equal("col1", col1.ToString());
             Assert.Equal("col2", col2.ToString());
         }

src/csharp/Microsoft.Spark.E2ETest/IpcTests/Sql/DataFrameReaderTests.cs

@@ -20,15 +20,15 @@ public DataFrameReaderTests(SparkFixture fixture)
         }
 
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             DataFrameReader dfr = _spark.Read();
 
             Assert.IsType<DataFrameReader>(dfr.Format("json"));
-            
+
             Assert.IsType<DataFrameReader>(
                 dfr.Schema(
                     new StructType(new[]

src/csharp/Microsoft.Spark.E2ETest/IpcTests/Sql/DataFrameTests.cs

@@ -437,10 +437,10 @@ private static FxDataFrame CountCharacters(FxDataFrame dataFrame)
         }
 
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             Assert.IsType<Column>(_df["name"]);
             Assert.IsType<Column>(_df["age"]);
@@ -569,6 +569,16 @@ public void TestSignaturesV2_3_X()
 
                 Assert.IsType<DataFrame>(df.Sum("age"));
                 Assert.IsType<DataFrame>(df.Sum("age", "tempAge"));
+
+                var values = new List<object> { 19, "twenty" };
+
+                Assert.IsType<RelationalGroupedDataset>(df.Pivot("age"));
+
+                Assert.IsType<RelationalGroupedDataset>(df.Pivot(Col("age")));
+
+                Assert.IsType<RelationalGroupedDataset>(df.Pivot("age", values));
+
+                Assert.IsType<RelationalGroupedDataset>(df.Pivot(Col("age"), values));
             }
 
             Assert.IsType<RelationalGroupedDataset>(_df.Rollup("age"));
@@ -669,32 +679,12 @@ public void TestSignaturesV2_3_X()
             _df.CreateOrReplaceGlobalTempView("global_view");
 
             Assert.IsType<string[]>(_df.InputFiles().ToArray());
-        }
 
-        /// <summary>
-        /// Test signatures for APIs introduced in Spark 2.4.*.
-        /// </summary>
-        [SkipIfSparkVersionIsLessThan(Versions.V2_4_0)]
-        public void TestSignaturesV2_4_X()
-        {
             _df.IsEmpty();
 
             _df.IntersectAll(_df);
 
             _df.ExceptAll(_df);
-
-            {
-                RelationalGroupedDataset df = _df.GroupBy("name");
-                var values = new List<object> { 19, "twenty" };
-
-                Assert.IsType<RelationalGroupedDataset>(df.Pivot("age"));
-
-                Assert.IsType<RelationalGroupedDataset>(df.Pivot(Col("age")));
-
-                Assert.IsType<RelationalGroupedDataset>(df.Pivot("age", values));
-
-                Assert.IsType<RelationalGroupedDataset>(df.Pivot(Col("age"), values));
-            }
         }
 
         /// <summary>

src/csharp/Microsoft.Spark.E2ETest/IpcTests/Sql/DataFrameWriterTests.cs

@@ -20,10 +20,10 @@ public DataFrameWriterTests(SparkFixture fixture)
         }
 
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             {
                 DataFrameWriter dfw = _spark

src/csharp/Microsoft.Spark.E2ETest/IpcTests/Sql/Expressions/WindowSpecTests.cs

@@ -15,10 +15,10 @@ namespace Microsoft.Spark.E2ETest.IpcTests
     public class WindowSpecTests
     {
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             Column col1 = Column("age");
             Column col2 = Column("name");

src/csharp/Microsoft.Spark.E2ETest/IpcTests/Sql/Expressions/WindowTests.cs

@@ -15,10 +15,10 @@ namespace Microsoft.Spark.E2ETest.IpcTests
     public class WindowTests
     {
         /// <summary>
-        /// Test signatures for APIs up to Spark 2.3.*.
+        /// Test signatures for APIs up to Spark 2.4.*.
         /// </summary>
         [Fact]
-        public void TestSignaturesV2_3_X()
+        public void TestSignaturesV2_4_X()
         {
             Column col1 = Column("age");
             Column col2 = Column("name");