hdfswriter/src/main/java/com/alibaba/datax/plugin/writer/hdfswriter/ParquetFileSupport.java [436:473]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void writeList(GroupType groupType, JSON value, int index) {
        if (value == null) {
            return;
        }

        JSONArray json = (JSONArray) value;

        if (json.isEmpty()) {
            return;
        }

        recordConsumer.startField(groupType.getName(), index);
        // list
        recordConsumer.startGroup();

        // list start
        recordConsumer.startField("list", 0);
        recordConsumer.startGroup();

        Type elementType = groupType.getFields().get(0).asGroupType().getFields().get(0);

        if (elementType.isPrimitive()) {
            for (Object elementValue : json) {
                writePrimitiveType(elementType, elementValue, 0);
            }
        } else {
            for (Object elementValue : json) {
                writeGroupType(elementType, (JSON) elementValue, 0);
            }
        }

        recordConsumer.endGroup();
        recordConsumer.endField("list", 0);
        // list end
        recordConsumer.endGroup();

        recordConsumer.endField(groupType.getName(), index);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/parquet/ParquetFileSupport.java [191:229]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void writeList(GroupType groupType, JSON value, int index) {
        if (value == null) {
            return;
        }

        JSONArray json = (JSONArray) value;

        if (json.isEmpty()) {
            return;
        }

        recordConsumer.startField(groupType.getName(), index);
        // list
        recordConsumer.startGroup();


        // list start
        recordConsumer.startField("list", 0);
        recordConsumer.startGroup();

        Type elementType = groupType.getFields().get(0).asGroupType().getFields().get(0);

        if (elementType.isPrimitive()) {
            for (Object elementValue : json) {
                writePrimitiveType(elementType, elementValue, 0);
            }
        } else {
            for (Object elementValue : json) {
                writeGroupType(elementType, (JSON) elementValue, 0);
            }
        }

        recordConsumer.endGroup();
        recordConsumer.endField("list", 0);
        // list end
        recordConsumer.endGroup();

        recordConsumer.endField(groupType.getName(), index);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -