fsk119 commented on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814182307
You can reuse these codes in the `setup` between
`PushFilterInCalcIntoTableSourceRuleTest ` and
`PushFilterIntoTableSourceScanRuleTest `.
```
// name: STRING, id: LONG, amount: INT, price: DOUBLE
String ddl1 =
"CREATE TABLE MyTable (\n"
+ " name STRING,\n"
+ " id bigint,\n"
+ " amount int,\n"
+ " price double\n"
+ ") WITH (\n"
+ " 'connector' = 'values',\n"
+ " 'filterable-fields' = 'amount',\n"
+ " 'bounded' = 'true'\n"
+ ")";
util().tableEnv().executeSql(ddl1);
String ddl2 =
"CREATE TABLE VirtualTable (\n"
+ " name STRING,\n"
+ " id bigint,\n"
+ " amount int,\n"
+ " virtualField as amount + 1,\n"
+ " price double\n"
+ ") WITH (\n"
+ " 'connector' = 'values',\n"
+ " 'filterable-fields' = 'amount',\n"
+ " 'bounded' = 'true'\n"
+ ")";
util().tableEnv().executeSql(ddl2);
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
