Browse Source

HUE-8330 [cluster] Support sending a remote query call

     $.post("/notebook/api/execute/impala", {
        "notebook": ko.mapping.toJSON({"type":"impala", "name": "query", "isSaved": false, "sessions": [], "snippets": [{"id": "1234", "type":"impala","statement_raw": "SHOW DATABASES", "result": {'handle': {}}}]}),
        "snippet": ko.mapping.toJSON({"id": "1234", "type": "impala", "statement":"SHOW DATABASES", "result": {'handle': {}}, "properties": {}}),
        "cluster": ko.mapping.toJSON("crn:altus:analyticdb:us-west-1:9d74eee4-1cad-45d7-b645-7ccf9edbb73d:cluster:arcus-ganeshk/1dbcb210-f113-4a59-aa68-61848092c074")
      }, function(data) {
        console.log(ko.mapping.toJSON(data));
      });
Romain Rigaux 7 years ago
parent
commit
2504a16318

+ 2 - 0
apps/beeswax/src/beeswax/server/dbms.py

@@ -78,6 +78,8 @@ def get(user, query_server=None, cluster=None):
 def get_query_server_config(name='beeswax', server=None, cluster=None):
 def get_query_server_config(name='beeswax', server=None, cluster=None):
   if cluster:
   if cluster:
     cluster_config = Cluster(user=None).get_config(cluster)
     cluster_config = Cluster(user=None).get_config(cluster)
+  else:
+    cluster_config = None
 
 
   if name == 'impala':
   if name == 'impala':
     from impala.dbms import get_query_server_config as impala_query_server_config
     from impala.dbms import get_query_server_config as impala_query_server_config

+ 1 - 1
desktop/libs/metadata/src/metadata/conf.py

@@ -165,7 +165,7 @@ ALTUS = ConfigSection(
     HOSTNAME=Config(
     HOSTNAME=Config(
       key='hostname',
       key='hostname',
       help=_t('Hostname prefix to Altus API or compatible service.'),
       help=_t('Hostname prefix to Altus API or compatible service.'),
-      default='.us-west-1.altus.cloudera.com'),
+      default='sdxapi.us-west-1.altus.cloudera.com'),
     HOSTNAME_ANALYTICDB=Config(
     HOSTNAME_ANALYTICDB=Config(
       key='hostname_analyticdb',
       key='hostname_analyticdb',
       help=_t('Hostname prefix to Altus ADB API or compatible service.'),
       help=_t('Hostname prefix to Altus ADB API or compatible service.'),

+ 2 - 3
desktop/libs/notebook/src/notebook/connectors/altus.py

@@ -108,7 +108,7 @@ class DataEngApi():
     if order:
     if order:
       args['order'] = order
       args['order'] = order
 
 
-    return _exec('dataeng', 'listJobs')
+    return _exec('dataeng', 'listJobs', args)
 
 
   def describe_job(self, job_id):
   def describe_job(self, job_id):
     return _exec('dataeng', 'describeJob', {'jobId', job_id})
     return _exec('dataeng', 'describeJob', {'jobId', job_id})
@@ -135,7 +135,6 @@ class DataEngApi():
   def terminate_job(self, job_id):
   def terminate_job(self, job_id):
     return _exec('dataeng', 'terminateJob', {'jobId': job_id})
     return _exec('dataeng', 'terminateJob', {'jobId': job_id})
 
 
-
   def list_clusters(self, names=None, page_size=None, starting_token=None):
   def list_clusters(self, names=None, page_size=None, starting_token=None):
     args = {}
     args = {}
 
 
@@ -146,7 +145,7 @@ class DataEngApi():
     if starting_token:
     if starting_token:
       args['startingToken'] = starting_token
       args['startingToken'] = starting_token
 
 
-    return _exec('dataeng', 'listClusters')
+    return _exec('dataeng', 'listClusters', args)
 
 
   def create_cluster(self):
   def create_cluster(self):
     return _exec('dataeng', 'createCluster')
     return _exec('dataeng', 'createCluster')

File diff suppressed because it is too large
+ 2 - 12
desktop/libs/notebook/src/notebook/connectors/altus_adb.py


Some files were not shown because too many files changed in this diff