0859a698253f07a28442ee7232e1adb76013dbd3
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 21
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type runtimeContext : StreamingRuntimeContext to processingTimeProvider : ProcessingTimeService in method public Kafka010Fetcher(sourceContext SourceContext<T>, assignedPartitions List<KafkaTopicPartition>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, processingTimeProvider ProcessingTimeService, autoWatermarkInterval long, userCodeClassLoader ClassLoader, enableCheckpointing boolean, taskNameWithSubtasks String, metricGroup MetricGroup, deserializer KeyedDeserializationSchema<T>, kafkaProperties Properties, pollTimeout long, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher | From | To | |
| Rename Variable | 1 | ||
| Rename Variable producerOperator : StreamSink<String> to testHarness : OneInputStreamOperatorTestHarness<String,Object> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute runtimeContext : RuntimeContext to metricGroup : MetricGroup in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type producerOperator : StreamSink<String> to testHarness : OneInputStreamOperatorTestHarness<String,Object> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator | From | To | |
| Split Parameter | 1 | ||
| Split Parameter runtimeContext : StreamingRuntimeContext to [userCodeClassLoader : ClassLoader, processingTimeProvider : ProcessingTimeService] in method protected AbstractFetcher(sourceContext SourceContext<T>, assignedPartitions List<KafkaTopicPartition>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, processingTimeProvider ProcessingTimeService, autoWatermarkInterval long, userCodeClassLoader ClassLoader, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type runtimeContext : RuntimeContext to metricGroup : MetricGroup in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter runtimeContext : StreamingRuntimeContext to processingTimeProvider : ProcessingTimeService in method public Kafka010Fetcher(sourceContext SourceContext<T>, assignedPartitions List<KafkaTopicPartition>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, processingTimeProvider ProcessingTimeService, autoWatermarkInterval long, userCodeClassLoader ClassLoader, enableCheckpointing boolean, taskNameWithSubtasks String, metricGroup MetricGroup, deserializer KeyedDeserializationSchema<T>, kafkaProperties Properties, pollTimeout long, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher | From | To |