Skip to content

Commit 56c925d

Browse files
committed
Creating json parser in out of the method.
1 parent 064bc5c commit 56c925d

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/jsonExpressions.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -760,9 +760,10 @@ case class StructsToJson(
760760
case class SchemaOfJson(child: Expression)
761761
extends UnaryExpression with String2StringExpression with CodegenFallback {
762762

763+
private val jsonOptions = new JSONOptions(Map.empty, "UTC")
764+
private val jsonFactory = new JsonFactory()
765+
763766
override def convert(v: UTF8String): UTF8String = {
764-
val jsonOptions = new JSONOptions(Map.empty, "UTC")
765-
val jsonFactory = new JsonFactory()
766767
val dt = Utils.tryWithResource(CreateJacksonParser.utf8String(jsonFactory, v)) { parser =>
767768
parser.nextToken()
768769
inferField(parser, jsonOptions)

0 commit comments

Comments
 (0)