icexelloss commented on code in PR #35513:
URL: https://github.com/apache/arrow/pull/35513#discussion_r1188828755
##########
cpp/src/arrow/engine/substrait/serde.h:
##########
@@ -96,6 +96,26 @@ ARROW_ENGINE_EXPORT Result<std::shared_ptr<acero::ExecPlan>>
DeserializePlan(
const ExtensionIdRegistry* registry = NULLPTR, ExtensionSet* ext_set_out =
NULLPTR,
const ConversionOptions& conversion_options = {});
+/// \brief Deserializes a single-relation Substrait Plan message into an
execution plan
+///
+/// The output of each top-level Substrait relation will be sent to a caller
supplied
+/// consumer function provided by consumer_factory
+///
+/// \param[in,out] plan an ExecNode corresponding to the single toplevel
relation in the
+/// Substrait Plan
+/// \param[in] buf a buffer containing the protobuf serialization of a
Substrait Plan
+/// message
+/// \param[in] consumer node that consumes the batches produced by each
toplevel Substrait
+/// relation
+/// \param[in] registry an extension-id-registry to use, or null for the
default one.
+/// \param[out] ext_set_out if non-null, the extension mapping used by the
Substrait
+/// \param[in] conversion_options options to control how the conversion is to
be done.
+ARROW_ENGINE_EXPORT Status DeserializePlan(
Review Comment:
Also, shouldn't this return Result object similar to other Deserialize*
function?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
