We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 05ec659 commit cb61473Copy full SHA for cb61473
1 file changed
spark/src/main/scala/org/apache/comet/serde/datetime.scala
@@ -546,9 +546,10 @@ object CometYears extends CometExpressionSerde[Years] {
546
}
547
548
549
- override def convert(expr: Years,
550
- inputs: Seq[Attribute],
551
- binding: Boolean): Option[ExprOuterClass.Expr] = {
+ override def convert(
+ expr: Years,
+ inputs: Seq[Attribute],
552
+ binding: Boolean): Option[ExprOuterClass.Expr] = {
553
val periodType = exprToProtoInternal(Literal("year"), inputs, binding)
554
val childExpr = exprToProtoInternal(expr.child, inputs, binding)
555
val optExpr = scalarFunctionExprToProto("datepart", Seq(periodType, childExpr): _*)
0 commit comments