[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676614549 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGen.java ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache Software

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676612350 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteFunction.java ## @@ -0,0 +1,225 @@ +/* + * Licensed to the Apache

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676560948 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGen.java ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache Software

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676559586 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteFunction.java ## @@ -0,0 +1,225 @@ +/* + * Licensed to the Apache

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676385780 ## File path: hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataParquetWriteSupport.java ## @@ -0,0 +1,86 @@ +/* +

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676388084 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGen.java ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache Software

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676386465 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteFunction.java ## @@ -0,0 +1,225 @@ +/* + * Licensed to the Apache

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676385780 ## File path: hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataParquetWriteSupport.java ## @@ -0,0 +1,86 @@ +/* +

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676385494 ## File path: hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataParquetWriteSupport.java ## @@ -0,0 +1,86 @@ +/* +

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676383783 ## File path: hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataCreateHandle.java ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676382204 ## File path: hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/HoodieRowData.java ## @@ -0,0 +1,184 @@ +/* + * Licensed to the

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r676381427 ## File path: hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/HoodieRowData.java ## @@ -0,0 +1,184 @@ +/* + * Licensed to the

[GitHub] [hudi] danny0405 commented on a change in pull request #3334: [HUDI-2209] Bulk insert for flink writer

danny0405 commented on a change in pull request #3334: URL: https://github.com/apache/hudi/pull/3334#discussion_r675907954 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriterHelper.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to the Apache Software