Skip to content

Commit 30723eb

Browse files
committed
Fix test
1 parent 2d30375 commit 30723eb

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/function/BuiltInFunctions.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,4 @@ public class BuiltInFunctions {
3232
put("path_to_descriptor", new PathToDescriptorUnbound());
3333
}
3434
};
35-
3635
}

paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/function/PathToDescriptorFunction.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
package org.apache.paimon.spark.function;
2020

2121
import org.apache.paimon.data.BlobDescriptor;
22+
2223
import org.apache.spark.sql.connector.catalog.functions.ScalarFunction;
2324
import org.apache.spark.sql.types.DataType;
2425
import org.apache.spark.sql.types.DataTypes;
@@ -31,7 +32,7 @@ public class PathToDescriptorFunction implements ScalarFunction<byte[]>, Seriali
3132

3233
@Override
3334
public DataType[] inputTypes() {
34-
return new DataType[] { DataTypes.StringType };
35+
return new DataType[] {DataTypes.StringType};
3536
}
3637

3738
@Override

paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/function/PathToDescriptorUnbound.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -30,15 +30,14 @@ public class PathToDescriptorUnbound implements UnboundFunction {
3030
public BoundFunction bind(StructType inputType) {
3131
if (inputType.fields().length != 1) {
3232
throw new UnsupportedOperationException(
33-
"Function 'byte_to_string' requires 1 argument, but found " + inputType.fields().length
34-
);
33+
"Function 'byte_to_string' requires 1 argument, but found "
34+
+ inputType.fields().length);
3535
}
3636

3737
if (!(inputType.fields()[0].dataType() instanceof StringType)) {
3838
throw new UnsupportedOperationException(
39-
"The first argument of 'byte_to_string' must be BINARY type, but found " +
40-
inputType.fields()[0].dataType().simpleString()
41-
);
39+
"The first argument of 'byte_to_string' must be BINARY type, but found "
40+
+ inputType.fields()[0].dataType().simpleString());
4241
}
4342

4443
return new PathToDescriptorFunction();

0 commit comments

Comments
 (0)