diff --git a/src/main/java/blue/strategic/parquet/ParquetWriter.java b/src/main/java/blue/strategic/parquet/ParquetWriter.java index 7d75b05..5e69946 100644 --- a/src/main/java/blue/strategic/parquet/ParquetWriter.java +++ b/src/main/java/blue/strategic/parquet/ParquetWriter.java @@ -151,7 +151,8 @@ private void writeField(String name, Object value) { case BOOLEAN: recordConsumer.addBoolean((boolean)value); break; case FLOAT: recordConsumer.addFloat((float)value); break; case BINARY: - if (type.getLogicalTypeAnnotation() == LogicalTypeAnnotation.stringType()) { + if (type.getLogicalTypeAnnotation() == LogicalTypeAnnotation.stringType() + || type.getLogicalTypeAnnotation() == LogicalTypeAnnotation.jsonType() ) { recordConsumer.addBinary(Binary.fromString((String)value)); } else { throw new UnsupportedOperationException("We don't support writing " + type.getLogicalTypeAnnotation());