[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16307352#comment-16307352
]
ASF GitHub Bot commented on FLINK-8302:
---------------------------------------
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5202#discussion_r159148500
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/sql/ScalarSqlFunctions.scala
---
@@ -58,4 +58,22 @@ object ScalarSqlFunctions {
OperandTypes.family(SqlTypeFamily.NUMERIC, SqlTypeFamily.NUMERIC)),
SqlFunctionCategory.NUMERIC)
+ val SHIFT_LEFT = new SqlFunction(
+ "SHIFT_LEFT",
+ SqlKind.OTHER_FUNCTION,
+ ReturnTypes.ARG0,
+ null,
+ OperandTypes.family(SqlTypeFamily.NUMERIC, SqlTypeFamily.NUMERIC),
+ SqlFunctionCategory.NUMERIC
+ )
+
+ val SHIFT_RIGHT = new SqlFunction(
+ "SHIFT_RIGHT",
+ SqlKind.OTHER_FUNCTION,
+ ReturnTypes.ARG0,
+ null,
+ OperandTypes.family(SqlTypeFamily.NUMERIC, SqlTypeFamily.NUMERIC),
+ SqlFunctionCategory.NUMERIC
--- End diff --
Second operand should be SqlTypeFamily.INTEGER.
`OperandTypes.family(SqlTypeFamily.NUMERIC, SqlTypeFamily.NUMERIC) ->
OperandTypes.family(SqlTypeFamily.NUMERIC, SqlTypeFamily.INTEGER) `
> Support shift_left and shift_right in TableAPI
> ----------------------------------------------
>
> Key: FLINK-8302
> URL: https://issues.apache.org/jira/browse/FLINK-8302
> Project: Flink
> Issue Type: Improvement
> Components: Table API & SQL
> Reporter: DuBin
> Labels: features
> Fix For: 1.5.0
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Add shift_left and shift_right support in TableAPI, shift_left(input, n) act
> as input << n, shift_right(input, n) act as input >> n.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
