Modify the existing config appropriately
(&self, mut config: SessionConfig)
| 80 | |
| 81 | /// Modify the existing config appropriately |
| 82 | pub fn update_config(&self, mut config: SessionConfig) -> SessionConfig { |
| 83 | if let Some(batch_size) = self.batch_size { |
| 84 | config = config.with_batch_size(batch_size); |
| 85 | } |
| 86 | |
| 87 | if let Some(partitions) = self.partitions { |
| 88 | config = config.with_target_partitions(partitions); |
| 89 | } |
| 90 | |
| 91 | if let Some(sort_spill_reservation_bytes) = self.sort_spill_reservation_bytes { |
| 92 | config = |
| 93 | config.with_sort_spill_reservation_bytes(sort_spill_reservation_bytes); |
| 94 | } |
| 95 | |
| 96 | config |
| 97 | } |
| 98 | |
| 99 | /// Return an appropriately configured `RuntimeEnvBuilder` |
| 100 | pub fn runtime_env_builder(&self) -> Result<RuntimeEnvBuilder> { |
no test coverage detected