snuyanzin commented on code in PR #28290:
URL: https://github.com/apache/flink/pull/28290#discussion_r3448174431
##########
flink-table/flink-table-planner/src/main/java/org/apache/calcite/jdbc/SimpleCalciteSchema.java:
##########
@@ -133,38 +133,8 @@ public CalciteSchema add(String name, Schema schema) {
}
@Override
- protected @Nullable CalciteSchema getImplicitSubSchema(
- String schemaName, boolean caseSensitive) {
- // Check implicit schemas.
- final String schemaName2 =
- caseSensitive
- ? schemaName
- : caseInsensitiveLookup(schema.getSubSchemaNames(),
schemaName);
- if (schemaName2 == null) {
- return null;
- }
- final Schema s = schema.getSubSchema(schemaName2);
- if (s == null) {
- return null;
- }
- return new SimpleCalciteSchema(this, s, schemaName2);
- }
-
- @Override
- protected @Nullable TableEntry getImplicitTable(String tableName, boolean
caseSensitive) {
- // Check implicit tables.
- final String tableName2 =
- caseSensitive
- ? tableName
- : caseInsensitiveLookup(schema.getTableNames(),
tableName);
- if (tableName2 == null) {
- return null;
- }
- final Table table = schema.getTable(tableName2);
- if (table == null) {
- return null;
- }
- return tableEntry(tableName2, table);
+ protected CalciteSchema createSubSchema(Schema schema, String name) {
Review Comment:
sync with Calcite
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
