| 157 | } |
| 158 | |
| 159 | arrow::Result<std::unique_ptr<SchemaResult>> FlightSqlClient::GetExecuteSchema( |
| 160 | const FlightCallOptions& options, const std::string& query, |
| 161 | const Transaction& transaction) { |
| 162 | flight_sql_pb::CommandStatementQuery command; |
| 163 | command.set_query(query); |
| 164 | if (transaction.is_valid()) { |
| 165 | command.set_transaction_id(transaction.transaction_id()); |
| 166 | } |
| 167 | return GetSchemaForCommand(this, options, command); |
| 168 | } |
| 169 | |
| 170 | arrow::Result<std::unique_ptr<FlightInfo>> FlightSqlClient::ExecuteSubstrait( |
| 171 | const FlightCallOptions& options, const SubstraitPlan& plan, |