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/11 06:43:17 UTC

[iceberg] branch master updated (8e26d56 -> 312c622)

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 8e26d56  Core: Add prorperty to enable/disable vectorized ORC reads (#2315)
     add 312c622  Flink :  Refactor FlinkTableFactory to implement DynamicTableSinkFactory and DynamicTableSourceFactory (#2229)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/iceberg/flink/FlinkCatalog.java     |   6 +-
 ...eFactory.java => FlinkDynamicTableFactory.java} |  38 +++---
 .../org/apache/iceberg/flink/IcebergTableSink.java |  59 +++++----
 .../apache/iceberg/flink/IcebergTableSource.java   | 141 +++++++++++----------
 .../apache/iceberg/flink/TestFlinkTableSource.java | 133 +++++--------------
 .../flink/actions/TestRewriteDataFilesAction.java  |  11 ++
 .../apache/iceberg/flink/FlinkTableFactory.html    |   2 +-
 .../apache/iceberg/flink/FlinkTableFactory.html    |   2 +-
 8 files changed, 175 insertions(+), 217 deletions(-)
 rename flink/src/main/java/org/apache/iceberg/flink/{FlinkTableFactory.java => FlinkDynamicTableFactory.java} (65%)