Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/6188#discussion_r197614200 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala --- @@ -328,6 +330,42 @@ case class TemporalOverlaps( } } + /** + * Standard conversion of the TIMESTAMPADD operator. + * Source: [[org.apache.calcite.sql2rel.StandardConvertletTable#TimestampAddConvertlet]] + */ +case class TimestampAdd( + unit: Expression, + count: Expression, + timestamp: Expression) + extends Expression { + + override private[flink] def children = unit :: count :: timestamp :: Nil --- End diff -- def children => def children: Seq[Expression]
---