[iceberg] branch master updated: Flink: add fixed field type for DataGenerators test util (#6426)

[stevenwu]

This is an automated email from the ASF dual-hosted git repository.

stevenwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new 145417135d Flink: add fixed field type for DataGenerators test util 
(#6426)
145417135d is described below

commit 145417135d75eb8cf627b585ea3231380610fd9f
Author: Steven Zhen Wu <stevenz...@gmail.com>
AuthorDate: Fri Jan 6 09:27:23 2023 -0800

    Flink: add fixed field type for DataGenerators test util (#6426)
---
 .../src/test/java/org/apache/iceberg/flink/DataGenerators.java   | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/DataGenerators.java 
b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/DataGenerators.java
index 0443d4261e..b2b608869f 100644
--- 
a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/DataGenerators.java
+++ 
b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/DataGenerators.java
@@ -22,6 +22,7 @@ import static 
org.apache.iceberg.types.Types.NestedField.required;
 
 import java.math.BigDecimal;
 import java.nio.ByteBuffer;
+import java.nio.charset.StandardCharsets;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
@@ -67,6 +68,7 @@ public class DataGenerators {
     private static final LocalDateTime JAVA_LOCAL_DATE_TIME_20220110 =
         LocalDateTime.of(2022, 1, 10, 0, 0, 0);
     private static final BigDecimal BIG_DECIMAL_NEGATIVE = new 
BigDecimal("-1.50");
+    private static final byte[] FIXED_BYTES = 
"012345689012345".getBytes(StandardCharsets.UTF_8);
 
     private final Schema icebergSchema =
         new Schema(
@@ -85,7 +87,8 @@ public class DataGenerators {
                 11, "ts_without_zone_field", 
Types.TimestampType.withoutZone()),
             Types.NestedField.required(12, "uuid_field", Types.UUIDType.get()),
             Types.NestedField.required(13, "binary_field", 
Types.BinaryType.get()),
-            Types.NestedField.required(14, "decimal_field", 
Types.DecimalType.of(9, 2)));
+            Types.NestedField.required(14, "decimal_field", 
Types.DecimalType.of(9, 2)),
+            Types.NestedField.required(15, "fixed_field", 
Types.FixedType.ofLength(16)));
 
     private final RowType flinkRowType = 
FlinkSchemaUtil.convert(icebergSchema);
 
@@ -128,6 +131,7 @@ public class DataGenerators {
       genericRecord.setField("binary_field", ByteBuffer.wrap(binaryBytes));
 
       genericRecord.setField("decimal_field", BIG_DECIMAL_NEGATIVE);
+      genericRecord.setField("fixed_field", FIXED_BYTES);
 
       return genericRecord;
     }
@@ -160,7 +164,8 @@ public class DataGenerators {
           TimestampData.fromEpochMillis(JODA_DATETIME_20220110.getMillis()),
           uuidBytes,
           binaryBytes,
-          DecimalData.fromBigDecimal(BIG_DECIMAL_NEGATIVE, 9, 2));
+          DecimalData.fromBigDecimal(BIG_DECIMAL_NEGATIVE, 9, 2),
+          FIXED_BYTES);
     }
   }