??DataStream??Tablerowtime??udtf??sqltableEnv.sql()Rowtime
attributes must not be in the input rows of a regular join. As a workaround
you can cast the time attributes of input tables to TIMESTAMP
before. to_
tem.out.println("??resultTable" + result);
result.printSchema();
tableEnv.createTemporaryView("resultTable", result);
DataStream midStream = tableEnv.toAppendStream(result,
MidInfo.class);
Table midTable =
flink1.14
| |
|
|
ccc0606fight...@163.com
|
| ?? | L Y<531599...@qq.com.INVALID> |
| | 2023??5??20?? 01:10 |
| ?? | user-zh |
| | ??table apirowtime?? |
HI??
??mid
->
element.getEvenTime()));
|
| |
|
|
ccc0606fight...@163.com
|
| ?? | L Y<531599...@qq.com.INVALID> |
| | 2023??5??23?? 01:25 |
| ?? | user-zh |
| ???? | ??table apirowtime?? |
HI??
sno=b8e947dc8498edfb9c7605f290fc13ba\npartenerName=zzinfo\nuniqueid=1C0FF05B-D047-45B4-8212-6AD8627DBA4F\nEmptyFields=Token&\ntztSDKType=0\n"}
|
| |
|
|
ccc0606fight...@163.com
|
| ?? | L Y<531599...@qq.com.INVALID>
