diff --git a/parquet-arrow/pom.xml b/parquet-arrow/pom.xml index 23be81594f..d9a9e8fb28 100644 --- a/parquet-arrow/pom.xml +++ b/parquet-arrow/pom.xml @@ -33,7 +33,7 @@ https://parquet.apache.org - 17.0.0 + 19.0.0 diff --git a/parquet-arrow/src/main/java/org/apache/parquet/arrow/schema/SchemaConverter.java b/parquet-arrow/src/main/java/org/apache/parquet/arrow/schema/SchemaConverter.java index 532fa7c53a..e779b6b8c2 100644 --- a/parquet-arrow/src/main/java/org/apache/parquet/arrow/schema/SchemaConverter.java +++ b/parquet-arrow/src/main/java/org/apache/parquet/arrow/schema/SchemaConverter.java @@ -179,6 +179,11 @@ public TypeMapping visit(ArrowType.ListView type) { return createListTypeMapping(); } + @Override + public TypeMapping visit(ArrowType.LargeListView type) { + return createListTypeMapping(); + } + private ListTypeMapping createListTypeMapping() { if (children.size() != 1) { throw new IllegalArgumentException("list fields must have exactly one child: " + field); @@ -349,6 +354,11 @@ public TypeMapping visit(ArrowType.Duration duration) { return primitiveFLBA(12, LogicalTypeAnnotation.IntervalLogicalTypeAnnotation.getInstance()); } + @Override + public TypeMapping visit(ArrowType.RunEndEncoded runEndEncoded) { + throw new UnsupportedOperationException("Unsupported type " + runEndEncoded); + } + @Override public TypeMapping visit(ArrowType.ExtensionType type) { return ArrowTypeVisitor.super.visit(type); @@ -769,6 +779,11 @@ public TypeMapping visit(ArrowType.ListView type) { return createListTypeMapping(type); } + @Override + public TypeMapping visit(ArrowType.LargeListView type) { + return createListTypeMapping(type); + } + private TypeMapping createListTypeMapping(ArrowType.ComplexType type) { if (arrowField.getChildren().size() != 1) { throw new IllegalArgumentException("Invalid list type: " + type); @@ -893,6 +908,11 @@ public TypeMapping visit(ArrowType.Duration duration) { return primitive(); } + @Override + public TypeMapping visit(ArrowType.RunEndEncoded runEndEncoded) { + throw new UnsupportedOperationException("Unsupported type " + runEndEncoded); + } + @Override public TypeMapping visit(ArrowType.FixedSizeBinary fixedSizeBinary) { return primitive();