You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by lz...@apache.org on 2020/10/13 06:26:12 UTC
[iceberg] branch master updated (0c50b20 -> b4ba650)
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git.
from 0c50b20 API: Validate bucket and truncate function parameters (#1569)
add b4ba650 Flink: move hadoop configuration to Loaders from Source/Sink API (#1565)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iceberg/flink/CatalogLoader.java | 27 +++--
.../org/apache/iceberg/flink/FlinkCatalog.java | 28 ++---
.../apache/iceberg/flink/FlinkCatalogFactory.java | 25 +++--
.../apache/iceberg/flink/FlinkTableFactory.java | 4 +-
.../org/apache/iceberg/flink/IcebergTableSink.java | 7 +-
.../apache/iceberg/flink/IcebergTableSource.java | 24 ++--
.../java/org/apache/iceberg/flink/TableLoader.java | 22 ++--
.../org/apache/iceberg/flink/sink/FlinkSink.java | 12 +-
.../iceberg/flink/sink/IcebergFilesCommitter.java | 8 +-
.../iceberg/flink/source/FlinkInputFormat.java | 8 +-
.../apache/iceberg/flink/source/FlinkSource.java | 15 +--
.../iceberg/flink/TestCatalogTableLoader.java | 121 +++++++++++++++++++++
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 4 -
.../flink/sink/TestIcebergFilesCommitter.java | 2 +-
14 files changed, 197 insertions(+), 110 deletions(-)
create mode 100644 flink/src/test/java/org/apache/iceberg/flink/TestCatalogTableLoader.java