| 180 | } |
| 181 | |
| 182 | arrow::Result<std::unique_ptr<SchemaResult>> FlightSqlClient::GetExecuteSubstraitSchema( |
| 183 | const FlightCallOptions& options, const SubstraitPlan& plan, |
| 184 | const Transaction& transaction) { |
| 185 | flight_sql_pb::CommandStatementSubstraitPlan command; |
| 186 | SetPlan(plan, command.mutable_plan()); |
| 187 | if (transaction.is_valid()) { |
| 188 | command.set_transaction_id(transaction.transaction_id()); |
| 189 | } |
| 190 | return GetSchemaForCommand(this, options, command); |
| 191 | } |
| 192 | |
| 193 | arrow::Result<int64_t> FlightSqlClient::ExecuteUpdate(const FlightCallOptions& options, |
| 194 | const std::string& query, |