-
Notifications
You must be signed in to change notification settings - Fork 57
feat: manifest writer and adapter impl part2 #216
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
base: main
Are you sure you want to change the base?
Conversation
f79e978
to
478a6ea
Compare
ICEBERG_ASSIGN_OR_RAISE(auto source_field, | ||
schema_->FindFieldById(partition_field.source_id())); | ||
if (!source_field.has_value()) { | ||
return InvalidSchema("Cannot find source field for partition field:{}", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Add a TODO comment to use unknown type when source field is missing.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is not resolved yet.
bafed12
to
977466d
Compare
const std::shared_ptr<Schema>& schema() const { return manifest_schema_; } | ||
|
||
protected: | ||
virtual Result<std::shared_ptr<StructType>> GetManifestEntryStructType(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think StructType
is redundant.
ICEBERG_ASSIGN_OR_RAISE(auto source_field, | ||
schema_->FindFieldById(partition_field.source_id())); | ||
if (!source_field.has_value()) { | ||
return InvalidSchema("Cannot find source field for partition field:{}", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is not resolved yet.
src/iceberg/partition_spec.h
Outdated
std::vector<PartitionField> fields_; | ||
int32_t last_assigned_field_id_; | ||
std::mutex mutex_; | ||
std::shared_ptr<Schema> partition_schema_; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same as above.
1 parse v1v2v3 manifest schema in adapter 2 convert ManifestFile&ManifestEntry into ArrowArray 3 add e2e case
96be403
to
ec65a69
Compare
1 parse v1v2v3 manifest schema in adapter
2 convert ManifestFile&ManifestEntry into ArrowArray
3 add e2e case