d1f2d722588c1e979510b5de5c8c22dc51d126f1
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Move Method | 2 | ||
Move Method public getObjectInspector(flinkType DataType) : ObjectInspector from class org.apache.flink.batch.connectors.hive.HiveTableUtil to public getObjectInspector(flinkType DataType) : ObjectInspector from class org.apache.flink.table.catalog.hive.util.HiveTableUtil | From | To | |
Move Method private getObjectInspector(type TypeInfo) : ObjectInspector from class org.apache.flink.batch.connectors.hive.HiveTableUtil to private getObjectInspector(type TypeInfo) : ObjectInspector from class org.apache.flink.table.catalog.hive.util.HiveTableUtil | From | To | |
Rename Attribute | 4 | ||
Rename Attribute partitionCols : List<String> to partitionColumns : List<String> in class org.apache.flink.batch.connectors.hive.HiveTableOutputFormat | From | To | |
Rename Attribute numNonPartitionCols : int to numNonPartitionColumns : int in class org.apache.flink.batch.connectors.hive.HiveTableOutputFormat | From | To | |
Rename Attribute dbName : String to databaseName : String in class org.apache.flink.batch.connectors.hive.HiveTableOutputFormat | From | To | |
Rename Attribute tblProperties : Properties to tableProperties : Properties in class org.apache.flink.batch.connectors.hive.HiveTableOutputFormat | From | To | |
Extract Method | 1 | ||
Extract Method private createCatalogTable(tableSchema TableSchema, numPartCols int) : HiveCatalogTable extracted from private createDestTable(dbName String, tblName String) : RowTypeInfo in class org.apache.flink.batch.connectors.hive.HiveTableOutputFormatTest | From | To | |
Extract And Move Method | 1 | ||
Extract And Move Method public createHivePartition(dbName String, tableName String, values List<String>, sd StorageDescriptor, parameters Map<String,String>) : Partition extracted from private instantiateHivePartition(hiveTable Table, partitionSpec CatalogPartitionSpec, catalogPartition CatalogPartition) : Partition in class org.apache.flink.table.catalog.hive.HiveCatalog & moved to class org.apache.flink.table.catalog.hive.util.HiveTableUtil | From | To | |
Rename Parameter | 3 | ||
Rename Parameter tblProperties : Properties to tableProperties : Properties in method public HiveTableOutputFormat(jobConf JobConf, databaseName String, tableName String, partitionColumns List<String>, rowTypeInfo RowTypeInfo, hiveTablePartition HiveTablePartition, tableProperties Properties, overwrite boolean) in class org.apache.flink.batch.connectors.hive.HiveTableOutputFormat | From | To | |
Rename Parameter dbName : String to databaseName : String in method public HiveTableOutputFormat(jobConf JobConf, databaseName String, tableName String, partitionColumns List<String>, rowTypeInfo RowTypeInfo, hiveTablePartition HiveTablePartition, tableProperties Properties, overwrite boolean) in class org.apache.flink.batch.connectors.hive.HiveTableOutputFormat | From | To | |
Rename Parameter partitionCols : List<String> to partitionColumns : List<String> in method public HiveTableOutputFormat(jobConf JobConf, databaseName String, tableName String, partitionColumns List<String>, rowTypeInfo RowTypeInfo, hiveTablePartition HiveTablePartition, tableProperties Properties, overwrite boolean) in class org.apache.flink.batch.connectors.hive.HiveTableOutputFormat | From | To |