File tree Expand file tree Collapse file tree 1 file changed +11
-12
lines changed
spark/src/main/scala/org/apache/comet/serde Expand file tree Collapse file tree 1 file changed +11
-12
lines changed Original file line number Diff line number Diff line change @@ -743,18 +743,17 @@ object QueryPlanSerde extends Logging with CometExprShim {
743743 binding,
744744 (builder, binaryExpr) => builder.setLtEq(binaryExpr))
745745
746- case Literal (value, dataType) if supportedDataType(
747- dataType,
748- allowComplex = value == null ||
749- // Nested literal support for native reader
750-
751-
752- // can be tracked https://github.com/apache/datafusion-comet/issues/1937
753- // now supports only Array of primitive
754- (Seq (CometConf .SCAN_NATIVE_ICEBERG_COMPAT , CometConf .SCAN_NATIVE_DATAFUSION )
755- .contains(CometConf .COMET_NATIVE_SCAN_IMPL .get()) && dataType
756- .isInstanceOf [ArrayType ]) && ! isComplexType(
757- dataType.asInstanceOf [ArrayType ].elementType)) =>
746+ case Literal (value, dataType)
747+ if supportedDataType(
748+ dataType,
749+ allowComplex = value == null ||
750+ // Nested literal support for native reader
751+ // can be tracked https://github.com/apache/datafusion-comet/issues/1937
752+ // now supports only Array of primitive
753+ (Seq (CometConf .SCAN_NATIVE_ICEBERG_COMPAT , CometConf .SCAN_NATIVE_DATAFUSION )
754+ .contains(CometConf .COMET_NATIVE_SCAN_IMPL .get()) && dataType
755+ .isInstanceOf [ArrayType ]) && ! isComplexType(
756+ dataType.asInstanceOf [ArrayType ].elementType)) =>
758757 val exprBuilder = ExprOuterClass .Literal .newBuilder()
759758
760759 if (value == null ) {
You can’t perform that action at this time.
0 commit comments