287adec537f654e548404d1d337133fd21a1a937
Files Diff
- Added: 5
- Removed: 0
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Merge Attribute | 1 | ||
| Merge Attribute [latestOffset : long, beginOffset : long] to partitionScanSpec : KafkaPartitionScanSpec in class org.apache.drill.exec.store.kafka.KafkaGroupScan.PartitionScanWork | From | To | |
| Change Parameter Type | 4 | ||
| Change Parameter Type subScanSpec : KafkaSubScanSpec to subScanSpec : KafkaPartitionScanSpec in method public MessageIterator(kafkaConsumer KafkaConsumer<byte[],byte[]>, subScanSpec KafkaPartitionScanSpec, kafkaPollTimeOut long) in class org.apache.drill.exec.store.kafka.MessageIterator | From | To | |
| Change Parameter Type partitionSubScanSpecList : LinkedList<KafkaSubScanSpec> to partitionSubScanSpecList : LinkedList<KafkaPartitionScanSpec> in method public KafkaSubScan(registry StoragePluginRegistry, userName String, kafkaStoragePluginConfig KafkaStoragePluginConfig, columns List<SchemaPath>, partitionSubScanSpecList LinkedList<KafkaPartitionScanSpec>) in class org.apache.drill.exec.store.kafka.KafkaSubScan | From | To | |
| Change Parameter Type subScanSpec : KafkaSubScan.KafkaSubScanSpec to subScanSpec : KafkaPartitionScanSpec in method public KafkaRecordReader(subScanSpec KafkaPartitionScanSpec, projectedColumns List<SchemaPath>, context FragmentContext, plugin KafkaStoragePlugin) in class org.apache.drill.exec.store.kafka.KafkaRecordReader | From | To | |
| Change Parameter Type partitionSubScanSpecList : List<KafkaSubScanSpec> to partitionSubScanSpecList : List<KafkaPartitionScanSpec> in method public KafkaSubScan(userName String, kafkaStoragePlugin KafkaStoragePlugin, columns List<SchemaPath>, partitionSubScanSpecList List<KafkaPartitionScanSpec>) in class org.apache.drill.exec.store.kafka.KafkaSubScan | From | To | |
| Change Return Type | 1 | ||
| Change Return Type List<KafkaSubScanSpec> to List<KafkaPartitionScanSpec> in method public getPartitionSubScanSpecList() : List<KafkaPartitionScanSpec> in class org.apache.drill.exec.store.kafka.KafkaSubScan | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.drill.exec.store.kafka.KafkaSubScan.KafkaSubScanSpec moved and renamed to org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute partitionWorkList : List<PartitionScanWork> to partitionWorkMap : Map<TopicPartition,PartitionScanWork> in class org.apache.drill.exec.store.kafka.KafkaGroupScan | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type scanSpec : KafkaSubScan.KafkaSubScanSpec to scanSpec : KafkaPartitionScanSpec in method public getBatch(context ExecutorFragmentContext, subScan KafkaSubScan, children List<RecordBatch>) : CloseableRecordBatch in class org.apache.drill.exec.store.kafka.KafkaScanBatchCreator | From | To | |
| Change Variable Type scanSpecList : List<KafkaSubScanSpec> to scanSpecList : List<KafkaPartitionScanSpec> in method public getSpecificScan(minorFragmentId int) : KafkaSubScan in class org.apache.drill.exec.store.kafka.KafkaGroupScan | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type partitionWorkList : List<PartitionScanWork> to partitionWorkMap : Map<TopicPartition,PartitionScanWork> in class org.apache.drill.exec.store.kafka.KafkaGroupScan | From | To | |
| Change Attribute Type subScanSpec : KafkaSubScanSpec to subScanSpec : KafkaPartitionScanSpec in class org.apache.drill.exec.store.kafka.MessageIteratorTest | From | To | |
| Change Attribute Type subScanSpec : KafkaSubScanSpec to subScanSpec : KafkaPartitionScanSpec in class org.apache.drill.exec.store.kafka.KafkaRecordReader | From | To | |
| Change Attribute Type partitionSubScanSpecList : List<KafkaSubScanSpec> to partitionSubScanSpecList : List<KafkaPartitionScanSpec> in class org.apache.drill.exec.store.kafka.KafkaSubScan | From | To |