fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/FlussDataTypeToPaimonDataType.java [150:160]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public DataType visit(RowType rowType) {
        org.apache.paimon.types.RowType.Builder rowTypeBuilder =
                org.apache.paimon.types.RowType.builder();
        for (DataField field : rowType.getFields()) {
            rowTypeBuilder.field(
                    field.getName(),
                    field.getType().accept(this),
                    field.getDescription().orElse(null));
        }
        return withNullability(rowTypeBuilder.build(), rowType.isNullable());
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/FlussDataTypeToPaimonDataType.java [150:160]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public DataType visit(RowType rowType) {
        org.apache.paimon.types.RowType.Builder rowTypeBuilder =
                org.apache.paimon.types.RowType.builder();
        for (DataField field : rowType.getFields()) {
            rowTypeBuilder.field(
                    field.getName(),
                    field.getType().accept(this),
                    field.getDescription().orElse(null));
        }
        return withNullability(rowTypeBuilder.build(), rowType.isNullable());
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



