5de1ef7009057f82c4adfc687d360c8c9a15ddd3
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 2 | ||
| Change Return Type Record<byte[]> to Record<KeyValue<byte[],byte[]>> in method private processSourceRecord(srcRecord SourceRecord) : Record<KeyValue<byte[],byte[]>> in class org.apache.pulsar.io.kafka.connect.KafkaConnectSource | From | To | |
| Change Return Type Record<byte[]> to Record<KeyValue<byte[],byte[]>> in method public read() : Record<KeyValue<byte[],byte[]>> in class org.apache.pulsar.io.kafka.connect.KafkaConnectSource | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type record : Record<byte[]> to record : Record<KeyValue<byte[],byte[]>> in method public testOpenAndRead() : void in class org.apache.pulsar.io.kafka.connect.KafkaConnectSourceTest | From | To | |
| Extract Variable | 3 | ||
| Extract Variable readBack3 : String in method public testOpenAndRead() : void from class org.apache.pulsar.io.kafka.connect.KafkaConnectSourceTest | From | To | |
| Extract Variable readBack1 : String in method public testOpenAndRead() : void from class org.apache.pulsar.io.kafka.connect.KafkaConnectSourceTest | From | To | |
| Extract Variable readBack2 : String in method public testOpenAndRead() : void from class org.apache.pulsar.io.kafka.connect.KafkaConnectSourceTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type outstandingRecords : IdentityHashMap<SourceRecord,SourceRecord> to outstandingRecords : AtomicInteger in class org.apache.pulsar.io.kafka.connect.KafkaConnectSource | From | To |