vibhatha commented on code in PR #14024:
URL: https://github.com/apache/arrow/pull/14024#discussion_r961349699
##########
python/pyarrow/_substrait.pyx:
##########
@@ -102,3 +103,40 @@ def get_supported_functions():
for c_id in c_ids:
functions_list.append(frombytes(c_id))
return functions_list
+
+
+cdef shared_ptr[CTable] _process_named_table(dict named_args, const
std_vector[c_string]& names):
+ cdef c_string c_name
+ py_names = []
+ for i in range(names.size()):
+ c_name = names[i]
+ py_names.append(frombytes(c_name))
+ return pyarrow_unwrap_table(named_args["provider"](py_names))
+
+
+def run_query_with_provider(plan, table_provider):
Review Comment:
Of course, this was just a prototype code to show case for test purpose in a
short time. I already refactored the code. I think it covers what you are
asking for.
--
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]
