Metrics

Stateful Functions includes a number of SDK specific metrics. Along with the standard metric scopes, Stateful Functions supports Function Scope which one level below operator scope.

metrics.scope.function

  • Default: <host>.taskmanager.<tm_id>.<job_name>.<operator_name>.<subtask_index>.<function_namespace>.<function_name>
  • Applied to all metrics that were scoped to a function.
Metrics Scope Description Type
in
Function The number of incoming messages. Counter
inRate
Function The average number of incoming messages per second. Meter
out-local
Function The number of messages sent to a function on the same task slot. Counter
out-localRate
Function The average number of messages sent to a function on the same task slot per second. Meter
out-remote
Function The number of messages sent to a function on a different task slot. Counter
out-remoteRate
Function The average number of messages sent to a function on a different task slot per second. Meter
out-egress
Function The number of messages sent to an egress. Counter
feedback.produced
Operator The number of messages read from the feedback channel. Meter
feedback.producedRate
Operator The average number of messages read from the feedback channel per second. Meter