From 955778bf433404f2a83ae00f067c9a3d93aea726 Mon Sep 17 00:00:00 2001 From: loneylee Date: Tue, 11 Jun 2024 16:33:36 +0800 Subject: [PATCH] fix style --- ...tenClickHouseMergeTreeWriteOnS3Suite.scala | 67 +++++++++---------- 1 file changed, 32 insertions(+), 35 deletions(-) diff --git a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseMergeTreeWriteOnS3Suite.scala b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseMergeTreeWriteOnS3Suite.scala index cac88b28be67..c5dc3a23754e 100644 --- a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseMergeTreeWriteOnS3Suite.scala +++ b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseMergeTreeWriteOnS3Suite.scala @@ -663,42 +663,39 @@ class GlutenClickHouseMergeTreeWriteOnS3Suite test("test mergetree with primary keys pruning by driver") { val tableName = "lineitem_mergetree_pk_pruning_by_driver_s3" val dataPath = s"s3a://$BUCKET_NAME/$tableName" - spark.sql( - s""" - |DROP TABLE IF EXISTS $tableName; - |""".stripMargin) + spark.sql(s""" + |DROP TABLE IF EXISTS $tableName; + |""".stripMargin) - spark.sql( - s""" - |CREATE TABLE IF NOT EXISTS $tableName - |( - | l_orderkey bigint, - | l_partkey bigint, - | l_suppkey bigint, - | l_linenumber bigint, - | l_quantity double, - | l_extendedprice double, - | l_discount double, - | l_tax double, - | l_returnflag string, - | l_linestatus string, - | l_shipdate date, - | l_commitdate date, - | l_receiptdate date, - | l_shipinstruct string, - | l_shipmode string, - | l_comment string - |) - |USING clickhouse - |TBLPROPERTIES (storage_policy='__s3_main', orderByKey='l_shipdate') - |LOCATION '$dataPath' - |""".stripMargin) - - spark.sql( - s""" - | insert into table $tableName - | select * from lineitem - |""".stripMargin) + spark.sql(s""" + |CREATE TABLE IF NOT EXISTS $tableName + |( + | l_orderkey bigint, + | l_partkey bigint, + | l_suppkey bigint, + | l_linenumber bigint, + | l_quantity double, + | l_extendedprice double, + | l_discount double, + | l_tax double, + | l_returnflag string, + | l_linestatus string, + | l_shipdate date, + | l_commitdate date, + | l_receiptdate date, + | l_shipinstruct string, + | l_shipmode string, + | l_comment string + |) + |USING clickhouse + |TBLPROPERTIES (storage_policy='__s3_main', orderByKey='l_shipdate') + |LOCATION '$dataPath' + |""".stripMargin) + + spark.sql(s""" + | insert into table $tableName + | select * from lineitem + |""".stripMargin) FileUtils.forceDelete(new File(S3_METADATA_PATH))