??????????
String initialValues =
"INSERT INTO kafka\n"
+ "SELECT CAST(price AS DECIMAL(10, 2)), currency, "
+ " CAST(d AS DATE), CAST(t AS TIME(0)), CAST(ts AS
TIMESTAMP(3))\n"
+ "FROM (VALUES (2.02,'Euro','2019-12-12', '00:00:01',
'2019-12-12 00:00:01.001001'), \n"
+ " (1.11,'US Dollar','2019-12-12', '00:00:02', '2019-12-12
00:00:02.002001'), \n"
+ " (50,'Yen','2019-12-12', '00:00:03', '2019-12-12
00:00:03.004001'), \n"
+ " (3.1,'Euro','2019-12-12', '00:00:04', '2019-12-12
00:00:04.005001'), \n"
+ " (5.33,'US Dollar','2019-12-12', '00:00:05', '2019-12-12
00:00:05.006001'), \n"
+ " (0,'DUMMY','2019-12-12', '00:00:10', '2019-12-12
00:00:10'))\n"
+ " AS orders (price, currency, d, t, ts)";
tEnv.executeSql(initialValues).await();
??????await??????????????????????????????????????
????.await()????????.await()??????????????
??????
