Details
-
Sub-task
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
3.1.0
-
None
-
None
Description
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/WriteToMicroBatchDataSource.scala
Warning:Warning:line (36)class WriteToDataSourceV2 in package v2 is deprecated (since 2.4.0): Use specific logical plans like AppendData instead def createPlan(batchId: Long): WriteToDataSourceV2 = { Warning:Warning:line (37)class WriteToDataSourceV2 in package v2 is deprecated (since 2.4.0): Use specific logical plans like AppendData instead WriteToDataSourceV2(new MicroBatchWrite(batchId, write), query)
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQuerySuite.scala
Warning:Warning:line (703)a pure expression does nothing in statement position; multiline expressions might require enclosing parentheses q1
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingAggregationSuite.scala
Warning:Warning:line (285)object typed in package scalalang is deprecated (since 3.0.0): please use untyped builtin aggregate functions.
val aggregated = inputData.toDS().groupByKey(_._1).agg(typed.sumLong(_._2))