Skip to content

Commit 12b4061

Browse files
committed
Add Variant in OriginalType
1 parent e7c97e6 commit 12b4061

2 files changed

Lines changed: 5 additions & 3 deletions

File tree

parquet-column/src/main/java/org/apache/parquet/schema/LogicalTypeAnnotation.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -260,6 +260,8 @@ public static LogicalTypeAnnotation fromOriginalType(OriginalType originalType,
260260
return bsonType();
261261
case MAP_KEY_VALUE:
262262
return MapKeyValueTypeAnnotation.getInstance();
263+
case VARIANT:
264+
return variantType();
263265
default:
264266
throw new RuntimeException(
265267
"Can't convert original type to logical type, unknown original type " + originalType);
@@ -1148,8 +1150,7 @@ private VariantLogicalTypeAnnotation() {}
11481150

11491151
@Override
11501152
public OriginalType toOriginalType() {
1151-
// No OriginalType for Variant
1152-
return null;
1153+
return OriginalType.VARIANT;
11531154
}
11541155

11551156
@Override

parquet-column/src/main/java/org/apache/parquet/schema/OriginalType.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,5 +44,6 @@ public enum OriginalType {
4444
INT_64,
4545
JSON,
4646
BSON,
47-
INTERVAL
47+
INTERVAL,
48+
VARIANT
4849
}

0 commit comments

Comments
 (0)