Hi, there are two useful utilities classes:

  *
https://nightlies.apache.org/flink/flink-docs-release-1.20/api/java//org/apache/flink/table/types/utils/DataTypeUtils.html
  *
https://nightlies.apache.org/flink/flink-docs-release-1.20/api/java//org/apache/flink/table/types/logical/utils/LogicalTypeChecks.html

My use case is that I am converting from Table to DataStream and I have a table 
that contains multiple time attributes (for e.g after a window join).

Unfortunately, the tables are generated from user input so I can't stop them 
outputting multiple attributes. I need to programmatically strip the attributes 
at the Java level - but these classes are marked as @internal.

Are they safe to use? Should I raise a PR to mark them as @PublicEvolving if 
they are safe?

Many thanks


--



Nic Townsend

IBM Event Processing

Architect / Senior Engineer

Slack: @nictownsend

Bluesky: @nict0wnsend.bsky.social




Unless otherwise stated above:

IBM United Kingdom Limited
Registered in England and Wales with number 741598
Registered office: Building C, IBM Hursley Office, Hursley Park Road, 
Winchester, Hampshire SO21 2JN

Reply via email to