Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5202#discussion_r160046904
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala
---
@@ -109,4 +110,45 @@ 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 = {
+ input << n
+ }
+
+ /**
+ * Returns the Long number after the input number left shift n bits
+ * @param input Long type
+ * @param n
+ * @return input << n
+ */
+ def shiftLeft(input: Long, n: Int): Long = {
+ input << n
+ }
+
+ /**
+ * Returns the Int number after the input number right shift n bits
--- End diff --
Add `.` at the end of sentence.
---
