d8a376a85e0fd54c725e9117396fc5819ce17dfa
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 20
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type context : ExecutionContext to tableEnv : TableEnvironment in method private createTable(tableEnv TableEnvironment, query String) : Table in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Move Method | 9 | ||
| Move Method public getQueryConfig() : QueryConfig from class org.apache.flink.table.client.gateway.local.ExecutionContext to public getQueryConfig() : QueryConfig from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Method private createExecutionEnvironment() : ExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext to private createExecutionEnvironment() : ExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Method private createStreamExecutionEnvironment() : StreamExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext to private createStreamExecutionEnvironment() : StreamExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Method public getExecutionConfig() : ExecutionConfig from class org.apache.flink.table.client.gateway.local.ExecutionContext to public getExecutionConfig() : ExecutionConfig from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Method private createQueryConfig() : QueryConfig from class org.apache.flink.table.client.gateway.local.ExecutionContext to private createQueryConfig() : QueryConfig from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Method public getStreamExecutionEnvironment() : StreamExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext to public getStreamExecutionEnvironment() : StreamExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Method public getTableEnvironment() : TableEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext to public getTableEnvironment() : TableEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Method public getExecutionEnvironment() : ExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext to public getExecutionEnvironment() : ExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Method public createPlan(name String, flinkConfig Configuration) : FlinkPlan from class org.apache.flink.table.client.gateway.local.ExecutionContext to private createPlan(name String, flinkConfig Configuration) : FlinkPlan from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Rename Variable | 2 | ||
| Rename Variable mergedEnv : Environment to envInst : ExecutionContext.EnvironmentInstance in method private executeQueryInternal(context ExecutionContext<T>, query String) : ResultDescriptor in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Rename Variable mergedEnv : Environment to context : ExecutionContext<?> in method public cancelQuery(session SessionContext, resultId String) : void in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Change Return Type | 3 | ||
| Change Return Type DynamicResult to DynamicResult<T> in method public getResult(resultId String) : DynamicResult<T> in class org.apache.flink.table.client.gateway.local.ResultStore | From | To | |
| Change Return Type DynamicResult to DynamicResult<T> in method public createResult(env Environment, schema TableSchema, config ExecutionConfig) : DynamicResult<T> in class org.apache.flink.table.client.gateway.local.ResultStore | From | To | |
| Change Return Type ExecutionContext to ExecutionContext<?> in method private getOrCreateExecutionContext(session SessionContext) : ExecutionContext<?> in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Move Attribute | 4 | ||
| Move Attribute private queryConfig : QueryConfig from class org.apache.flink.table.client.gateway.local.ExecutionContext to private queryConfig : QueryConfig from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Attribute private streamExecEnv : StreamExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext to private streamExecEnv : StreamExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Attribute private execEnv : ExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext to private execEnv : ExecutionEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Move Attribute private tableEnv : TableEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext to private tableEnv : TableEnvironment from class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.table.client.gateway.local.ExecutionContext.EnvironmentInstance from class org.apache.flink.table.client.gateway.local.ExecutionContext | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute execEnv : ExecutionEnvironment to clusterSpec : ClusterSpecification in class org.apache.flink.table.client.gateway.local.ExecutionContext | From | To | |
| Rename Attribute streamExecEnv : StreamExecutionEnvironment to runOptions : RunOptions in class org.apache.flink.table.client.gateway.local.ExecutionContext | From | To | |
| Rename Attribute queryConfig : QueryConfig to commandLine : CommandLine in class org.apache.flink.table.client.gateway.local.ExecutionContext | From | To | |
| Extract Variable | 1 | ||
| Extract Variable tableEnv : TableEnvironment in method public explainStatement(session SessionContext, statement String) : String from class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type result : DynamicResult to result : DynamicResult<T> in method private cancelQueryInternal(context ExecutionContext<T>, resultId String) : void in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Change Variable Type context : ExecutionContext to context : ExecutionContext<?> in method public executeQuery(session SessionContext, query String) : ResultDescriptor in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Change Variable Type mergedEnv : Environment to envInst : ExecutionContext.EnvironmentInstance in method private executeQueryInternal(context ExecutionContext<T>, query String) : ResultDescriptor in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Change Variable Type mergedEnv : Environment to context : ExecutionContext<?> in method public cancelQuery(session SessionContext, resultId String) : void in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Extract Method | 3 | ||
| Extract Method private executeQueryInternal(context ExecutionContext<T>, query String) : ResultDescriptor extracted from public executeQuery(session SessionContext, query String) : ResultDescriptor in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Extract Method private discoverDependencies(jars List<URL>, libraries List<URL>) : List<URL> extracted from public LocalExecutor(defaultEnv URL, jars List<URL>, libraries List<URL>) in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Extract Method private cancelQueryInternal(context ExecutionContext<T>, resultId String) : void extracted from public cancelQuery(session SessionContext, resultId String) : void in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Change Attribute Type | 5 | ||
| Change Attribute Type execEnv : ExecutionEnvironment to clusterSpec : ClusterSpecification in class org.apache.flink.table.client.gateway.local.ExecutionContext | From | To | |
| Change Attribute Type streamExecEnv : StreamExecutionEnvironment to runOptions : RunOptions in class org.apache.flink.table.client.gateway.local.ExecutionContext | From | To | |
| Change Attribute Type results : Map<String,DynamicResult> to results : Map<String,DynamicResult<?>> in class org.apache.flink.table.client.gateway.local.ResultStore | From | To | |
| Change Attribute Type queryConfig : QueryConfig to commandLine : CommandLine in class org.apache.flink.table.client.gateway.local.ExecutionContext | From | To | |
| Change Attribute Type executionContext : ExecutionContext to executionContext : ExecutionContext<?> in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter context : ExecutionContext to tableEnv : TableEnvironment in method private createTable(tableEnv TableEnvironment, query String) : Table in class org.apache.flink.table.client.gateway.local.LocalExecutor | From | To |