Hi,
Here's an example that works for me:
"""
import org.apache.flink.api.common.typeinfo.Types;
import org.apache.flink.api.java.typeutils.RowTypeInfo;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironme
Hi,
I'm pulling in Timo and Jark as they know Table API better.
Regards,
Roman
On Sun, Apr 11, 2021 at 3:36 PM vtygoss wrote:
>
> Hi All,
>
>
> there is a scenario where I need to process OGG Log data in kafka using Flink
> Sql. I can convert the OGG Log Stream to DataStream and each event
>
Hi All,
there is a scenario where I need to process OGG Log data in kafka using Flink
Sql. I can convert the OGG Log Stream to DataStream and each event has
RowKind, but i have trouble converting DataStream to a Table.
For test, i tried StreamTableEnvironment#fromDataStream and createTemporary
