@@ -33,8 +33,7 @@ import org.apache.spark.sql.catalyst.rules.Rule
3333import org .apache .spark .sql .catalyst .util .{sideBySide , ArrayBasedMapData , GenericArrayData , MetadataColumnHelper }
3434import org .apache .spark .sql .catalyst .util .ResolveDefaultColumns .getExistenceDefaultValues
3535import org .apache .spark .sql .comet .{CometBatchScanExec , CometScanExec }
36- import org .apache .spark .sql .execution .{FileSourceScanExec , SparkPlan , SubqueryAdaptiveBroadcastExec }
37- import org .apache .spark .sql .execution .InSubqueryExec
36+ import org .apache .spark .sql .execution .{FileSourceScanExec , InSubqueryExec , SparkPlan , SubqueryAdaptiveBroadcastExec }
3837import org .apache .spark .sql .execution .datasources .HadoopFsRelation
3938import org .apache .spark .sql .execution .datasources .v2 .BatchScanExec
4039import org .apache .spark .sql .execution .datasources .v2 .csv .CSVScan
@@ -51,8 +50,7 @@ import org.apache.comet.objectstore.NativeConfig
5150import org .apache .comet .parquet .{CometParquetScan , Native , SupportsComet }
5251import org .apache .comet .parquet .CometParquetUtils .{encryptionEnabled , isEncryptionConfigSupported }
5352import org .apache .comet .serde .operator .CometNativeScan
54- import org .apache .comet .shims .{CometTypeShim , ShimFileFormat }
55- import org .apache .comet .shims .ShimSubqueryBroadcast
53+ import org .apache .comet .shims .{CometTypeShim , ShimFileFormat , ShimSubqueryBroadcast }
5654
5755/**
5856 * Spark physical optimizer rule for replacing Spark scans with Comet scans.
0 commit comments