This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from b9d7aff92b8 [fix](nereids)agg funs case insensitive (#50444)
add 6cff01ca806 [feat](iceberg) implement hdfs fileio for iceberg (#51778)
No new revisions were added by this update.
Summary of changes:
.../iceberg/IcebergHadoopExternalCatalog.java | 19 ++
.../doris/datasource/iceberg/IcebergUtils.java | 1 -
.../datasource/iceberg/fileio/DelegateFileIO.java | 243 +++++++++++++++++++++
.../iceberg/fileio/DelegateInputFile.java | 117 ++++++++++
.../iceberg/fileio/DelegateOutputFile.java | 197 +++++++++++++++++
.../fileio/DelegateSeekableInputStream.java | 164 ++++++++++++++
.../property/storage/HdfsProperties.java | 4 +
.../main/java/org/apache/doris/fs/FileSystem.java | 25 +++
.../java/org/apache/doris/fs/io/DorisInput.java | 54 +++++
.../org/apache/doris/fs/io/DorisInputFile.java | 75 +++++++
.../org/apache/doris/fs/io/DorisInputStream.java | 51 +++++
.../org/apache/doris/fs/io/DorisOutputFile.java | 59 +++++
.../io/ParsedPath.java} | 21 +-
.../org/apache/doris/fs/io/hdfs/HdfsInput.java | 107 +++++++++
.../org/apache/doris/fs/io/hdfs/HdfsInputFile.java | 155 +++++++++++++
.../apache/doris/fs/io/hdfs/HdfsInputStream.java | 180 +++++++++++++++
.../apache/doris/fs/io/hdfs/HdfsOutputFile.java | 95 ++++++++
.../apache/doris/fs/io/hdfs/HdfsOutputStream.java | 135 ++++++++++++
.../java/org/apache/doris/fs/obj/ObjStorage.java | 1 +
.../java/org/apache/doris/fs/obj/S3ObjStorage.java | 3 +-
.../apache/doris/fs/remote/dfs/DFSFileSystem.java | 82 ++++---
.../external/iceberg/IcebergHadoopCatalogTest.java | 2 +-
22 files changed, 1755 insertions(+), 35 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/fileio/DelegateFileIO.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/fileio/DelegateInputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/fileio/DelegateOutputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/fileio/DelegateSeekableInputStream.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/DorisInput.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/DorisInputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/DorisInputStream.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/DorisOutputFile.java
copy
fe/fe-core/src/main/java/org/apache/doris/{nereids/properties/SelectHintOrdered.java
=> fs/io/ParsedPath.java} (67%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsInput.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsInputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsInputStream.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsOutputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsOutputStream.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
