Refactoring

Author: Amar3tto

it/google-cloud-platform/src/main/resources/test-artifact.json

@@ -281,6 +281,7 @@ private static void setTempLocation(TestPipeline pipeline) {
   private static class MapToIcebergFormat extends DoFn<Long, Row> {
 
     private final int valueSizeBytes;
+    private transient Random random;
 
     private MapToIcebergFormat(int valueSizeBytes) {
       if (valueSizeBytes <= 0) {
@@ -290,6 +291,11 @@ private MapToIcebergFormat(int valueSizeBytes) {
       this.valueSizeBytes = valueSizeBytes;
     }
 
+    @Setup
+    public void setup() {
+      random = new Random();
+    }
+
     @ProcessElement
     public void processElement(@Element Long index, OutputReceiver<Row> output) {
 
@@ -299,7 +305,8 @@ public void processElement(@Element Long index, OutputReceiver<Row> output) {
        * Using the row index as the seed makes retries deterministic. Random data also prevents
        * compression from making the generated payload significantly smaller than configured.
        */
-      new Random(index).nextBytes(value);
+      random.setSeed(index);
+      random.nextBytes(value);
 
       output.output(Row.withSchema(ROW_SCHEMA).addValues(index, value).build());
     }