Github user vvysotskyi commented on a diff in the pull request:

    https://github.com/apache/drill/pull/1232#discussion_r184008307
  
    --- Diff: 
exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java
 ---
    @@ -228,14 +232,33 @@ private void newSchema() throws IOException {
         setUp(schema, consumer);
       }
     
    -  private PrimitiveType getPrimitiveType(MaterializedField field) {
    +  protected PrimitiveType getPrimitiveType(MaterializedField field) {
         MinorType minorType = field.getType().getMinorType();
         String name = field.getName();
    +    int length = ParquetTypeHelper.getLengthForMinorType(minorType);
         PrimitiveTypeName primitiveTypeName = 
ParquetTypeHelper.getPrimitiveTypeNameForMinorType(minorType);
    +    if (DecimalUtility.isDecimalType(minorType)) {
    +      OptionManager optionManager = 
oContext.getFragmentContext().getOptions();
    +      if (optionManager.getString(PARQUET_WRITER_LOGICAL_TYPE_FOR_DECIMALS)
    --- End diff --
    
    Agree, thanks for pointing this, used `writerOptions`.


---

Reply via email to