| 122 | } |
| 123 | |
| 124 | void enqueue( |
| 125 | const std::string& taskId, |
| 126 | const RowTypePtr& rowType, |
| 127 | vector_size_t size, |
| 128 | bool expectedBlock = false) { |
| 129 | enqueue(taskId, 0, rowType, size); |
| 130 | } |
| 131 | |
| 132 | // Returns the enqueued page byte size. |
| 133 | uint64_t enqueue( |