Kaynağa Gözat

HUE-4530 [indexer] Allow to select parquet tables

Romain Rigaux 9 yıl önce
ebeveyn
işleme
42af931c68
1 değiştirilmiş dosya ile 2 ekleme ve 0 silme
  1. 2 0
      desktop/libs/indexer/src/indexer/api3.py

+ 2 - 0
desktop/libs/indexer/src/indexer/api3.py

@@ -74,6 +74,8 @@ def guess_format(request):
     storage = dict([(delim['data_type'], delim['comment']) for delim in table_metadata.storage_details])
     storage = dict([(delim['data_type'], delim['comment']) for delim in table_metadata.storage_details])
     if table_metadata.details['properties']['format'] == 'text':
     if table_metadata.details['properties']['format'] == 'text':
       format_ = {"quoteChar": "\"", "recordSeparator": '\\n', "type": "csv", "hasHeader": False, "fieldSeparator": storage['serialization.format']}
       format_ = {"quoteChar": "\"", "recordSeparator": '\\n', "type": "csv", "hasHeader": False, "fieldSeparator": storage['serialization.format']}
+    elif table_metadata.details['properties']['format'] == 'parquet':
+      format_ = {"type": "parquet", "hasHeader": False,}
     else:
     else:
       raise PopupException('Hive table format %s is not supported.' % table_metadata.details['properties']['format'])
       raise PopupException('Hive table format %s is not supported.' % table_metadata.details['properties']['format'])
   elif file_format['inputFormat'] == 'query':
   elif file_format['inputFormat'] == 'query':