8014dade4ba844786afa85fd517d6aba807dbc81
Files Diff
- Added: 15
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Extract Method | 3 | ||
Extract Method private createModifiedExecutor(configFileName String, clusterClient ClusterClient<T>, replaceVars Map<String,String>) : LocalExecutor extracted from private createModifiedExecutor(clusterClient ClusterClient<T>, replaceVars Map<String,String>) : LocalExecutor in class org.apache.flink.table.client.gateway.local.LocalExecutorITCase | From | To | |
Extract Method private retrieveChangelogResult(executor Executor, session SessionContext, resultID String) : List<String> extracted from public testStreamQueryExecutionChangelog() : void in class org.apache.flink.table.client.gateway.local.LocalExecutorITCase | From | To | |
Extract Method private createDefaultExecutor(configFileName String, clusterClient ClusterClient<T>) : LocalExecutor extracted from private createDefaultExecutor(clusterClient ClusterClient<T>) : LocalExecutor in class org.apache.flink.table.client.gateway.local.LocalExecutorITCase | From | To |