Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5202#discussion_r159148345
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala
---
@@ -109,4 +110,75 @@ object ScalarFunctions {
Math.log(x) / Math.log(base)
}
}
+
+ /**
+ * Returns the Int number after the input number left shift n bits
+ * @param input Int type
+ * @param n
+ * @return input << n
+ */
+ def shiftLeft(input: Int, n: Int): Int = {
+ _shiftLeft(input, n).asInstanceOf[Int]
--- End diff --
input << n ?
---
