|
@@ -77,7 +77,6 @@ class HiveDS(DataSourceBase):
|
|
|
sql1 = f'show columns in {self.database_name}.{table_name}'
|
|
|
res = self._execute_sql([sql1])
|
|
|
if res:
|
|
|
- logger.info(res[0])
|
|
|
columns = list(map(lambda x: x[0],res[0]))
|
|
|
logger.info(columns)
|
|
|
else:
|
|
@@ -90,7 +89,6 @@ class HiveDS(DataSourceBase):
|
|
|
if res:
|
|
|
print(res[0])
|
|
|
res = [[str(i) , *x]for i, x in enumerate(filter(lambda x: x[0] != '', res[0]))]
|
|
|
- logger.info(res[1:3])
|
|
|
ans.append(flat_map(lambda x: [':'.join(x[:3])], res))
|
|
|
|
|
|
else:
|