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
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
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.*:* =
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
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 @@
+/*
+
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 @@
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 @@
+/*
+ *
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
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
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
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
11 matches
Mail list logo