flink 352a995e2aca8651046afb0767cb0d361f2571ca

352a995e2aca8651046afb0767cb0d361f2571ca

Files Diff

Added: 3
Removed: 1
Renamed: 0
Modified: 22

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Merge Attribute	1
	Merge Attribute [extraNetworkBuffersPerGate : int, networkBuffersPerChannel : int, enableCreditBased : boolean] to config : NetworkEnvironmentConfiguration in class org.apache.flink.runtime.io.network.NetworkEnvironment	From	To
	Move And Rename Method	4
	Move And Rename Method private parseQueryableStateConfiguration(config Configuration) : QueryableStateConfiguration from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration to public fromConfiguration(config Configuration) : QueryableStateConfiguration from class org.apache.flink.runtime.taskexecutor.QueryableStateConfiguration	From	To
	Move And Rename Method public hasNewNetworkBufConf(config Configuration) : boolean from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration to public hasNewNetworkConfig(config Configuration) : boolean from class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration	From	To
	Move And Rename Method protected checkNetworkConfigOld(numNetworkBuffers int) : void from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration to private checkOldNetworkConfig(numNetworkBuffers int) : void from class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration	From	To
	Move And Rename Method protected checkNetworkBufferConfig(pageSize int, networkBufFraction float, networkBufMin long, networkBufMax long) : void from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration to private checkNewNetworkConfig(pageSize int, networkBufFraction float, networkBufMin long, networkBufMax long) : void from class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration	From	To
	Move Method	3
	Move Method private createNetworkEnvironment(numBuffers int, memorySegmentSize int, partitionRequestInitialBackoff int, partitionRequestMaxBackoff int, networkBuffersPerChannel int, extraNetworkBuffersPerGate int, enableCreditBased boolean, connectionManager ConnectionManager) : NetworkEnvironment from class org.apache.flink.runtime.taskexecutor.TaskSubmissionTestEnvironment to private createNetworkEnvironment() : NetworkEnvironment from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest	From	To
	Move Method public isCreditBased() : boolean from class org.apache.flink.runtime.io.network.NetworkEnvironment to public isCreditBased() : boolean from class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration	From	To
	Move Method package checkConfigParameter(condition boolean, parameter Object, name String, errorMessage String) : void from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration to public checkConfigParameter(condition boolean, parameter Object, name String, errorMessage String) : void from class org.apache.flink.runtime.util.ConfigurationParserUtils	From	To
	Rename Variable	2
	Rename Variable tmConfig : TaskManagerServicesConfiguration to config : Configuration in method public calculateNetworkBufFromHeapSize() : void in class org.apache.flink.runtime.taskexecutor.NetworkBufferCalculationTest	From	To
	Rename Variable nettyConnectionManager : NettyConnectionManager to configuration : NetworkEnvironmentConfiguration in method private createNettyNetworkEnvironment(bufferPoolSize int, config Configuration) : NetworkEnvironment in class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment	From	To
	Rename Class	1
	Rename Class org.apache.flink.runtime.taskexecutor.TaskManagerServicesTest renamed to org.apache.flink.runtime.taskexecutor.NetworkEnvironmentConfigurationTest	From	To
	Change Variable Type	2
	Change Variable Type tmConfig : TaskManagerServicesConfiguration to config : Configuration in method public calculateNetworkBufFromHeapSize() : void in class org.apache.flink.runtime.taskexecutor.NetworkBufferCalculationTest	From	To
	Change Variable Type nettyConnectionManager : NettyConnectionManager to configuration : NetworkEnvironmentConfiguration in method private createNettyNetworkEnvironment(bufferPoolSize int, config Configuration) : NetworkEnvironment in class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment	From	To