Support JSON reader

be/src/exec/scan/file_scanner_v2.cpp

@@ -120,6 +120,10 @@ bool is_text_format(TFileFormatType::type format_type) {
     return format_type == TFileFormatType::FORMAT_TEXT;
 }
 
+bool is_json_format(TFileFormatType::type format_type) {
+    return format_type == TFileFormatType::FORMAT_JSON;
+}
+
 bool is_partition_slot(const TFileScanSlotInfo& slot_info, const std::string& column_name) {
     if (column_name.starts_with(BeConsts::GLOBAL_ROWID_COL) ||
         column_name == BeConsts::ICEBERG_ROWID_COL) {
@@ -213,7 +217,8 @@ bool FileScannerV2::is_supported(const TFileScanRangeParams& params, const TFile
         return is_supported_table_format(range);
     } else if (format_type == TFileFormatType::FORMAT_JNI) {
         return is_supported_jni_table_format(range);
-    } else if (is_csv_format(format_type) || is_text_format(format_type)) {
+    } else if (is_csv_format(format_type) || is_text_format(format_type) ||
+               is_json_format(format_type)) {
         return is_supported_table_format(range);
     } else {
         LOG(WARNING) << "Unsupported file format type " << format_type << " for file scanner v2";
@@ -597,6 +602,9 @@ Status FileScannerV2::_to_file_format(TFileFormatType::type format_type,
     case TFileFormatType::FORMAT_TEXT:
         *file_format = format::FileFormat::TEXT;
         return Status::OK();
+    case TFileFormatType::FORMAT_JSON:
+        *file_format = format::FileFormat::JSON;
+        return Status::OK();
     default:
         return Status::NotSupported("FileScannerV2 does not support file format {}",
                                     to_string(format_type));

be/src/format_v2/file_reader.h

@@ -114,6 +114,7 @@ enum class FileFormat {
     PARQUET,
     ORC,
     CSV,
+    JSON,
     TEXT,
     JNI,
 };