4a727c0a224921ec03d9ecc81455dd2815c89d15
Files Diff
- Added: 8
- Removed: 1
- Renamed: 0
- Modified: 136
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 1 | ||
Change Parameter Type defaultSchemas : List<String> to defaultSchemas : List<List<String>> in method public FlinkCalciteCatalogReader(rootSchema CalciteSchema, defaultSchemas List<List<String>>, typeFactory RelDataTypeFactory, config CalciteConnectionConfig) in class org.apache.flink.table.calcite.FlinkCalciteCatalogReader | From | To | |
Extract Variable | 1 | ||
Extract Variable refId : String in method private convertToDataStreamScan(operation DataStreamQueryOperation<?>) : RelNode from class org.apache.flink.table.plan.QueryOperationConverter.SingleRelVisitor | From | To | |
Rename Parameter | 1 | ||
Rename Parameter tableSourceTable : TableSourceQueryOperation<U> to tableSourceOperation : TableSourceQueryOperation<U> in method public visit(tableSourceOperation TableSourceQueryOperation<U>) : RelNode in class org.apache.flink.table.plan.QueryOperationConverter.SingleRelVisitor | From | To |