[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396799211 ## File path: versions.lock ## @@ -1,90 +1,119 @@ # Run ./gradlew --write-locks to regenerate this file

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396799055 ## File path: versions.lock ## @@ -1,90 +1,119 @@ # Run ./gradlew --write-locks to regenerate this file

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396798797 ## File path: versions.props ## @@ -12,6 +12,9 @@ org.apache.commons:commons-lang3 = 3.9 com.fasterxml.jackson.*:* =

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396796965 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/sink/IcebergSinkAppender.java ## @@ -0,0 +1,100

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396796302 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/sink/FileWriter.java ## @@ -0,0 +1,241 @@ +/* +

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396795518 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/sink/AvroSerializer.java ## @@ -0,0 +1,32 @@

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396795752 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/sink/AvroUtils.java ## @@ -0,0 +1,68 @@ +/* + *

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396794083 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/model/CommitMetadataUtil.java ## @@ -0,0 +1,59

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396793205 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/IcebergConnectorConstant.java ## @@ -0,0 +1,62

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396793400 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/IcebergConnectorConstant.java ## @@ -0,0 +1,62

[GitHub] [incubator-iceberg] rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink

2020-03-23 Thread GitBox
rdblue commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396793205 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/IcebergConnectorConstant.java ## @@ -0,0 +1,62