This is an automated email from the ASF dual-hosted git repository.
ethanfeng pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git
from 8948df17f [CELEBORN-1733] Support ordered grouped kv input for Tez
add cfd20fa0d [CELEBORN-1732] Support unordered kv input for Tez
No new revisions were added by this update.
Summary of changes:
.../CelebornFetcher.java} | 169 +++----
.../shuffle/impl/CelebornShuffleManager.java | 496 +++++++++++++++++++++
.../library/input/CelebornUnorderedKVInput.java | 317 +++++++++++++
3 files changed, 875 insertions(+), 107 deletions(-)
copy
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/{orderedgrouped/CelebornTezShuffleDataFetcher.java
=> impl/CelebornFetcher.java} (56%)
create mode 100644
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/CelebornShuffleManager.java
create mode 100644
client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornUnorderedKVInput.java
