Adding get_databases to HiveMetastoreHook
This commit is contained in:
Родитель
1ef4446a1c
Коммит
a1800221e3
|
@ -212,6 +212,15 @@ class HiveMetastoreHook(BaseHook):
|
||||||
self.metastore._oprot.trans.close()
|
self.metastore._oprot.trans.close()
|
||||||
return objs
|
return objs
|
||||||
|
|
||||||
|
def get_databases(self, pattern='*'):
|
||||||
|
'''
|
||||||
|
Get a metastore table object
|
||||||
|
'''
|
||||||
|
self.metastore._oprot.trans.open()
|
||||||
|
dbs = self.metastore.get_databases(pattern)
|
||||||
|
self.metastore._oprot.trans.close()
|
||||||
|
return dbs
|
||||||
|
|
||||||
def get_partitions(
|
def get_partitions(
|
||||||
self, schema, table_name, filter=None):
|
self, schema, table_name, filter=None):
|
||||||
'''
|
'''
|
||||||
|
|
Загрузка…
Ссылка в новой задаче