| 167 | } |
| 168 | |
| 169 | AsofJoinNodeOptions GetRepeatedOptions(size_t repeat, FieldRef on_key, |
| 170 | std::vector<FieldRef> by_key, int64_t tolerance) { |
| 171 | std::vector<AsofJoinNodeOptions::Keys> input_keys(repeat); |
| 172 | for (size_t i = 0; i < repeat; i++) { |
| 173 | input_keys[i] = {on_key, by_key}; |
| 174 | } |
| 175 | return AsofJoinNodeOptions(input_keys, tolerance); |
| 176 | } |
| 177 | |
| 178 | // mutates by copying from_key into to_key and changing from_key to zero |
| 179 | Result<BatchesWithSchema> MutateByKey(BatchesWithSchema& batches, std::string from_key, |
no outgoing calls
no test coverage detected