| 183 | } |
| 184 | |
| 185 | Status Validate() const override { |
| 186 | ARROW_RETURN_NOT_OK(ExecNode::Validate()); |
| 187 | if (output_ != nullptr) { |
| 188 | return Status::Invalid("Sink node '", label(), "' has an output"); |
| 189 | } |
| 190 | if (inputs_[0]->ordering().is_unordered() && !!sequencer_) { |
| 191 | return Status::Invalid("Sink node '", label(), |
| 192 | "' is configured to sequence output but there is no " |
| 193 | "meaningful ordering in the input"); |
| 194 | } |
| 195 | return Status::OK(); |
| 196 | } |
| 197 | |
| 198 | void RecordBackpressureBytesUsed(const ExecBatch& batch) { |
| 199 | if (backpressure_queue_.enabled()) { |