| 722 | } |
| 723 | |
| 724 | ::arrow::Result<SetSessionOptionsResult> FlightClient::SetSessionOptions( |
| 725 | const FlightCallOptions& options, const SetSessionOptionsRequest& request) { |
| 726 | RETURN_NOT_OK(CheckOpen()); |
| 727 | ARROW_ASSIGN_OR_RAISE(auto body, request.SerializeToBuffer()); |
| 728 | Action action{ActionType::kSetSessionOptions.type, std::move(body)}; |
| 729 | ARROW_ASSIGN_OR_RAISE(auto stream, DoAction(options, action)); |
| 730 | ARROW_ASSIGN_OR_RAISE(auto result, stream->Next()); |
| 731 | ARROW_ASSIGN_OR_RAISE( |
| 732 | auto set_session_options_result, |
| 733 | SetSessionOptionsResult::Deserialize(std::string_view(*result->body))); |
| 734 | ARROW_RETURN_NOT_OK(stream->Drain()); |
| 735 | return set_session_options_result; |
| 736 | } |
| 737 | |
| 738 | ::arrow::Result<GetSessionOptionsResult> FlightClient::GetSessionOptions( |
| 739 | const FlightCallOptions& options, const GetSessionOptionsRequest& request) { |