| 168 | } |
| 169 | |
| 170 | arrow::Result<std::unique_ptr<FlightInfo>> FlightSqlClient::ExecuteSubstrait( |
| 171 | const FlightCallOptions& options, const SubstraitPlan& plan, |
| 172 | const Transaction& transaction) { |
| 173 | flight_sql_pb::CommandStatementSubstraitPlan command; |
| 174 | SetPlan(plan, command.mutable_plan()); |
| 175 | if (transaction.is_valid()) { |
| 176 | command.set_transaction_id(transaction.transaction_id()); |
| 177 | } |
| 178 | |
| 179 | return GetFlightInfoForCommand(this, options, command); |
| 180 | } |
| 181 | |
| 182 | arrow::Result<std::unique_ptr<SchemaResult>> FlightSqlClient::GetExecuteSubstraitSchema( |
| 183 | const FlightCallOptions& options, const SubstraitPlan& plan, |