Skip to content

Commit e60408f

Browse files
committed
remove unused code
1 parent d22d7db commit e60408f

File tree

2 files changed

+0
-5
lines changed

2 files changed

+0
-5
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/python/PythonArrowInput.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ import org.apache.spark.{SparkEnv, TaskContext}
2626
import org.apache.spark.api.python.{BasePythonRunner, PythonRDD}
2727
import org.apache.spark.sql.catalyst.InternalRow
2828
import org.apache.spark.sql.execution.arrow.ArrowWriter
29-
import org.apache.spark.sql.internal.SQLConf
3029
import org.apache.spark.sql.types.StructType
3130
import org.apache.spark.sql.util.ArrowUtils
3231
import org.apache.spark.util.Utils

sql/core/src/main/scala/org/apache/spark/sql/execution/python/PythonArrowOutput.scala

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,10 +41,6 @@ private[python] trait PythonArrowOutput[OUT <: AnyRef] { self: BasePythonRunner[
4141

4242
protected def deserializeColumnarBatch(batch: ColumnarBatch, schema: StructType): OUT
4343

44-
protected def handleStateUpdate(stream: DataInputStream): Unit = {
45-
new IllegalStateException("Should not reach here!")
46-
}
47-
4844
protected def newReaderIterator(
4945
stream: DataInputStream,
5046
writerThread: WriterThread,

0 commit comments

Comments
 (0)