提交 817da8a8 编写于 作者: Louisxu1215's avatar Louisxu1215 提交者: Jark Wu

[FLINK-13353][table-planner] Remove 2 args constructor in REPLACE expression

This closes #9218
上级 d57741ce
......@@ -304,12 +304,8 @@ class PlannerExpressionConverter private extends ApiExpressionVisitor[PlannerExp
}
case REPLACE =>
assert(args.size == 2 || args.size == 3)
if (args.size == 2) {
new Replace(args.head, args.last)
} else {
Replace(args.head, args(1), args.last)
}
assert(args.size == 3)
Replace(args.head, args(1), args.last)
case TRIM =>
assert(args.size == 4)
......
......@@ -476,8 +476,6 @@ case class Replace(
search: PlannerExpression,
replacement: PlannerExpression) extends PlannerExpression with InputTypeSpec {
def this(str: PlannerExpression, begin: PlannerExpression) = this(str, begin, CharLength(str))
override private[flink] def children: Seq[PlannerExpression] = str :: search :: replacement :: Nil
override private[flink] def resultType: TypeInformation[_] = STRING_TYPE_INFO
......
......@@ -285,12 +285,8 @@ class PlannerExpressionConverter private extends ApiExpressionVisitor[PlannerExp
}
case REPLACE =>
assert(args.size == 2 || args.size == 3)
if (args.size == 2) {
new Replace(args.head, args.last)
} else {
Replace(args.head, args(1), args.last)
}
assert(args.size == 3)
Replace(args.head, args(1), args.last)
case TRIM =>
assert(args.size == 4)
......
......@@ -569,8 +569,6 @@ case class Replace(
search: PlannerExpression,
replacement: PlannerExpression) extends PlannerExpression with InputTypeSpec {
def this(str: PlannerExpression, begin: PlannerExpression) = this(str, begin, CharLength(str))
override private[flink] def children: Seq[PlannerExpression] = str :: search :: replacement :: Nil
override private[flink] def resultType: TypeInformation[_] = STRING_TYPE_INFO
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册