MCPcopy Create free account
hub / github.com/apache/arrow / _arrow_ExecPlan_Write

Function _arrow_ExecPlan_Write

r/src/arrowExports.cpp:1088–1109  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1086#if defined(ARROW_R_WITH_DATASET)
1087void ExecPlan_Write(const std::shared_ptr<acero::ExecPlan>& plan, const std::shared_ptr<acero::ExecNode>& final_node, const std::shared_ptr<arrow::Schema>& schema, const std::shared_ptr<ds::FileWriteOptions>& file_write_options, const std::shared_ptr<fs::FileSystem>& filesystem, std::string base_dir, const std::shared_ptr<ds::Partitioning>& partitioning, std::string basename_template, arrow::dataset::ExistingDataBehavior existing_data_behavior, int max_partitions, uint32_t max_open_files, uint64_t max_rows_per_file, uint64_t min_rows_per_group, uint64_t max_rows_per_group, bool create_directory, bool preserve_order);
1088extern "C" SEXP _arrow_ExecPlan_Write(SEXP plan_sexp, SEXP final_node_sexp, SEXP schema_sexp, SEXP file_write_options_sexp, SEXP filesystem_sexp, SEXP base_dir_sexp, SEXP partitioning_sexp, SEXP basename_template_sexp, SEXP existing_data_behavior_sexp, SEXP max_partitions_sexp, SEXP max_open_files_sexp, SEXP max_rows_per_file_sexp, SEXP min_rows_per_group_sexp, SEXP max_rows_per_group_sexp, SEXP create_directory_sexp, SEXP preserve_order_sexp){
1089BEGIN_CPP11
1090 arrow::r::Input<const std::shared_ptr<acero::ExecPlan>&>::type plan(plan_sexp);
1091 arrow::r::Input<const std::shared_ptr<acero::ExecNode>&>::type final_node(final_node_sexp);
1092 arrow::r::Input<const std::shared_ptr<arrow::Schema>&>::type schema(schema_sexp);
1093 arrow::r::Input<const std::shared_ptr<ds::FileWriteOptions>&>::type file_write_options(file_write_options_sexp);
1094 arrow::r::Input<const std::shared_ptr<fs::FileSystem>&>::type filesystem(filesystem_sexp);
1095 arrow::r::Input<std::string>::type base_dir(base_dir_sexp);
1096 arrow::r::Input<const std::shared_ptr<ds::Partitioning>&>::type partitioning(partitioning_sexp);
1097 arrow::r::Input<std::string>::type basename_template(basename_template_sexp);
1098 arrow::r::Input<arrow::dataset::ExistingDataBehavior>::type existing_data_behavior(existing_data_behavior_sexp);
1099 arrow::r::Input<int>::type max_partitions(max_partitions_sexp);
1100 arrow::r::Input<uint32_t>::type max_open_files(max_open_files_sexp);
1101 arrow::r::Input<uint64_t>::type max_rows_per_file(max_rows_per_file_sexp);
1102 arrow::r::Input<uint64_t>::type min_rows_per_group(min_rows_per_group_sexp);
1103 arrow::r::Input<uint64_t>::type max_rows_per_group(max_rows_per_group_sexp);
1104 arrow::r::Input<bool>::type create_directory(create_directory_sexp);
1105 arrow::r::Input<bool>::type preserve_order(preserve_order_sexp);
1106 ExecPlan_Write(plan, final_node, schema, file_write_options, filesystem, base_dir, partitioning, basename_template, existing_data_behavior, max_partitions, max_open_files, max_rows_per_file, min_rows_per_group, max_rows_per_group, create_directory, preserve_order);
1107 return R_NilValue;
1108END_CPP11
1109}
1110#else
1111extern "C" SEXP _arrow_ExecPlan_Write(SEXP plan_sexp, SEXP final_node_sexp, SEXP schema_sexp, SEXP file_write_options_sexp, SEXP filesystem_sexp, SEXP base_dir_sexp, SEXP partitioning_sexp, SEXP basename_template_sexp, SEXP existing_data_behavior_sexp, SEXP max_partitions_sexp, SEXP max_open_files_sexp, SEXP max_rows_per_file_sexp, SEXP min_rows_per_group_sexp, SEXP max_rows_per_group_sexp, SEXP create_directory_sexp, SEXP preserve_order_sexp){
1112 Rf_error("Cannot call ExecPlan_Write(). See https://arrow.apache.org/docs/r/articles/install.html for help installing Arrow C++ libraries. ");

Callers

nothing calls this directly

Calls 1

ExecPlan_WriteFunction · 0.85

Tested by

no test coverage detected