Skip to content

Commit 15c6849

Browse files
committed
[SPARK-55285][SQL][PYTHON][FOLLOW-UP] Code clean up
### What changes were proposed in this pull request? follow up of apache#54068, we don't need the `_schema` trick now ### Why are the changes needed? to make the field names consistent with others ### Does this PR introduce _any_ user-facing change? no ### How was this patch tested? ci ### Was this patch authored or co-authored using generative AI tooling? no Closes apache#54088 from zhengruifeng/follow_up_init. Authored-by: Ruifeng Zheng <ruifengz@apache.org> Signed-off-by: Ruifeng Zheng <ruifengz@apache.org>
1 parent 7792122 commit 15c6849

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -49,17 +49,17 @@ class TransformWithStateInPySparkPythonRunner(
4949
funcs: Seq[(ChainedPythonFunctions, Long)],
5050
evalType: Int,
5151
argOffsets: Array[Array[Int]],
52-
_schema: StructType,
52+
schema: StructType,
5353
processorHandle: StatefulProcessorHandleImpl,
54-
_timeZoneId: String,
54+
timeZoneId: String,
5555
initialRunnerConf: Map[String, String],
5656
override val pythonMetrics: Map[String, SQLMetric],
5757
jobArtifactUUID: Option[String],
5858
groupingKeySchema: StructType,
5959
batchTimestampMs: Option[Long],
6060
eventTimeWatermarkForEviction: Option[Long])
6161
extends TransformWithStateInPySparkPythonBaseRunner[InType](
62-
funcs, evalType, argOffsets, _schema, processorHandle, _timeZoneId,
62+
funcs, evalType, argOffsets, schema, processorHandle, timeZoneId,
6363
initialRunnerConf, pythonMetrics, jobArtifactUUID, groupingKeySchema,
6464
batchTimestampMs, eventTimeWatermarkForEviction)
6565
with PythonArrowInput[InType] {

0 commit comments

Comments
 (0)