in c3r-sdk-parquet/src/main/java/com/amazonaws/c3r/data/ParquetDataType.java [346:369]
public void validate() {
if (parquetType == null) {
return;
}
if (clientDataType == ClientDataType.UNKNOWN) {
return;
}
if (!isSupportedType(parquetType)) {
throw new C3rRuntimeException("Parquet type " + parquetType + " is not supported.");
} else if (parquetType.isPrimitive()) {
final PrimitiveTypeName name = parquetType.asPrimitiveType().getPrimitiveTypeName();
if (name == PrimitiveTypeName.INT32 || name == PrimitiveTypeName.INT64) {
final LogicalTypeAnnotation logicalTypeAnnotation = parquetType.getLogicalTypeAnnotation();
if (logicalTypeAnnotation == null) {
return;
}
if (logicalTypeAnnotation.equals(LogicalTypeAnnotation.intType(ClientDataType.SMALLINT_BIT_SIZE, false)) ||
logicalTypeAnnotation.equals(LogicalTypeAnnotation.intType(ClientDataType.INT_BIT_SIZE, false)) ||
logicalTypeAnnotation.equals(LogicalTypeAnnotation.intType(ClientDataType.BIGINT_BIT_SIZE, false))) {
throw new C3rRuntimeException("Unsigned integer values are not supported.");
}
}
}
}