You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
data-transport/transport/warehouse/iceberg.py

130 lines
4.6 KiB
Python

"""
dependency:
- spark and SPARK_HOME environment variable must be set
self._catalog.setCurrentCatalog(_args['catalog'])
return False
return _args['table'] in [_item.name for _item in self._catalog.listTables(_prefix)]
except Exception as e:
print (e)
return False