Details
-
New Feature
-
Status: Resolved
-
P2
-
Resolution: Done
-
None
Description
Introduce the usage of metrics API in IOs.
POC using CountingInput:
- Add metrics to CountingInput
- RunnableOnService test which creates a pipeline which asserts these metrics.
- Close any gaps in Direct runner and Spark runner to support these metrics.
Attachments
Issue Links
- blocks
-
BEAM-1398 KafkaIO metrics
- Resolved
- links to