if S3_Utils.decomp_s3_url(self.config.alter_query, segment="BUCKET"): self.spark.sql(S3_Utils.open_s3_text_file(self.config.alter_query)) else: self.spark.sql(self.config.alter_query) self.logger.info(f"Alter query is complete. SQL: {self.config.alter_query}")
时间: 2024-03-28 12:40:49 浏览: 102
planar_utils.py和testCases_cv2.py
这是一段代码,看起来像是一个方法或函数。在这段代码中,使用了S3_Utils这个工具类的decomp_s3_url方法来判断config.alter_query是否是S3的URL,并通过open_s3_text_file方法打开S3中的文本文件。如果不是S3的URL,直接执行config.alter_query中的SQL语句。最后使用logger来记录日志,输出执行的SQL语句。
阅读全文