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

Posted to commits@iceberg.apache.org by st...@apache.org on 2023/05/15 15:43:55 UTC

[iceberg] branch master updated (1144241009 -> 203b8db4dc)

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

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


    from 1144241009 Docs: Improve readability on page Branching and Tagging (#7592)
     add 203b8db4dc Flink: change sink shuffle to use RowData as data type and statistics key type (#7494)

No new revisions were added by this update.

Summary of changes:
 .../iceberg/flink/sink/shuffle/DataStatistics.java |  18 +-
 .../flink/sink/shuffle/DataStatisticsEvent.java    |   8 +-
 .../flink/sink/shuffle/DataStatisticsFactory.java  |  33 ----
 .../flink/sink/shuffle/DataStatisticsOperator.java |  51 +++--
 .../flink/sink/shuffle/DataStatisticsOrRecord.java |  53 ++++-
 .../shuffle/DataStatisticsOrRecordSerializer.java  | 219 +++++++++++++++++++++
 .../flink/sink/shuffle/MapDataStatistics.java      |  27 +--
 .../sink/shuffle/MapDataStatisticsFactory.java     |  34 ----
 .../sink/shuffle/MapDataStatisticsSerializer.java  | 183 +++++++++++++++++
 .../sink/shuffle/TestDataStatisticsOperator.java   | 186 +++++++++--------
 10 files changed, 609 insertions(+), 203 deletions(-)
 delete mode 100644 flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsFactory.java
 create mode 100644 flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOrRecordSerializer.java
 delete mode 100644 flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatisticsFactory.java
 create mode 100644 flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatisticsSerializer.java