51a5048b24ffe7655e2197c04aa844239bf1af83
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type runtimeContext : StreamingRuntimeContext to timerService : TimeServiceProvider in method package PeriodicWatermarkEmitter(allPartitions KafkaTopicPartitionStateWithPeriodicWatermarks<?,?>[], emitter SourceContext<?>, timerService TimeServiceProvider, autoWatermarkInterval long) in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.PeriodicWatermarkEmitter | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute triggerContext : StreamingRuntimeContext to timerService : TimeServiceProvider in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.PeriodicWatermarkEmitter | From | To | |
| Rename Attribute task : AsyncExceptionHandler to exceptionHandler : AsyncExceptionHandler in class org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider.TriggerTask | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type triggerContext : StreamingRuntimeContext to timerService : TimeServiceProvider in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.PeriodicWatermarkEmitter | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter task : AsyncExceptionHandler to exceptionHandler : AsyncExceptionHandler in method public create(exceptionHandler AsyncExceptionHandler, executor ScheduledExecutorService, checkpointLock Object) : DefaultTimeServiceProvider in class org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider | From | To | |
| Rename Parameter task : AsyncExceptionHandler to exceptionHandler : AsyncExceptionHandler in method package TriggerTask(exceptionHandler AsyncExceptionHandler, lock Object, target Triggerable, timestamp long) in class org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider.TriggerTask | From | To | |
| Rename Parameter runtimeContext : StreamingRuntimeContext to timerService : TimeServiceProvider in method package PeriodicWatermarkEmitter(allPartitions KafkaTopicPartitionStateWithPeriodicWatermarks<?,?>[], emitter SourceContext<?>, timerService TimeServiceProvider, autoWatermarkInterval long) in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.PeriodicWatermarkEmitter | From | To |