到目前为止,我的第一个lambda函数删除了包含以下SQL查询的表: DROP TABLE IF EXISTS [dummytable] 然后我有了第二个lambda,它删除了表所在的文件夹,以防止"failure_reason":"HIVE_PATH_ALREADY_EXISTS: 因此,第二个lambda删除了路径: s3://mytablesbucket/dummytable 有没有办法用一个lambda就能做到这一点呢
我试图在Glue目录中创建一个包含s3路径位置的表,这个位置是在EMR中使用hive运行的火花路径。pyspark.sql.utils.AnalysisException: u'java.lang.IllegalArgumentException:无法从空字符串创建路径;‘
sparksession.sql("CREATE TABLEIF NOT EXISTS abc LOCATION 's3://my-bucket/test/' as (SELECT * f
我正在尝试创建动态SQL,以便它在start_date到end_date之间循环,以便根据日期从不同的s3文件夹复制到其中。stmt = snowflake.createStatement(
{sqlText: "copy into table from s3://test/2020-01-01/"}我想执行3次copy into命令; copy into table from s3://test/2