(self, name: str, namespace: str = "BeamWriter")
| 515 | |
| 516 | @functools.lru_cache() |
| 517 | def _get_counter(self, name: str, namespace: str = "BeamWriter"): |
| 518 | return beam.metrics.Metrics.counter(namespace, name) |
| 519 | |
| 520 | @functools.lru_cache() |
| 521 | def _get_distribution(self, name: str, namespace: str = "BeamWriter"): |