You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@iceberg.apache.org by op...@apache.org on 2021/03/05 03:21:21 UTC

[iceberg] branch master updated (4c5c22a -> 343104c)

This is an automated email from the ASF dual-hosted git repository.

openinx pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git.


    from 4c5c22a  API: Refactor Actions API (#2255)
     add 343104c  Flink: Refactor flink source tests for FLIP-27 unified source. (#2047)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/iceberg/flink/data/RowDataUtil.java |  31 ++++
 .../org/apache/iceberg/flink/TestFixtures.java}    |  45 +++---
 .../java/org/apache/iceberg/flink/TestHelpers.java |  41 ++---
 .../iceberg/flink/source/TestFlinkInputFormat.java |  23 ++-
 .../source/TestFlinkInputFormatReaderDeletes.java  |  72 +--------
 ...eletes.java => TestFlinkReaderDeletesBase.java} |  64 +++-----
 .../apache/iceberg/flink/source/TestFlinkScan.java | 166 +++++++--------------
 .../iceberg/flink/source/TestFlinkScanSql.java     |  18 ++-
 .../iceberg/flink/source/TestFlinkSource.java      |  78 ++++++++++
 .../flink/source/TestStreamingMonitorFunction.java |   9 +-
 .../flink/source/TestStreamingReaderOperator.java  |  13 +-
 11 files changed, 269 insertions(+), 291 deletions(-)
 copy flink/src/{main/java/org/apache/iceberg/flink/FlinkFixupTypes.java => test/java/org/apache/iceberg/flink/TestFixtures.java} (51%)
 copy flink/src/test/java/org/apache/iceberg/flink/source/{TestFlinkInputFormatReaderDeletes.java => TestFlinkReaderDeletesBase.java} (52%)
 create mode 100644 flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java