This is an automated email from the ASF dual-hosted git repository.
blue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 0adf678b7 Spark: Add CommitMetadata class to pass additional snapshot
properties (#4956)
add 31dafee40 Flink: FLIP-27 source enumerator help classes (#4329)
No new revisions were added by this update.
Summary of changes:
.../iceberg/flink/source/FlinkSplitPlanner.java | 79 +++-
.../apache/iceberg/flink/source/ScanContext.java | 149 ++++---
.../flink/source/StreamingStartingStrategy.java | 58 +++
.../enumerator/ContinuousEnumerationResult.java | 58 +++
.../source/enumerator/ContinuousSplitPlanner.java | 16 +-
.../enumerator/ContinuousSplitPlannerImpl.java | 189 +++++++++
.../enumerator/IcebergEnumeratorPosition.java | 70 ++--
.../apache/iceberg/flink/HadoopTableResource.java | 93 +++++
.../apache/iceberg/flink/source/TestFlinkScan.java | 6 +-
.../enumerator/ManualContinuousSplitPlanner.java | 57 +++
.../enumerator/TestContinuousSplitPlannerImpl.java | 463 +++++++++++++++++++++
...estContinuousSplitPlannerImplStartStrategy.java | 187 +++++++++
12 files changed, 1315 insertions(+), 110 deletions(-)
create mode 100644
flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java
create mode 100644
flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java
copy core/src/main/java/org/apache/iceberg/avro/MetricsAwareDatumWriter.java
=>
flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java
(64%)
create mode 100644
flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java
copy dell/src/test/java/org/apache/iceberg/dell/mock/ecs/ObjectId.java =>
flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java
(50%)
create mode 100644
flink/v1.14/flink/src/test/java/org/apache/iceberg/flink/HadoopTableResource.java
create mode 100644
flink/v1.14/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/ManualContinuousSplitPlanner.java
create mode 100644
flink/v1.14/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImpl.java
create mode 100644
flink/v1.14/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImplStartStrategy.java
