Skip to content

Commit

Permalink
Clean up code
Browse files Browse the repository at this point in the history
  • Loading branch information
surnaik committed Jun 14, 2024
1 parent b14caee commit 55b378d
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -189,8 +189,9 @@ object VeloxBackendSettings extends BackendSettingsApi {
val fileSinkConfField = format.getClass.getDeclaredField("fileSinkConf")
fileSinkConfField.setAccessible(true)
val fileSinkConf = fileSinkConfField.get(hiveFileFormat)
val getTableInfoMethod = fileSinkConf.getClass.getDeclaredMethod("getTableInfo")
val tableInfo = getTableInfoMethod.invoke(fileSinkConf)
val tableInfoField = fileSinkConf.getClass.getDeclaredField("tableInfo")
tableInfoField.setAccessible(true)
val tableInfo = tableInfoField.get(fileSinkConf)
val getOutputFileFormatClassNameMethod = tableInfo.getClass
.getDeclaredMethod("getOutputFileFormatClassName")
val outputFileFormatClassName = getOutputFileFormatClassNameMethod.invoke(tableInfo)
Expand Down

0 comments on commit 55b378d

Please sign in to comment.