Struct FlightRowSet

server/flightclient/flight_executor.go:491–504

FlightRowSet wraps an Arrow Flight RecordBatch reader to implement RowSet.

func (e *FlightExecutor) forwardQueryLogEntry(ctx context.Context, entry wire.QueryLogEntry) (err error) {
	if e.dead.Load() {
		observe.AddQueryLogDroppedEntries("forward_worker_dead", 1)
		return nil
	}
	if e.client == nil || e.client.Client == nil {
		observe.AddQueryLogDroppedEntries("forward_unavailable", 1)
		return nil
	}
	defer func() {
		recoverClientPanic(&err)
		if err != nil {
			observe.AddQueryLogDroppedEntries("forward_error", 1)
		}
	}()

	payload, err := json.Marshal(wire.WorkerQueryLogPayload{
		WorkerControlMetadata: wire.WorkerControlMetadata{