File tree Expand file tree Collapse file tree 1 file changed +14
-0
lines changed
Expand file tree Collapse file tree 1 file changed +14
-0
lines changed Original file line number Diff line number Diff line change @@ -608,6 +608,11 @@ def test_and_detect(self, infer_storage_types=False):
608608 elif settings .type in self .__class__ ._SQL_TYPES :
609609 return self .client ._perform_json ("POST" ,
610610 "/projects/%s/datasets/%s/actions/testAndDetectSettings/externalSQL" % (self .project_key , self .dataset_name ))
611+
612+ elif settings .type == "ElasticSearch" :
613+ return self .client ._perform_json ("POST" ,
614+ "/projects/%s/datasets/%s/actions/testAndDetectSettings/elasticsearch" % (self .project_key , self .dataset_name ))
615+
611616 else :
612617 raise ValueError ("don't know how to test/detect on dataset type:%s" % settings .type )
613618
@@ -642,6 +647,15 @@ def autodetect_settings(self, infer_storage_types=False):
642647
643648 settings .get_raw ()["schema" ] = result ["schemaDetection" ]["newSchema" ]
644649 return settings
650+
651+ elif settings .type == "ElasticSearch" :
652+ result = self .test_and_detect ()
653+
654+ if not "schemaDetection" in result :
655+ raise DataikuException ("Format detection failed, complete response is " + json .dumps (result ))
656+
657+ settings .get_raw ()["schema" ] = result ["schemaDetection" ]["newSchema" ]
658+ return settings
645659
646660 else :
647661 raise ValueError ("don't know how to test/detect on dataset type:%s" % settings .type )
You can’t perform that action at this time.
0 commit comments