Hello! I am trying to implement an ExecNode in Acero that receives the input batch, writes the batch to the FlightStreamWriter and then passes the batch to the downstream node.
Looking at the API, I am thinking of doing sth like : void InputReceived(ExecNode* input, ExecBatch batch) { # turn batch to RecordBatch # call flight_writer->WriteRecordBatch # call output_.inputReceived(this, batch); } My question is, how do I handle the error in WriteRecordBatch properly with ExecNode API? Thanks, Li