e8e74a648a134fe054081a49a36b8c45f30c21bc
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public testQueryExecutionChangelog() : void renamed to public testStreamQueryExecutionChangelog() : void in class org.apache.flink.table.client.gateway.local.LocalExecutorITCase | From | To | |
| Rename Method public testQueryExecutionTable() : void renamed to public testBatchQueryExecution() : void in class org.apache.flink.table.client.gateway.local.LocalExecutorITCase | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type program : Runnable to deployer : ProgramDeployer<C> in method public startRetrieval(deployer ProgramDeployer<C>) : void in class org.apache.flink.table.client.gateway.local.DynamicResult | From | To | |
| Change Parameter Type program : Runnable to deployer : ProgramDeployer<C> in method public startRetrieval(deployer ProgramDeployer<C>) : void in class org.apache.flink.table.client.gateway.local.CollectStreamResult | From | To | |
| Move Method | 1 | ||
| Move Method private deployJob(context ExecutionContext<T>, jobGraph JobGraph, result DynamicResult<T>) : void from class org.apache.flink.table.client.gateway.local.LocalExecutor to private deployJob(context ExecutionContext<T>, jobGraph JobGraph, result DynamicResult<T>) : JobExecutionResult from class org.apache.flink.table.client.gateway.local.ProgramDeployer | From | To | |
| Rename Variable | 1 | ||
| Rename Variable program : Runnable to deployer : ProgramDeployer<T> in method private executeQueryInternal(context ExecutionContext<T>, query String) : ResultDescriptor in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Change Return Type | 1 | ||
| Change Return Type void to JobExecutionResult in method private deployJob(context ExecutionContext<T>, jobGraph JobGraph, result DynamicResult<T>) : JobExecutionResult in class org.apache.flink.table.client.gateway.local.ProgramDeployer | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute program : Runnable to deployer : ProgramDeployer<C> in class org.apache.flink.table.client.gateway.local.CollectStreamResult | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type program : Runnable to deployer : ProgramDeployer<T> in method private executeQueryInternal(context ExecutionContext<T>, query String) : ResultDescriptor in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Extract Method | 1 | ||
| Extract Method private retrieveTableResult(executor Executor, session SessionContext, resultID String) : List<String> extracted from public testQueryExecutionTable() : void in class org.apache.flink.table.client.gateway.local.LocalExecutorITCase | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type program : Runnable to deployer : ProgramDeployer<C> in class org.apache.flink.table.client.gateway.local.CollectStreamResult | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter program : Runnable to deployer : ProgramDeployer<C> in method public startRetrieval(deployer ProgramDeployer<C>) : void in class org.apache.flink.table.client.gateway.local.DynamicResult | From | To | |
| Rename Parameter program : Runnable to deployer : ProgramDeployer<C> in method public startRetrieval(deployer ProgramDeployer<C>) : void in class org.apache.flink.table.client.gateway.local.CollectStreamResult | From | To |