diff --git a/velox/connectors/hive/HiveConnectorUtil.cpp b/velox/connectors/hive/HiveConnectorUtil.cpp index 236120e1763f..ac7289c5b261 100644 --- a/velox/connectors/hive/HiveConnectorUtil.cpp +++ b/velox/connectors/hive/HiveConnectorUtil.cpp @@ -993,12 +993,20 @@ void updateWriterOptionsFromHiveConfig( const std::shared_ptr& hiveConfig, const config::ConfigBase* sessionProperties, std::shared_ptr& writerOptions) { - if (fileFormat == dwio::common::FileFormat::PARQUET) { + switch (fileFormat) { + case dwio::common::FileFormat::DWRF: + updateDWRFWriterOptions(hiveConfig, sessionProperties, writerOptions); + break; + case dwio::common::FileFormat::PARQUET: #ifdef VELOX_ENABLE_PARQUET - updateParquetWriterOptions(hiveConfig, sessionProperties, writerOptions); + updateParquetWriterOptions(hiveConfig, sessionProperties, writerOptions); #endif - } else { - updateDWRFWriterOptions(hiveConfig, sessionProperties, writerOptions); + break; + case dwio::common::FileFormat::NIMBLE: + // No-op for now. + break; + default: + VELOX_UNSUPPORTED("{}", fileFormat); } }