File tree Expand file tree Collapse file tree
auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/flink/arrow Expand file tree Collapse file tree Original file line number Diff line number Diff line change 5353/**
5454 * Utility class for converting Flink {@link LogicalType} instances to Arrow types, fields and schemas.
5555 */
56- public class FlinkArrowUtils {
56+ public final class FlinkArrowUtils {
5757
5858 /**
5959 * Root allocator for Arrow memory management.
@@ -82,6 +82,9 @@ public static BufferAllocator createChildAllocator(String name) {
8282 * @throws UnsupportedOperationException if the type is not supported
8383 */
8484 public static ArrowType toArrowType (LogicalType logicalType ) {
85+ if (logicalType == null ) {
86+ throw new IllegalArgumentException ("logicalType cannot be null" );
87+ }
8588 if (logicalType instanceof NullType ) {
8689 return ArrowType .Null .INSTANCE ;
8790 } else if (logicalType instanceof BooleanType ) {
You can’t perform that action at this time.
0 commit comments