41f58182289226850b23c61a32f01223485d4775
Files Diff
- Added: 1
- Removed: 4
- Renamed: 0
- Modified: 14
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public testMetricsAndEndOfStream() : void renamed to public testEndOfStream() : void in class org.apache.flink.streaming.connectors.kafka.Kafka09ITCase | From | To | |
| Rename Method public runMetricsAndEndOfStreamTest() : void renamed to public runEndOfStreamTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To | |
| Rename Method public testMetricsAndEndOfStream() : void renamed to public testEndOfStream() : void in class org.apache.flink.streaming.connectors.kafka.Kafka08ITCase | From | To | |
| Merge Attribute | 1 | ||
| Merge Attribute [userCodeClassLoader : ClassLoader, taskName : String] to runtimeContext : RuntimeContext in class org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher | From | To | |
| Pull Up Attribute | 1 | ||
| Pull Up Attribute public KEY_DISABLE_METRICS : String from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 to public KEY_DISABLE_METRICS : String from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase | From | To | |
| Move And Rename Attribute | 1 | ||
| Move And Rename Attribute private forwardKafkaMetrics : boolean renamed to protected useMetrics : boolean and moved from class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher to class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter forwardKafkaMetrics : boolean to useMetrics : boolean in method public Kafka09Fetcher(sourceContext SourceContext<T>, assignedPartitions List<KafkaTopicPartition>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, runtimeContext StreamingRuntimeContext, deserializer KeyedDeserializationSchema<T>, kafkaProperties Properties, pollTimeout long, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher | From | To |