Warning
This functionality is still an experimental feature, and this page may be changed at any time.
Collect Metrics
To collect metrics such as the processing speed of each data group, you need to call the beginProcess and endProcess methods in your custom class that implements the MeasuredFlinkNode abstract class. After each call to the endProcess method, TEQ will automatically calculate and aggregate metrics such as the processing speed for each data group in the main process. Each process will have a UUID to identify it, which will be returned by the beginProcess method and needs to be passed into the endProcess method. In this way, you can collect almost all the metrics you want during each run.
Transform Metrics
To convert the collected metrics into the desired ones, you need to inherit from the SendingMetricsReceiver class and override the finishStream method. This method will receive a processing chain of a specific record, and you can transform this processing chain into the metrics you want and return them.
Display Metrics
To display your custom metrics in the user interface, you can call the addChart method of the MetricsDisplayer class.