OutputMetricsUpdater
Related Docs:
object OutputMetricsUpdater
| package metrics
A method to be called when the task is finished.
A method to be called when the task is finished. It stops the task timer and flushes data.
Updates the metrics being collected for the connector after writing each single statement.
Updates the metrics being collected for the connector after writing each single statement. This method is thread-safe.
whether the statement succeeded or not
the statement - either bound or batch
the time when the write task has been submitted
the time when the write task has been really executed
A trait that provides a method to update write metrics which are collected for connector related tasks. The appropriate instance is created by the companion object.
Instances of
OutputMetricsUpdaterare thread-safe, because the Cassandra write task implementation is multi-threaded.