Skip to content

Commit 0393510

Browse files
committed
overriding prettyName
1 parent 89d748b commit 0393510

File tree

2 files changed

+2
-14
lines changed

2 files changed

+2
-14
lines changed

external/avro/src/main/scala/org/apache/spark/sql/avro/AvroDataToCatalyst.scala

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -109,13 +109,7 @@ case class AvroDataToCatalyst(
109109
}
110110
}
111111

112-
override def simpleString: String = {
113-
s"from_avro(${child.sql}, ${dataType.simpleString}, ${options.toString()})"
114-
}
115-
116-
override def sql: String = {
117-
s"from_avro(${child.sql}, ${dataType.catalogString}, ${options.toString()})"
118-
}
112+
override def prettyName: String = "from_avro"
119113

120114
override protected def doGenCode(ctx: CodegenContext, ev: ExprCode): ExprCode = {
121115
val expr = ctx.addReferenceObj("this", this)

external/avro/src/main/scala/org/apache/spark/sql/avro/CatalystDataToAvro.scala

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -52,13 +52,7 @@ case class CatalystDataToAvro(child: Expression) extends UnaryExpression {
5252
out.toByteArray
5353
}
5454

55-
override def simpleString: String = {
56-
s"to_avro(${child.sql}, ${child.dataType.simpleString})"
57-
}
58-
59-
override def sql: String = {
60-
s"to_avro(${child.sql}, ${child.dataType.catalogString})"
61-
}
55+
override def prettyName: String = "to_avro"
6256

6357
override protected def doGenCode(ctx: CodegenContext, ev: ExprCode): ExprCode = {
6458
val expr = ctx.addReferenceObj("this", this)

0 commit comments

Comments
 (0)