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

Reply via email to