in google-datacatalog-hive-connector/src/google/datacatalog_connectors/hive/scrape/metadata_sync_event_scraper.py [0:0]
def __build_common_metadata_fields(cls, table_message):
database = entities.Database()
database.id = None
database.name = table_message['dbName']
table = entities.Table()
table.id = None
table.name = table_message['tableName']
table.type = 'table'
table.create_time = table_message['createTime']
table.database_id = None
table.sd_id = None
storage_message = table_message['sd']
table_storage = entities.TableStorage()
table_storage.sd_id = None
table_storage.location = storage_message['location']
table_storage.cd_id = None
cols_message = storage_message['cols']
columns = []
for col_message in cols_message:
column = entities.Column()
column.id = None
column.name = col_message['name']
column.type = col_message['type']
column.comment = col_message['comment']
columns.append(column)
table_storage.columns = columns
table_storages = [table_storage]
table.table_storages = table_storages
return database, table