flink f8ca273549aded00c7cd12699cebc1f5bba83153

f8ca273549aded00c7cd12699cebc1f5bba83153

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 19

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	3
	Change Parameter Type specificStartupDate : Date to startupTimestamp : Long in method protected readSequence(env StreamExecutionEnvironment, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>, startupTimestamp Long, cc Properties, topicName String, partitionsToValuesCountAndStartOffset Map<Integer,Tuple2<Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Change Parameter Type specificStartupDate : Date to startupTimestamp : Long in method protected setKafkaConsumerOffset(startupMode StartupMode, consumer FlinkKafkaConsumerBase<Tuple2<Integer,Integer>>, specificStartupOffsets Map<KafkaTopicPartition,Long>, startupTimestamp Long) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Change Parameter Type specificStartupDate : Date to startupTimestamp : Long in method protected readSequence(env StreamExecutionEnvironment, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>, startupTimestamp Long, cc Properties, sourceParallelism int, topicName String, valuesCount int, startFrom int) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Change Return Type	1
	Change Return Type TopicWithStartDate to void in method protected writeAppendSequence(topicName String, originalNumElements int, numElementsToAppend int, parallelism int) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Parameterize Variable	3
	Parameterize Variable attempt : int to numElementsToAppend : int in method protected writeAppendSequence(topicName String, originalNumElements int, numElementsToAppend int, parallelism int) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Parameterize Variable topicName : String to topic : String in method private validateSequence(topic String, parallelism int, deserSchema KeyedDeserializationSchema<Tuple2<Integer,Integer>>, totalNumElements int) : boolean in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Extract Method	2
	Extract Method private validateSequence(topic String, parallelism int, deserSchema KeyedDeserializationSchema<Tuple2<Integer,Integer>>, totalNumElements int) : boolean extracted from protected writeAppendSequence(baseTopicName String, numElements int, parallelism int, replicationFactor int) : TopicWithStartDate in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Extract Method private validateSequence(topic String, parallelism int, deserSchema KeyedDeserializationSchema<Tuple2<Integer,Integer>>, totalNumElements int) : boolean extracted from protected writeSequence(baseTopicName String, numElements int, parallelism int, replicationFactor int) : String in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Rename Parameter	4
	Rename Parameter baseTopicName : String to topicName : String in method protected writeAppendSequence(topicName String, originalNumElements int, numElementsToAppend int, parallelism int) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Rename Parameter specificStartupDate : Date to startupTimestamp : Long in method protected readSequence(env StreamExecutionEnvironment, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>, startupTimestamp Long, cc Properties, topicName String, partitionsToValuesCountAndStartOffset Map<Integer,Tuple2<Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Rename Parameter specificStartupDate : Date to startupTimestamp : Long in method protected setKafkaConsumerOffset(startupMode StartupMode, consumer FlinkKafkaConsumerBase<Tuple2<Integer,Integer>>, specificStartupOffsets Map<KafkaTopicPartition,Long>, startupTimestamp Long) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To
	Rename Parameter specificStartupDate : Date to startupTimestamp : Long in method protected readSequence(env StreamExecutionEnvironment, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>, startupTimestamp Long, cc Properties, sourceParallelism int, topicName String, valuesCount int, startFrom int) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase	From	To