Эх сурвалжийг харах

HUE-8948 [hive] Pick-up if transactional table support from hive-site.xml

Romain 6 жил өмнө
parent
commit
e999cb92f7

+ 11 - 4
apps/beeswax/src/beeswax/hive_site.py

@@ -55,11 +55,12 @@ _CNF_HIVESERVER2_TRUSTSTORE_PASSWORD = 'hive.server2.truststore.password'
 _CNF_HIVESERVER2_TRANSPORT_MODE = 'hive.server2.transport.mode'
 _CNF_HIVESERVER2_TRANSPORT_MODE = 'hive.server2.transport.mode'
 _CNF_HIVESERVER2_THRIFT_HTTP_PORT = 'hive.server2.thrift.http.port'
 _CNF_HIVESERVER2_THRIFT_HTTP_PORT = 'hive.server2.thrift.http.port'
 _CNF_HIVESERVER2_THRIFT_HTTP_PATH = 'hive.server2.thrift.http.path'
 _CNF_HIVESERVER2_THRIFT_HTTP_PATH = 'hive.server2.thrift.http.path'
-
 _CNF_HIVESERVER2_THRIFT_SASL_QOP = 'hive.server2.thrift.sasl.qop'
 _CNF_HIVESERVER2_THRIFT_SASL_QOP = 'hive.server2.thrift.sasl.qop'
 
 
 _CNF_HIVESERVER2_USE_SASL = 'hive.metastore.sasl.enabled'
 _CNF_HIVESERVER2_USE_SASL = 'hive.metastore.sasl.enabled'
 
 
+_CNF_HIVE_SUPPORT_CONCURRENCY = 'hive.support.concurrency'
+
 
 
 # Host is whatever up to the colon. Allow and ignore a trailing slash.
 # Host is whatever up to the colon. Allow and ignore a trailing slash.
 _THRIFT_URI_RE = re.compile("^thrift://([^:]+):(\d+)[/]?$")
 _THRIFT_URI_RE = re.compile("^thrift://([^:]+):(\d+)[/]?$")
@@ -175,6 +176,15 @@ def hiveserver2_thrift_http_path():
   return get_conf().get(_CNF_HIVESERVER2_THRIFT_HTTP_PATH, 'cliservice')
   return get_conf().get(_CNF_HIVESERVER2_THRIFT_HTTP_PATH, 'cliservice')
 
 
 
 
+def get_use_sasl():
+  return get_conf().get(_CNF_HIVESERVER2_USE_SASL)
+
+
+def has_concurrency_support():
+  '''For SQL transactions like INSERT, DELETE, UPDATE'''
+  return get_conf().get(_CNF_HIVE_SUPPORT_CONCURRENCY, 'FALSE').upper() == 'TRUE'
+
+
 def _parse_hive_site():
 def _parse_hive_site():
   """
   """
   Parse hive-site.xml and store in _HIVE_SITE_DICT
   Parse hive-site.xml and store in _HIVE_SITE_DICT
@@ -200,6 +210,3 @@ def get_hive_site_content():
     return ''
     return ''
   else:
   else:
     return file(hive_site_path, 'r').read()
     return file(hive_site_path, 'r').read()
-
-def get_use_sasl():
-  return get_conf().get(_CNF_HIVESERVER2_USE_SASL)