Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/iceberg/avro/avro_direct_decoder_internal.h
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ struct DecodeContext {
/// \param projected_schema The target Iceberg schema after projection
/// \param array_builder The Arrow array builder to append decoded data to
/// \param ctx Decode context for reusing scratch buffers
/// \return Status::OK if successful, or an error status
/// \return Status indicating success, or an error status
Status DecodeAvroToBuilder(const ::avro::NodePtr& avro_node, ::avro::Decoder& decoder,
const SchemaProjection& projection,
const Schema& projected_schema,
Expand Down
2 changes: 1 addition & 1 deletion src/iceberg/avro/avro_direct_encoder_internal.h
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ struct EncodeContext {
/// \param array The Arrow array containing the data to encode
/// \param row_index The index of the row to encode within the array
/// \param ctx Encode context for reusing scratch buffers
/// \return Status::OK if successful, or an error status
/// \return Status indicating success, or an error status
Status EncodeArrowToAvro(const ::avro::NodePtr& avro_node, ::avro::Encoder& encoder,
const Type& type, const ::arrow::Array& array, int64_t row_index,
EncodeContext& ctx);
Expand Down
6 changes: 3 additions & 3 deletions src/iceberg/catalog.h
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ class ICEBERG_EXPORT Catalog {
///
/// \param ns the namespace to create
/// \param properties a key-value map of metadata for the namespace
/// \return Status::OK if created successfully;
/// \return Status indicating success if created successfully;
/// ErrorKind::kAlreadyExists if the namespace already exists;
/// ErrorKind::kNotSupported if the operation is not supported
virtual Status CreateNamespace(
Expand All @@ -72,7 +72,7 @@ class ICEBERG_EXPORT Catalog {
/// \brief Drop a namespace.
///
/// \param ns the namespace to drop
/// \return Status::OK if dropped successfully;
/// \return Status indicating success if dropped successfully;
/// ErrorKind::kNoSuchNamespace if the namespace does not exist;
/// ErrorKind::kNotAllowed if the namespace is not empty
virtual Status DropNamespace(const Namespace& ns) = 0;
Expand All @@ -88,7 +88,7 @@ class ICEBERG_EXPORT Catalog {
/// \param ns the namespace to update
/// \param updates a set of properties to add or overwrite
/// \param removals a set of property keys to remove
/// \return Status::OK if the update is successful;
/// \return Status indicating success if the update is successful;
/// ErrorKind::kNoSuchNamespace if the namespace does not exist;
/// ErrorKind::kUnsupported if the operation is not supported
virtual Status UpdateNamespaceProperties(
Expand Down
10 changes: 5 additions & 5 deletions src/iceberg/catalog/memory/in_memory_catalog.cc
Original file line number Diff line number Diff line change
Expand Up @@ -58,15 +58,15 @@ class ICEBERG_EXPORT InMemoryNamespace {
///
/// \param namespace_ident The namespace to create.
/// \param properties A map of key-value pairs to associate with the namespace.
/// \return Status::OK if the namespace is created;
/// \return Status indicating success if the namespace is created;
/// ErrorKind::kAlreadyExists if the namespace already exists.
Status CreateNamespace(const Namespace& namespace_ident,
const std::unordered_map<std::string, std::string>& properties);

/// \brief Deletes an existing namespace.
///
/// \param namespace_ident The namespace to delete.
/// \return Status::OK if the namespace is deleted;
/// \return Status indicating success if the namespace is deleted;
/// ErrorKind::kNoSuchNamespace if the namespace does not exist;
/// ErrorKind::kNotAllowed if the namespace is not empty.
Status DropNamespace(const Namespace& namespace_ident);
Expand All @@ -84,7 +84,7 @@ class ICEBERG_EXPORT InMemoryNamespace {
/// \param namespace_ident The namespace to update.
/// \param updates Properties to add or overwrite.
/// \param removals Property keys to remove.
/// \return Status::OK if the update is successful;
/// \return Status indicating success if the update is successful;
/// ErrorKind::kNoSuchNamespace if the namespace does not exist;
/// ErrorKind::kUnsupported if the operation is not supported.
Status UpdateNamespaceProperties(
Expand All @@ -102,15 +102,15 @@ class ICEBERG_EXPORT InMemoryNamespace {
///
/// \param table_ident The fully qualified identifier of the table.
/// \param metadata_location The path to the table's metadata.
/// \return Status::OK if the table is registered;
/// \return Status indicating success if the table is registered;
/// Error otherwise.
Status RegisterTable(const TableIdentifier& table_ident,
const std::string& metadata_location);

/// \brief Unregisters a table from the specified namespace.
///
/// \param table_ident The identifier of the table to unregister.
/// \return Status::OK if the table is removed;
/// \return Status indicating success if the table is removed;
/// ErrorKind::kNoSuchTable if the table does not exist.
Status UnregisterTable(const TableIdentifier& table_ident);

Expand Down
4 changes: 2 additions & 2 deletions src/iceberg/util/error_collector.h
Original file line number Diff line number Diff line change
Expand Up @@ -148,8 +148,8 @@ class ICEBERG_EXPORT ErrorCollector {
/// in Build(), Apply(), or Commit() methods) to validate that no errors
/// were accumulated during the builder method calls.
///
/// \return Status::OK if no errors, or a ValidationFailed error with
/// all accumulated error messages
/// \return Status indicating success if no errors, or a ValidationFailed
/// error with all accumulated error messages
[[nodiscard]] Status CheckErrors() const {
if (!errors_.empty()) {
std::string error_msg = "Validation failed due to the following errors:\n";
Expand Down
Loading