[
https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167874#comment-17167874
]
Hequn Cheng commented on FLINK-18763:
-------------------------------------
[~twalthr] Hi, thanks for your comments. We only plan to support some basic
types(STRING, BOOLEAN, SHORT, INT, etc.) in Python DataStream API. The types
like ObjectTypeInfo would not be included. We need the `BasicTypeInfo` since
lots of operations in DataStream use TypeInfos, such as the from_collection():
{code}
ds = self.env.from_collection([(1, 'Hi', 'Hello'), (2, 'Hello', 'Hi')],
type_info=Types.ROW([Types.INT(), Types.STRING(), Types.STRING()]))
{code}
BTW, what do you mean by legacy typeinfo? Do we also plan to support a new type
system in DataStream API?
> Support basic TypeInformation for Python DataStream API
> -------------------------------------------------------
>
> Key: FLINK-18763
> URL: https://issues.apache.org/jira/browse/FLINK-18763
> Project: Flink
> Issue Type: Sub-task
> Reporter: Hequn Cheng
> Priority: Major
> Labels: pull-request-available
>
> Supports basic TypeInformation including BasicTypeInfo, LocalTimeTypeInfo,
> PrimitiveArrayTypeInfo, RowTypeInfo.
> Types.ROW()/Types.ROW_NAMED()/Types.PRIMITIVE_ARRAY() should also be
> supported.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
