Update the `DataflowParameters` with new configuration.
(&mut self, storage_parameters: StorageParameters)
| 56 | } |
| 57 | /// Update the `DataflowParameters` with new configuration. |
| 58 | pub fn update(&mut self, storage_parameters: StorageParameters) { |
| 59 | self.upsert_rocksdb_tuning_config |
| 60 | .apply(storage_parameters.upsert_rocksdb_tuning_config.clone()); |
| 61 | } |
| 62 | } |
| 63 | |
| 64 | /// Internal commands that can be sent by individual operators/workers that will |
no test coverage detected