[flink] 02/05: [FLINK-13237][table-planner-blink] TypeInfoDataTypeConverter should support convert from DayTimeIntervalType

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 93c056a5020a649ddf2a21e69b4ea9735f632c49
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Thu Jul 25 16:25:33 2019 +0800

    [FLINK-13237][table-planner-blink] TypeInfoDataTypeConverter should support 
convert from DayTimeIntervalType
---
 .../apache/flink/table/runtime/types/TypeInfoDataTypeConverter.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/types/TypeInfoDataTypeConverter.java
 
b/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/types/TypeInfoDataTypeConverter.java
index 044356c..b08f72d 100644
--- 
a/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/types/TypeInfoDataTypeConverter.java
+++ 
b/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/types/TypeInfoDataTypeConverter.java
@@ -44,6 +44,7 @@ import org.apache.flink.table.types.logical.DecimalType;
 import org.apache.flink.table.types.logical.LogicalType;
 import org.apache.flink.table.types.logical.RowType;
 import org.apache.flink.table.types.utils.TypeConversions;
+import org.apache.flink.table.typeutils.TimeIntervalTypeInfo;
 import org.apache.flink.types.Row;
 import org.apache.flink.util.Preconditions;
 
@@ -110,6 +111,10 @@ public class TypeInfoDataTypeConverter {
                        case BINARY:
                        case VARBINARY: // ignore precision
                                return 
PrimitiveArrayTypeInfo.BYTE_PRIMITIVE_ARRAY_TYPE_INFO;
+                       case INTERVAL_YEAR_MONTH:
+                               return TimeIntervalTypeInfo.INTERVAL_MONTHS;
+                       case INTERVAL_DAY_TIME:
+                               return TimeIntervalTypeInfo.INTERVAL_MILLIS;
                        case ARRAY:
                                if (dataType instanceof CollectionDataType &&
                                                
!isPrimitive(((CollectionDataType) 
dataType).getElementDataType().getLogicalType())) {