Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[charry-pick](branch3.0) support text hive #41656

Merged
merged 4 commits into from
Oct 10, 2024

Conversation

suxiaogang223
Copy link
Contributor

@suxiaogang223 suxiaogang223 commented Oct 10, 2024

Proposed changes

pick from master:
#40315
#40291
#40183
#38549

@doris-robot
Copy link

Thank you for your contribution to Apache Doris.
Don't know what should be done next? See How to process your PR

Since 2024-03-18, the Document has been moved to doris-website.
See Doris Document.

1. Support write hive text table
2. Add SessionVariable `hive_text_compression` to write compressed hive
text table
3. Supported compression type: gzip, bzip2, snappy, lz4, zstd
followup apache#38549
If the large_block_len is 0, should not continue reading the block_len.
…#40291)

## Proposed changes
related pr: apache#39700
support escape.delim and serialization.null.format for hive text
Impl ZstdDecompressor and support read hive text table which is
compressed by zstd.
@suxiaogang223
Copy link
Contributor Author

run buildall

Copy link
Contributor

@github-actions github-actions bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

clang-tidy made some suggestions

ZstdDecompressor() : Decompressor(CompressType::ZSTD) {}
Status init() override;

private:
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

warning: redundant access specifier has the same accessibility as the previous access specifier [readability-redundant-access-specifiers]

Suggested change
private:
Additional context

be/src/exec/decompressor.h:149: previously declared here

private:
^

@@ -17,6 +17,7 @@

#pragma once

#include <gen_cpp/PlanNodes_types.h>
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

warning: 'gen_cpp/PlanNodes_types.h' file not found [clang-diagnostic-error]

#include <gen_cpp/PlanNodes_types.h>
         ^

@@ -174,6 +174,23 @@ void PlainCsvTextFieldSplitter::do_split(const Slice& line, std::vector<Slice>*
}
}

void HiveCsvTextFieldSplitter::do_split(const Slice& line, std::vector<Slice>* splitted_values) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

warning: method 'do_split' can be made const [readability-make-member-function-const]

be/src/vec/exec/format/csv/csv_reader.cpp:177:

- values) {
+ values) const {

@morningman morningman merged commit eb419c2 into apache:branch-3.0 Oct 10, 2024
10 of 16 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants